/* * Copyright 2022 The Android Open Source Project * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #include #include #include #include #include #include "hci/controller_interface_mock.h" #include "osi/include/allocator.h" #include "stack/btm/btm_int_types.h" #include "stack/include/bt_psm_types.h" #include "stack/include/l2cap_controller_interface.h" #include "stack/include/l2cap_hci_link_interface.h" #include "stack/include/l2cap_module.h" #include "stack/include/l2cdefs.h" #include "stack/l2cap/l2c_int.h" #include "test/mock/mock_main_shim_entry.h" tBTM_CB btm_cb; extern tL2C_CB l2cb; void l2c_link_send_to_lower_br_edr(tL2C_LCB* p_lcb, BT_HDR* p_buf); void l2c_link_send_to_lower_ble(tL2C_LCB* p_lcb, BT_HDR* p_buf); using testing::Return; namespace { constexpr uint16_t kAclBufferCountClassic = 123; constexpr uint16_t kAclBufferCountBle = 45; constexpr uint16_t kAclBufferSizeBle = 45; } // namespace class StackL2capTest : public ::testing::Test { protected: void SetUp() override { bluetooth::hci::testing::mock_controller_ = &controller_interface_; ON_CALL(controller_interface_, GetNumAclPacketBuffers) .WillByDefault(Return(kAclBufferCountClassic)); bluetooth::hci::LeBufferSize le_sizes; le_sizes.total_num_le_packets_ = kAclBufferCountBle; le_sizes.le_data_packet_length_ = kAclBufferSizeBle; ON_CALL(controller_interface_, GetLeBufferSize).WillByDefault(Return(le_sizes)); ON_CALL(controller_interface_, SupportsBle).WillByDefault(Return(true)); l2c_init(); } void TearDown() override { l2c_free(); bluetooth::hci::testing::mock_controller_ = nullptr; } bluetooth::hci::testing::MockControllerInterface controller_interface_; }; TEST_F(StackL2capTest, l2cble_process_data_length_change_event) { l2cb.lcb_pool[0].tx_data_len = 0xdead; // ACL unknown and legal inputs l2cble_process_data_length_change_event(0x1234, 0x001b, 0x001b); ASSERT_EQ(0xdead, l2cb.lcb_pool[0].tx_data_len); l2cb.lcb_pool[0].in_use = true; l2cu_set_lcb_handle(l2cb.lcb_pool[0], 0x1234); ASSERT_EQ(0x1234, l2cb.lcb_pool[0].Handle()); // ACL known and illegal inputs l2cble_process_data_length_change_event(0x1234, 1, 1); ASSERT_EQ(0xdead, l2cb.lcb_pool[0].tx_data_len); // ACL known and legal inputs l2cble_process_data_length_change_event(0x1234, 0x001b, 0x001b); ASSERT_EQ(0x001b, l2cb.lcb_pool[0].tx_data_len); } class StackL2capChannelTest : public StackL2capTest { protected: void SetUp() override { StackL2capTest::SetUp(); } void TearDown() override { StackL2capTest::TearDown(); } tL2C_CCB ccb_ = { .in_use = true, .chnl_state = CST_OPEN, // tL2C_CHNL_STATE .local_conn_cfg = { // tL2CAP_LE_CFG_INFO .result = tL2CAP_CFG_RESULT::L2CAP_CFG_OK, .mtu = 100, .mps = 100, .credits = L2CA_LeCreditDefault(), .number_of_channels = L2CAP_CREDIT_BASED_MAX_CIDS, }, .peer_conn_cfg = { // tL2CAP_LE_CFG_INFO .result = tL2CAP_CFG_RESULT::L2CAP_CFG_OK, .mtu = 100, .mps = 100, .credits = L2CA_LeCreditDefault(), .number_of_channels = L2CAP_CREDIT_BASED_MAX_CIDS, }, .is_first_seg = false, .ble_sdu = nullptr, // BT_HDR*; Buffer for storing unassembled sdu .ble_sdu_length = 0, /* Length of unassembled sdu length*/ .p_next_ccb = nullptr, // struct t_l2c_ccb* Next CCB in the chain .p_prev_ccb = nullptr, // struct t_l2c_ccb* Previous CCB in the chain .p_lcb = nullptr, // struct t_l2c_linkcb* Link this CCB is assigned to .local_cid = 40, .remote_cid = 80, .l2c_ccb_timer = nullptr, // alarm_t* CCB Timer Entry .p_rcb = nullptr, // tL2C_RCB* Registration CB for this Channel .config_done = 0, // Configuration flag word .remote_config_rsp_result = tL2CAP_CFG_RESULT::L2CAP_CFG_OK, // The config rsp result from remote .local_id = 12, // Transaction ID for local trans .remote_id = 22, // Transaction ID for local .flags = 0, .connection_initiator = false, .our_cfg = {}, // tL2CAP_CFG_INFO Our saved configuration options .peer_cfg = {}, // tL2CAP_CFG_INFO Peer's saved configuration options .xmit_hold_q = nullptr, // fixed_queue_t* Transmit data hold queue .cong_sent = false, .buff_quota = 0, .ccb_priority = L2CAP_CHNL_PRIORITY_HIGH, // tL2CAP_CHNL_PRIORITY Channel priority .tx_data_rate = 0, // tL2CAP_CHNL_PRIORITY Channel Tx data rate .rx_data_rate = 0, // tL2CAP_CHNL_PRIORITY Channel Rx data rate .ertm_info = { // .tL2CAP_ERTM_INFO .preferred_mode = 0, }, .fcrb = { // tL2C_FCRB .next_tx_seq = 0, .last_rx_ack = 0, .next_seq_expected = 0, .last_ack_sent = 0, .num_tries = 0, .max_held_acks = 0, .remote_busy = false, .rej_sent = false, .srej_sent = false, .wait_ack = false, .rej_after_srej = false, .send_f_rsp = false, .rx_sdu_len = 0, .p_rx_sdu = nullptr, // BT_HDR* Buffer holding the SDU being received .waiting_for_ack_q = nullptr, // fixed_queue_t* .srej_rcv_hold_q = nullptr, // fixed_queue_t* .retrans_q = nullptr, // fixed_queue_t* .ack_timer = nullptr, // alarm_t* .mon_retrans_timer = nullptr, // alarm_t* }, .tx_mps = 0, .max_rx_mtu = 0, .fcr_cfg_tries = 0, .peer_cfg_already_rejected = false, .out_cfg_fcr_present = false, .is_flushable = false, .fixed_chnl_idle_tout = 0, .tx_data_len = 0, .remote_credit_count = 0, .ecoc = false, .reconfig_started = false, .metrics = {}, }; }; TEST_F(StackL2capChannelTest, l2c_lcc_proc_pdu__FirstSegment) { ccb_.is_first_seg = true; BT_HDR* p_buf = (BT_HDR*)osi_calloc(sizeof(BT_HDR) + 32); p_buf->len = 32; l2c_lcc_proc_pdu(&ccb_, p_buf); } TEST_F(StackL2capChannelTest, l2c_lcc_proc_pdu__NextSegment) { BT_HDR* p_buf = (BT_HDR*)osi_calloc(sizeof(BT_HDR) + 32); p_buf->len = 32; l2c_lcc_proc_pdu(&ccb_, p_buf); } TEST_F(StackL2capChannelTest, l2c_link_init) { l2cb.num_lm_acl_bufs = 0; l2cb.controller_xmit_window = 0; l2c_link_init(kAclBufferCountClassic); ASSERT_EQ(kAclBufferCountClassic, l2cb.num_lm_acl_bufs); ASSERT_EQ(kAclBufferCountClassic, l2cb.controller_xmit_window); } TEST_F(StackL2capTest, l2cap_result_code_text) { std::vector> results = { std::make_pair(tL2CAP_CONN::L2CAP_CONN_OK, "tL2CAP_CONN::L2CAP_CONN_OK(0x0000)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_PENDING, "tL2CAP_CONN::L2CAP_CONN_PENDING(0x0001)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_NO_PSM, "tL2CAP_CONN::L2CAP_CONN_NO_PSM(0x0002)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_SECURITY_BLOCK, "tL2CAP_CONN::L2CAP_CONN_SECURITY_BLOCK(0x0003)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_NO_RESOURCES, "tL2CAP_CONN::L2CAP_CONN_NO_RESOURCES(0x0004)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_TIMEOUT, "tL2CAP_CONN::L2CAP_CONN_TIMEOUT(0xeeee)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_OTHER_ERROR, "tL2CAP_CONN::L2CAP_CONN_OTHER_ERROR(0xf000)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_ACL_CONNECTION_FAILED, "tL2CAP_CONN::L2CAP_CONN_ACL_CONNECTION_FAILED(0xf001)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_CLIENT_SECURITY_CLEARANCE_FAILED, "tL2CAP_CONN::L2CAP_CONN_CLIENT_SECURITY_CLEARANCE_FAILED(0xf002)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_NO_LINK, "tL2CAP_CONN::L2CAP_CONN_NO_LINK(0xf003)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_CANCEL, "tL2CAP_CONN::L2CAP_CONN_CANCEL(0xf004)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_INSUFFICIENT_AUTHENTICATION, "tL2CAP_CONN::L2CAP_CONN_INSUFFICIENT_AUTHENTICATION(0xff05)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_INSUFFICIENT_AUTHORIZATION, "tL2CAP_CONN::L2CAP_CONN_INSUFFICIENT_AUTHORIZATION(0xff06)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_INSUFFICIENT_ENCRYP_KEY_SIZE, "tL2CAP_CONN::L2CAP_CONN_INSUFFICIENT_ENCRYP_KEY_SIZE(0xff07)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_INSUFFICIENT_ENCRYP, "tL2CAP_CONN::L2CAP_CONN_INSUFFICIENT_ENCRYP(0xff08)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_INVALID_SOURCE_CID, "tL2CAP_CONN::L2CAP_CONN_INVALID_SOURCE_CID(0xff09)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_SOURCE_CID_ALREADY_ALLOCATED, "tL2CAP_CONN::L2CAP_CONN_SOURCE_CID_ALREADY_ALLOCATED(0xff0a)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_UNACCEPTABLE_PARAMETERS, "tL2CAP_CONN::L2CAP_CONN_UNACCEPTABLE_PARAMETERS(0xff0b)"), std::make_pair(tL2CAP_CONN::L2CAP_CONN_INVALID_PARAMETERS, "tL2CAP_CONN::L2CAP_CONN_INVALID_PARAMETERS(0xff0c)"), }; for (const auto& result : results) { ASSERT_STREQ(result.second.c_str(), l2cap_result_code_text(result.first).c_str()); } std::ostringstream oss; oss << "Unknown tL2CAP_CONN(" << std::hex << "0x" << std::numeric_limits::max() << ")"; ASSERT_STREQ(oss.str().c_str(), l2cap_result_code_text( static_cast(std::numeric_limits::max())) .c_str()); } TEST_F(StackL2capTest, L2CA_Dumpsys) { int sv[2]; char buf[32]; ASSERT_EQ(0, socketpair(AF_UNIX, SOCK_STREAM, 0, sv)); ASSERT_EQ(0, fcntl(sv[1], F_SETFL, fcntl(sv[1], F_GETFL, 0) | O_NONBLOCK)); L2CA_Dumpsys(sv[0]); while (read(sv[1], buf, sizeof(buf)) != -1) { } } TEST_F(StackL2capTest, bt_psm_text) { std::map map = { {BT_PSM_SDP, "BT_PSM_SDP"}, {BT_PSM_RFCOMM, "BT_PSM_RFCOMM"}, {BT_PSM_TCS, "BT_PSM_TCS"}, {BT_PSM_CTP, "BT_PSM_CTP"}, {BT_PSM_BNEP, "BT_PSM_BNEP"}, {BT_PSM_HIDC, "BT_PSM_HIDC"}, {HID_PSM_CONTROL, "HID_PSM_CONTROL"}, {BT_PSM_HIDI, "BT_PSM_HIDI"}, {HID_PSM_INTERRUPT, "HID_PSM_INTERRUPT"}, {BT_PSM_UPNP, "BT_PSM_UPNP"}, {BT_PSM_AVCTP, "BT_PSM_AVCTP"}, {BT_PSM_AVDTP, "BT_PSM_AVDTP"}, {BT_PSM_AVCTP_BROWSE, "BT_PSM_AVCTP_BROWSE"}, {BT_PSM_UDI_CP, "BT_PSM_UDI_CP"}, {BT_PSM_ATT, "BT_PSM_ATT"}, {BT_PSM_EATT, "BT_PSM_EATT"}, {BRCM_RESERVED_PSM_START, "BRCM_RESERVED_PSM_START"}, {BRCM_RESERVED_PSM_END, "BRCM_RESERVED_PSM_END"}, }; for (const auto& it : map) { bluetooth::log::info("{} {} ", bt_psm_text(it.first), it.second); } }