| /packages/modules/Bluetooth/system/stack/gatt/ |
| D | gatt_sr.cc | 60 uint32_t gatt_sr_enqueue_cmd(tGATT_TCB& tcb, uint16_t cid, uint8_t op_code, in gatt_sr_enqueue_cmd() argument
64 if (cid == tcb.att_lcid) { in gatt_sr_enqueue_cmd()
65 p_cmd = &tcb.sr_cmd; in gatt_sr_enqueue_cmd()
68 EattExtension::GetInstance()->FindEattChannelByCid(tcb.peer_bda, cid); in gatt_sr_enqueue_cmd()
70 log::warn("{}, cid 0x{:02x} already disconnected", tcb.peer_bda, cid); in gatt_sr_enqueue_cmd()
86 trans_id = ++tcb.trans_id; in gatt_sr_enqueue_cmd()
88 p_cmd->trans_id = ++tcb.trans_id; in gatt_sr_enqueue_cmd()
92 tcb.trans_id %= GATT_TRANS_ID_MAX; in gatt_sr_enqueue_cmd()
109 bool gatt_sr_cmd_empty(tGATT_TCB& tcb, uint16_t cid) { in gatt_sr_cmd_empty() argument
110 if (cid == tcb.att_lcid) return (tcb.sr_cmd.op_code == 0); in gatt_sr_cmd_empty()
[all …]
|
| D | gatt_utils.cc | 293 if (gatt_cb.tcb[i].in_use && gatt_cb.tcb[i].ch_state == GATT_CH_OPEN) { in gatt_find_the_connected_bda()
294 bda = gatt_cb.tcb[i].peer_bda; in gatt_find_the_connected_bda()
296 *p_transport = gatt_cb.tcb[i].transport; in gatt_find_the_connected_bda()
381 if (gatt_cb.tcb[i].in_use && gatt_cb.tcb[i].peer_bda == bda) { in gatt_is_bda_connected()
403 if (gatt_cb.tcb[i].peer_bda == bda && in gatt_find_i_tcb_by_addr()
404 gatt_cb.tcb[i].transport == transport) { in gatt_find_i_tcb_by_addr()
423 if ((tcb_idx < gatt_get_max_phy_channel()) && gatt_cb.tcb[tcb_idx].in_use) in gatt_get_tcb_by_idx()
424 p_tcb = &gatt_cb.tcb[tcb_idx]; in gatt_get_tcb_by_idx()
444 if (i != GATT_INDEX_INVALID) p_tcb = &gatt_cb.tcb[i]; in gatt_find_tcb_by_addr()
463 tGATT_TCB* p_tcb = &gatt_cb.tcb[i]; in gatt_tcb_dump()
[all …]
|
| D | gatt_attr.cc | 641 tGATT_TCB& tcb = gatt_cb.tcb[tcb_idx]; in gatt_cl_op_cmpl_cback() local
648 STREAM_TO_UINT8(tcb.sr_supp_feat, pp); in gatt_cl_op_cmpl_cback()
649 btif_storage_set_gatt_sr_supp_feat(tcb.peer_bda, tcb.sr_supp_feat); in gatt_cl_op_cmpl_cback()
653 std::move(operation_callback_data.cb).Run(tcb.peer_bda, tcb.sr_supp_feat); in gatt_cl_op_cmpl_cback()
659 if (tcb.sr_supp_feat & BLE_GATT_SVR_SUP_FEAT_EATT_BITMASK) { in gatt_cl_op_cmpl_cback()
667 tGATT_TCB& tcb = gatt_cb.tcb[tcb_idx]; in gatt_cl_op_cmpl_cback() local
671 tcb.gatt_status = status; in gatt_cl_op_cmpl_cback()
674 STREAM_TO_UINT8(tcb.sirk_type, pp); in gatt_cl_op_cmpl_cback()
675 STREAM_TO_ARRAY(tcb.sirk.data(), pp, 16); in gatt_cl_op_cmpl_cback()
679 .Run(tcb.gatt_status, tcb.peer_bda, tcb.sirk_type, tcb.sirk); in gatt_cl_op_cmpl_cback()
[all …]
|
| D | gatt_cl.cc | 63 void gatt_send_prepare_write(tGATT_TCB& tcb, tGATT_CLCB* p_clcb);
152 tGATT_TCB& tcb = *p_clcb->p_tcb; in gatt_act_read() local
219 if (op_code != 0) rt = attp_send_cl_msg(tcb, p_clcb, op_code, &msg); in gatt_act_read()
228 tGATT_TCB& tcb = *p_clcb->p_tcb; in gatt_act_write() local
234 uint16_t payload_size = gatt_tcb_get_payload_size(tcb, p_clcb->cid); in gatt_act_write()
241 tGATT_STATUS rt = gatt_send_write_msg(tcb, p_clcb, op_code, attr.handle, in gatt_act_write()
258 tcb, p_clcb, GATT_REQ_WRITE, attr.handle, attr.len, 0, attr.value); in gatt_act_write()
270 gatt_send_prepare_write(tcb, p_clcb); in gatt_act_write()
276 gatt_send_prepare_write(tcb, p_clcb); in gatt_act_write()
293 void gatt_send_queue_write_cancel(tGATT_TCB& tcb, tGATT_CLCB* p_clcb, in gatt_send_queue_write_cancel() argument
[all …]
|
| D | gatt_int.h | 406 tGATT_TCB tcb[GATT_MAX_PHY_CHANNEL]; member
496 void gatt_cl_init_sr_status(tGATT_TCB& tcb);
505 bool gatt_sr_is_cl_multi_variable_len_notif_supported(tGATT_TCB& tcb);
507 bool gatt_sr_is_cl_change_aware(tGATT_TCB& tcb);
508 void gatt_sr_init_cl_status(tGATT_TCB& tcb);
509 void gatt_sr_update_cl_status(tGATT_TCB& tcb, bool chg_aware);
512 tGATT_STATUS attp_send_cl_confirmation_msg(tGATT_TCB& tcb, uint16_t cid);
513 tGATT_STATUS attp_send_cl_msg(tGATT_TCB& tcb, tGATT_CLCB* p_clcb,
515 BT_HDR* attp_build_sr_msg(tGATT_TCB& tcb, uint8_t op_code, tGATT_SR_MSG* p_msg,
517 tGATT_STATUS attp_send_sr_msg(tGATT_TCB& tcb, uint16_t cid, BT_HDR* p_msg);
[all …]
|
| D | att_protocol.cc | 375 tGATT_STATUS attp_send_msg_to_l2cap(tGATT_TCB& tcb, uint16_t lcid, in attp_send_msg_to_l2cap() argument
381 l2cap_ret = L2CA_SendFixedChnlData(lcid, tcb.peer_bda, p_toL2CAP); in attp_send_msg_to_l2cap()
398 BT_HDR* attp_build_sr_msg(tGATT_TCB& tcb, uint8_t op_code, tGATT_SR_MSG* p_msg, in attp_build_sr_msg() argument
405 op_code, tcb.peer_bda); in attp_build_sr_msg()
457 tGATT_STATUS attp_send_sr_msg(tGATT_TCB& tcb, uint16_t cid, BT_HDR* p_msg) { in attp_send_sr_msg() argument
465 return attp_send_msg_to_l2cap(tcb, cid, p_msg); in attp_send_sr_msg()
480 static tGATT_STATUS attp_cl_send_cmd(tGATT_TCB& tcb, tGATT_CLCB* p_clcb, in attp_cl_send_cmd() argument
484 if (gatt_tcb_is_cid_busy(tcb, p_clcb->cid) && in attp_cl_send_cmd()
486 if (gatt_cmd_enq(tcb, p_clcb, true, cmd_code, p_cmd)) { in attp_cl_send_cmd()
492 log::error("{}, cid 0x{:02x} already disconnected", tcb.peer_bda, in attp_cl_send_cmd()
[all …]
|
| D | gatt_auth.cc | 101 void gatt_verify_signature(tGATT_TCB& tcb, uint16_t cid, BT_HDR* p_buf) { in gatt_verify_signature() argument
116 if (!BTM_BleVerifySignature(tcb.peer_bda, p_orig, cmd_len, counter, p)) { in gatt_verify_signature()
123 gatt_server_handle_client_req(tcb, cid, op_code, (uint16_t)(p_buf->len - 1), in gatt_verify_signature()
350 tGATT_STATUS gatt_get_link_encrypt_status(tGATT_TCB& tcb) { in gatt_get_link_encrypt_status() argument
353 bool encrypted = BTM_IsEncrypted(tcb.peer_bda, tcb.transport); in gatt_get_link_encrypt_status()
354 bool link_key_known = BTM_IsLinkKeyKnown(tcb.peer_bda, tcb.transport); in gatt_get_link_encrypt_status()
355 bool link_key_authed = BTM_IsLinkKeyAuthed(tcb.peer_bda, tcb.transport); in gatt_get_link_encrypt_status()
|
| D | gatt_main.cc | 178 gatt_cb.tcb[i].pending_enc_clcb = std::deque<tGATT_CLCB*>(); in gatt_free()
180 fixed_queue_free(gatt_cb.tcb[i].pending_ind_q, NULL); in gatt_free()
181 gatt_cb.tcb[i].pending_ind_q = NULL; in gatt_free()
183 alarm_free(gatt_cb.tcb[i].conf_timer); in gatt_free()
184 gatt_cb.tcb[i].conf_timer = NULL; in gatt_free()
186 alarm_free(gatt_cb.tcb[i].ind_ack_timer); in gatt_free()
187 gatt_cb.tcb[i].ind_ack_timer = NULL; in gatt_free()
189 fixed_queue_free(gatt_cb.tcb[i].sr_cmd.multi_rsp_q, NULL); in gatt_free()
190 gatt_cb.tcb[i].sr_cmd.multi_rsp_q = NULL; in gatt_free()
192 if (gatt_cb.tcb[i].eatt) in gatt_free()
[all …]
|
| D | gatt_db.cc | 44 tGATT_TCB& tcb, uint16_t cid, uint8_t op_code, uint16_t handle,
277 tGATT_TCB& tcb, uint16_t cid, tGATT_SVC_DB* p_db, uint8_t op_code, in gatts_db_read_attr_value_by_type() argument
299 status = gatts_send_app_read_request(tcb, cid, op_code, attr.handle, in gatts_db_read_attr_value_by_type()
475 tGATT_TCB& tcb, uint16_t cid, tGATT_SVC_DB* p_db, uint8_t op_code, in gatts_read_attr_value_by_handle() argument
488 status = gatts_send_app_read_request(tcb, cid, op_code, p_attr->handle, in gatts_read_attr_value_by_handle()
702 tGATT_TCB& tcb, uint16_t cid, uint8_t op_code, uint16_t handle, in gatts_send_app_read_request() argument
705 uint16_t conn_id = GATT_CREATE_CONN_ID(tcb.tcb_idx, el.gatt_if); in gatts_send_app_read_request()
708 trans_id = gatt_sr_enqueue_cmd(tcb, cid, op_code, handle); in gatts_send_app_read_request()
709 gatt_sr_update_cback_cnt(tcb, cid, el.gatt_if, true, true); in gatts_send_app_read_request()
|
| D | gatt_api.cc | 149 tGATT_TCB& tcb = gatt_cb.tcb[i]; in gatt_update_for_database_change() local
150 if (tcb.in_use) gatt_sr_update_cl_status(tcb, /* chg_aware= */ false); in gatt_update_for_database_change()
1304 for (i = 0, p_tcb = gatt_cb.tcb; i < GATT_MAX_PHY_CHANNEL; i++, p_tcb++) { in GATT_Deregister()
|
| /packages/modules/Bluetooth/system/stack/test/gatt/ |
| D | mock_gatt_utils_ref.cc | 34 BT_HDR* attp_build_sr_msg(tGATT_TCB& tcb, uint8_t op_code, tGATT_SR_MSG* p_msg, in attp_build_sr_msg() argument
38 tGATT_STATUS attp_send_cl_confirmation_msg(tGATT_TCB& tcb, uint16_t cid) { in attp_send_cl_confirmation_msg() argument
41 tGATT_STATUS attp_send_cl_msg(tGATT_TCB& tcb, tGATT_CLCB* p_clcb, in attp_send_cl_msg() argument
45 tGATT_STATUS attp_send_sr_msg(tGATT_TCB& tcb, uint16_t cid, BT_HDR* p_msg) { in attp_send_sr_msg() argument
50 void gatt_sr_init_cl_status(tGATT_TCB& tcb) {} in gatt_sr_init_cl_status() argument
64 uint32_t gatt_sr_enqueue_cmd(tGATT_TCB& tcb, uint16_t cid, uint8_t op_code, in gatt_sr_enqueue_cmd() argument
66 void gatt_dequeue_sr_cmd(tGATT_TCB& tcb, uint16_t cid) {} in gatt_dequeue_sr_cmd() argument
|
| D | gatt_sr_test.cc | 65 BT_HDR* attp_build_sr_msg(tGATT_TCB& tcb, uint8_t op_code, tGATT_SR_MSG* p_msg, in attp_build_sr_msg() argument
70 tGATT_STATUS attp_send_cl_confirmation_msg(tGATT_TCB& tcb, uint16_t cid) { in attp_send_cl_confirmation_msg() argument
73 tGATT_STATUS attp_send_cl_msg(tGATT_TCB& tcb, tGATT_CLCB* p_clcb, in attp_send_cl_msg() argument
77 tGATT_STATUS attp_send_sr_msg(tGATT_TCB& tcb, uint16_t cid, BT_HDR* p_msg) { in attp_send_sr_msg() argument
85 tGATT_TCB& tcb, uint16_t cid, tGATT_SVC_DB* p_db, uint8_t op_code, in gatts_db_read_attr_value_by_type() argument
104 tGATT_TCB& tcb, uint16_t cid, tGATT_SVC_DB* p_db, uint8_t op_code, in gatts_read_attr_value_by_handle() argument
134 bool gatt_sr_is_cl_change_aware(tGATT_TCB& tcb) { return false; } in gatt_sr_is_cl_change_aware() argument
|
| /packages/modules/Bluetooth/system/stack/test/common/ |
| D | mock_gatt_layer.cc | 33 void gatt_cl_init_sr_status(tGATT_TCB& tcb) { in gatt_cl_init_sr_status() argument
34 return gatt_interface->ClientInitServerStatus(tcb); in gatt_cl_init_sr_status()
|
| D | mock_gatt_layer.h | 30 virtual void ClientInitServerStatus(tGATT_TCB& tcb) = 0;
40 MOCK_METHOD1(ClientInitServerStatus, void(tGATT_TCB& tcb));
|
| /packages/modules/Bluetooth/system/stack/test/eatt/ |
| D | eatt_test.cc | 58 void gatt_data_process(tGATT_TCB& tcb, uint16_t cid, BT_HDR* p_buf) { return; } in gatt_data_process() argument
|