Home
last modified time | relevance | path

Searched refs:conn (Results 1 – 25 of 61) sorted by relevance

123

/system/security/keystore2/src/database/
Dversioning.rs101 let mut conn = Connection::open_in_memory().unwrap(); in upgrade_database_test() localVariable
102 conn.execute("ATTACH DATABASE 'file::memory:' as persistent;", NO_PARAMS).unwrap(); in upgrade_database_test()
119 conn.execute( in upgrade_database_test()
134 conn.execute("DROP TABLE IF EXISTS persistent.version;", NO_PARAMS).unwrap(); in upgrade_database_test()
135 conn.execute("DROP TABLE IF EXISTS persistent.test;", NO_PARAMS).unwrap(); in upgrade_database_test()
136 conn.execute( in upgrade_database_test()
146 conn.transaction_with_behavior(TransactionBehavior::Immediate).unwrap(); in upgrade_database_test()
152 conn.transaction_with_behavior(TransactionBehavior::Immediate).unwrap(); in upgrade_database_test()
164 conn.query_row( in upgrade_database_test()
175 conn.query_row( in upgrade_database_test()
[all …]
/system/bt/btif/co/
Dbta_pan_co.cc75 btpan_conn_t* conn = btpan_find_conn_handle(handle); in bta_pan_co_close() local
76 if (conn && conn->state == PAN_STATE_OPEN) { in bta_pan_co_close()
82 conn->state = PAN_STATE_CLOSE; in bta_pan_co_close()
119 btpan_conn_t* conn = btpan_find_conn_handle(handle); in bta_pan_co_tx_path() local
120 if (!conn) { in bta_pan_co_tx_path()
123 } else if (conn->state != PAN_STATE_OPEN) { in bta_pan_co_tx_path()
125 __func__, conn, conn->state); in bta_pan_co_tx_path()
137 if (is_empty_eth_addr(conn->eth_addr) && is_valid_bt_eth_addr(src)) { in bta_pan_co_tx_path()
138 VLOG(1) << __func__ << " pan bt peer addr: " << conn->peer in bta_pan_co_tx_path()
140 conn->eth_addr = src; in bta_pan_co_tx_path()
[all …]
/system/bt/gd/cert/
Dos_utils.py72 …lambda conn: (conn and conn.status == psutil.CONN_LISTEN and conn.laddr and conn.laddr.port in por…
75 for conn in listening_conns_for_port:
76 logging.warning("Freeing port %d used by %s" % (conn.laddr.port, str(conn)))
77 if not conn.pid:
78 … logging.error("Failed to kill process occupying port %d due to lack of pid" % conn.laddr.port)
81 logging.warning("Killing pid %d that is using port port %d" % (conn.pid, conn.laddr.port))
82 process = psutil.Process(conn.pid)
87 … logging.error("SIGKILL timeout after %d seconds for pid %d" % (timeout_seconds, conn.pid))
/system/bt/btif/src/
Dbtif_pan.cc83 static void btpan_cleanup_conn(btpan_conn_t* conn);
219 btpan_conn_t* conn = btpan_find_conn_addr(*bd_addr); in btif_in_pan_generic_evt() local
222 asrt(conn != NULL); in btif_in_pan_generic_evt()
223 if (conn) { in btif_in_pan_generic_evt()
224 btpan_conn_local_role = bta_role_to_btpan(conn->local_role); in btif_in_pan_generic_evt()
225 btpan_remote_role = bta_role_to_btpan(conn->remote_role); in btif_in_pan_generic_evt()
227 BT_STATUS_SUCCESS, &conn->peer, in btif_in_pan_generic_evt()
238 btpan_conn_t* conn = btpan_find_conn_addr(*bd_addr); in btpan_disconnect() local
239 if (conn && conn->handle >= 0) { in btpan_disconnect()
244 BTA_PanClose(conn->handle); in btpan_disconnect()
[all …]
Dbtif_hd.cc200 RawAddress* addr = (RawAddress*)&p_data->conn.bda; in btif_hd_upstreams_evt()
211 btif_storage_set_hidd(p_data->conn.bda); in btif_hd_upstreams_evt()
214 (RawAddress*)&p_data->conn.bda, BTHD_CONN_STATE_CONNECTED); in btif_hd_upstreams_evt()
219 RawAddress* addr = (RawAddress*)&p_data->conn.bda; in btif_hd_upstreams_evt()
226 (RawAddress*)&p_data->conn.bda, BTHD_CONN_STATE_DISCONNECTED); in btif_hd_upstreams_evt()
251 (RawAddress*)&p_data->conn.bda, BTHD_CONN_STATE_DISCONNECTED); in btif_hd_upstreams_evt()
252 if (bta_dm_check_if_only_hd_connected(p_data->conn.bda)) { in btif_hd_upstreams_evt()
255 BTA_DmRemoveDevice(p_data->conn.bda); in btif_hd_upstreams_evt()
257 RawAddress* bd_addr = (RawAddress*)&p_data->conn.bda; in btif_hd_upstreams_evt()
269 (RawAddress*)&p_data->conn.bda, in btif_hd_upstreams_evt()
[all …]
Dbtif_gatt_server.cc143 btif_gatt_check_encrypted_link(p_data->conn.remote_bda, in btapp_gatts_handle_cback()
144 p_data->conn.transport); in btapp_gatts_handle_cback()
146 HAL_CBACK(bt_gatt_callbacks, server->connection_cb, p_data->conn.conn_id, in btapp_gatts_handle_cback()
147 p_data->conn.server_if, true, p_data->conn.remote_bda); in btapp_gatts_handle_cback()
152 HAL_CBACK(bt_gatt_callbacks, server->connection_cb, p_data->conn.conn_id, in btapp_gatts_handle_cback()
153 p_data->conn.server_if, false, p_data->conn.remote_bda); in btapp_gatts_handle_cback()
Dbtif_hh.cc774 p_data->conn.handle, p_data->conn.status); in btif_hh_upstreams_evt()
776 if (p_data->conn.status == BTA_HH_OK) { in btif_hh_upstreams_evt()
777 p_dev = btif_hh_find_connected_dev_by_handle(p_data->conn.handle); in btif_hh_upstreams_evt()
781 p_data->conn.handle); in btif_hh_upstreams_evt()
786 BTA_HhClose(p_data->conn.handle); in btif_hh_upstreams_evt()
788 (RawAddress*)&p_data->conn.bda, in btif_hh_upstreams_evt()
793 p_dev->bd_addr = p_data->conn.bda; in btif_hh_upstreams_evt()
797 BTA_HhClose(p_data->conn.handle); in btif_hh_upstreams_evt()
802 p_data->conn.handle); in btif_hh_upstreams_evt()
803 p_dev->bd_addr = p_data->conn.bda; in btif_hh_upstreams_evt()
[all …]
/system/bt/gd/rust/linux/service/src/
Dmain.rs41 let (resource, conn) = connection::new_system_sync()?; in main()
51 conn.request_name(DBUS_SERVICE_NAME, false, true, false).await?; in main()
56 conn.clone(), in main()
69 disconnect_watcher.lock().unwrap().setup_watch(conn.clone()).await; in main()
74 conn.clone(), in main()
82 conn.clone(), in main()
88 conn.start_receive( in main()
90 Box::new(move |msg, conn| { in main()
91 cr.handle_message(msg, conn).unwrap(); in main()
/system/bt/service/
Dgatt_server.cc208 for (const auto& conn : conn_iter->second) { in SendNotification() local
210 if (pending_indications_.find(conn->conn_id) != in SendNotification()
213 << " is already pending for connection: " << conn->conn_id; in SendNotification()
223 conn->conn_id, confirm, value); in SendNotification()
233 pending_indications_[conn->conn_id] = pending_ind; in SendNotification()
344 auto conn = GetConnection(conn_id, bda, trans_id); in RequestReadCharacteristicCallback() local
345 if (!conn) return; in RequestReadCharacteristicCallback()
354 conn->request_id_to_handle[trans_id] = attribute_handle; in RequestReadCharacteristicCallback()
377 auto conn = GetConnection(conn_id, bda, trans_id); in RequestReadDescriptorCallback() local
378 if (!conn) return; in RequestReadDescriptorCallback()
[all …]
/system/bt/stack/hid/
Dhidh_conn.cc121 hh_cb.devices[xx].conn.conn_state = HID_CONN_STATE_UNUSED; in hidh_conn_reg()
137 tHID_CONN* p_hcon = &hh_cb.devices[dhandle].conn; in hidh_conn_disconnect()
186 tHID_CONN* p_hcon = &hh_cb.devices[i].conn; in hidh_l2cif_connect_ind()
324 p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_connect_cfm()
380 p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_config_ind()
420 if (dhandle < kHID_HOST_MAX_DEVICES) p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_config_cfm()
493 if (dhandle < kHID_HOST_MAX_DEVICES) p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_disconnect_ind()
528 alarm_set_on_mloop(hh_cb.devices[dhandle].conn.process_repage_timer, in hidh_l2cif_disconnect_ind()
568 tHID_CONN* p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_disconnect()
604 if (dhandle < kHID_HOST_MAX_DEVICES) p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_cong_ind()
[all …]
Dhidd_conn.cc65 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_check_config_done()
108 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_connect_ind()
187 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_connect_cfm()
233 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_config_ind()
262 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_config_cfm()
306 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_disconnect_ind()
344 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_disconnect()
391 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_cong_ind()
428 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_data_ind()
618 if (p_dev->conn.conn_state != HID_CONN_STATE_UNUSED) { in hidd_conn_initiate()
[all …]
Dhidh_api.cc278 hh_cb.devices[i].conn.process_repage_timer = in HID_HostRegister()
300 alarm_free(hh_cb.devices[i].conn.process_repage_timer); in HID_HostDeregister()
369 hh_cb.devices[dev_handle].conn.conn_state = HID_CONN_STATE_UNUSED; in HID_HostRemoveDev()
370 hh_cb.devices[dev_handle].conn.ctrl_cid = in HID_HostRemoveDev()
371 hh_cb.devices[dev_handle].conn.intr_cid = 0; in HID_HostRemoveDev()
460 alarm_cancel(hh_cb.devices[dev_handle].conn.process_repage_timer); in HID_HostCloseDev()
/system/bt/stack/gap/
Dgap_conn.cc78 tGAP_CONN conn; variable
112 memset(&conn, 0, sizeof(tGAP_CONN)); in gap_conn_init()
113 conn.reg_info.pL2CA_ConnectInd_Cb = gap_connect_ind; in gap_conn_init()
114 conn.reg_info.pL2CA_ConnectCfm_Cb = gap_connect_cfm; in gap_conn_init()
115 conn.reg_info.pL2CA_ConfigInd_Cb = gap_config_ind; in gap_conn_init()
116 conn.reg_info.pL2CA_ConfigCfm_Cb = gap_config_cfm; in gap_conn_init()
117 conn.reg_info.pL2CA_DisconnectInd_Cb = gap_disconnect_ind; in gap_conn_init()
118 conn.reg_info.pL2CA_DataInd_Cb = gap_data_ind; in gap_conn_init()
119 conn.reg_info.pL2CA_CongestionStatus_Cb = gap_congestion_ind; in gap_conn_init()
120 conn.reg_info.pL2CA_TxComplete_Cb = gap_tx_complete_ind; in gap_conn_init()
[all …]
/system/bt/gd/rust/linux/dbus_projection/dbus_macros/src/
Dlib.rs151 let conn_clone = conn.clone(); in generate_dbus_exporter()
178 conn: std::sync::Arc<SyncConnection>, in generate_dbus_exporter()
184 conn: Arc<SyncConnection>, in generate_dbus_exporter()
193 let iface_token = get_iface_token(conn, cr, disconnect_watcher); in generate_dbus_exporter()
285 conn.clone(), in dbus_propmap()
315 conn.clone(), in dbus_propmap()
353 conn: Arc<SyncConnection>, in dbus_propmap()
448 let conn = self.conn.clone(); in dbus_proxy_obj() localVariable
454 conn, in dbus_proxy_obj()
476 conn: Arc<SyncConnection>, in dbus_proxy_obj()
[all …]
/system/nfc/src/fuzzers/rw/
Dmfc.cc113 tNFC_CONN conn = { in Fuzz_Deinit() local
119 rf_cback(NFC_RF_CONN_ID, NFC_DEACTIVATE_CEVT, &conn); in Fuzz_Deinit()
139 tNFC_CONN conn = {.data = { in Fuzz_Run() local
148 rf_cback(NFC_RF_CONN_ID, NFC_DATA_CEVT, &conn); in Fuzz_Run()
Dt4t.cc121 tNFC_CONN conn = { in Fuzz_Deinit() local
127 rf_cback(NFC_RF_CONN_ID, NFC_DEACTIVATE_CEVT, &conn); in Fuzz_Deinit()
147 tNFC_CONN conn = {.data = { in Fuzz_Run() local
156 rf_cback(NFC_RF_CONN_ID, NFC_DATA_CEVT, &conn); in Fuzz_Run()
Dt2t.cc161 tNFC_CONN conn = { in Fuzz_Deinit() local
167 rf_cback(NFC_RF_CONN_ID, NFC_DEACTIVATE_CEVT, &conn); in Fuzz_Deinit()
187 tNFC_CONN conn = {.data = { in Fuzz_Run() local
196 rf_cback(NFC_RF_CONN_ID, NFC_DATA_CEVT, &conn); in Fuzz_Run()
Dt1t.cc202 tNFC_CONN conn = { in Fuzz_Deinit() local
208 rf_cback(NFC_RF_CONN_ID, NFC_DEACTIVATE_CEVT, &conn); in Fuzz_Deinit()
228 tNFC_CONN conn = {.data = { in Fuzz_Run() local
237 rf_cback(NFC_RF_CONN_ID, NFC_DATA_CEVT, &conn); in Fuzz_Run()
Dt5t.cc279 tNFC_CONN conn = { in Fuzz_Deinit() local
285 rf_cback(NFC_RF_CONN_ID, NFC_DEACTIVATE_CEVT, &conn); in Fuzz_Deinit()
305 tNFC_CONN conn = {.data = { in Fuzz_Run() local
314 rf_cback(NFC_RF_CONN_ID, NFC_DATA_CEVT, &conn); in Fuzz_Run()
Dt3t.cc221 tNFC_CONN conn = { in Fuzz_Deinit() local
227 rf_cback(NFC_RF_CONN_ID, NFC_DEACTIVATE_CEVT, &conn); in Fuzz_Deinit()
250 tNFC_CONN conn = {.data = { in t3t_data_msg() local
260 rf_cback(NFC_RF_CONN_ID, NFC_DATA_CEVT, &conn); in t3t_data_msg()
/system/bt/gd/rust/linux/dbus_projection/src/
Dlib.rs36 pub async fn setup_watch(&mut self, conn: Arc<SyncConnection>) { in setup_watch()
39 conn.add_match_no_cb(&mr.match_str()).await.unwrap(); in setup_watch()
41 conn.start_receive( in setup_watch()
/system/bt/bta/hh/
Dbta_hh_act.cc517 tBTA_HH_CONN conn; in bta_hh_open_cmpl_act() local
521 memset((void*)&conn, 0, sizeof(tBTA_HH_CONN)); in bta_hh_open_cmpl_act()
522 conn.handle = dev_handle; in bta_hh_open_cmpl_act()
523 conn.bda = p_cb->addr; in bta_hh_open_cmpl_act()
532 conn.status = p_cb->status; in bta_hh_open_cmpl_act()
533 conn.le_hid = p_cb->is_le_device; in bta_hh_open_cmpl_act()
534 conn.scps_supported = p_cb->scps_supported; in bta_hh_open_cmpl_act()
554 conn.status = BTA_HH_ERR_PROTO; in bta_hh_open_cmpl_act()
555 (*bta_hh_cb.p_cback)(BTA_HH_OPEN_EVT, (tBTA_HH*)&conn); in bta_hh_open_cmpl_act()
557 conn.status = BTA_HH_OK; in bta_hh_open_cmpl_act()
[all …]
/system/bt/bta/hf_client/
Dbta_hf_client_act.cc294 evt.conn.bd_addr = client_cb->peer_addr; in bta_hf_client_rfc_close()
448 evt.conn.bd_addr = client_cb->peer_addr; in bta_hf_client_svc_conn_open()
449 evt.conn.peer_feat = client_cb->peer_features; in bta_hf_client_svc_conn_open()
450 evt.conn.chld_feat = client_cb->chld_features; in bta_hf_client_svc_conn_open()
/system/nfc/src/fuzzers/llcp/
Dllcp.cc81 tNFC_CONN conn = {.data = { in Fuzz_Run() local
86 rf_cback(NFC_RF_CONN_ID, NFC_DATA_CEVT, &conn); in Fuzz_Run()
/system/bt/bta/hd/
Dbta_hd_act.cc291 cback_data.conn.bda = p_ctrl->addr; in bta_hd_connect_act()
292 cback_data.conn.status = BTHD_CONN_STATE_CONNECTING; in bta_hd_connect_act()
319 if (HID_DevGetDevice(&cback_data.conn.bda) == HID_SUCCESS) { in bta_hd_disconnect_act()
320 cback_data.conn.status = BTHD_CONN_STATE_DISCONNECTING; in bta_hd_disconnect_act()
455 cback_data.conn.bda = p_cback->addr; in bta_hd_open_act()
485 cback_data.conn.bda = p_cback->addr; in bta_hd_close_act()
668 cback_data.conn.bda = p_cback->addr; in bta_hd_vc_unplug_done_act()

123