| /packages/modules/Bluetooth/system/btif/src/ |
| D | btif_pan.cc | 89 static void btpan_cleanup_conn(btpan_conn_t* conn);
225 btpan_conn_t* conn = btpan_find_conn_addr(*bd_addr); in btif_in_pan_generic_evt() local
228 asrt(conn != NULL); in btif_in_pan_generic_evt()
229 if (conn) { in btif_in_pan_generic_evt()
230 btpan_conn_local_role = bta_role_to_btpan(conn->local_role); in btif_in_pan_generic_evt()
231 btpan_remote_role = bta_role_to_btpan(conn->remote_role); in btif_in_pan_generic_evt()
233 BT_STATUS_SUCCESS, &conn->peer, in btif_in_pan_generic_evt()
244 btpan_conn_t* conn = btpan_find_conn_addr(*bd_addr); in btpan_disconnect() local
245 if (conn && conn->handle >= 0) { in btpan_disconnect()
250 BTA_PanClose(conn->handle); in btpan_disconnect()
[all …]
|
| D | btif_hd.cc | 208 RawAddress* addr = (RawAddress*)&p_data->conn.bda; in btif_hd_upstreams_evt()
219 btif_storage_set_hidd(p_data->conn.bda); in btif_hd_upstreams_evt()
222 (RawAddress*)&p_data->conn.bda, BTHD_CONN_STATE_CONNECTED); in btif_hd_upstreams_evt()
227 RawAddress* addr = (RawAddress*)&p_data->conn.bda; in btif_hd_upstreams_evt()
234 (RawAddress*)&p_data->conn.bda, BTHD_CONN_STATE_DISCONNECTED); in btif_hd_upstreams_evt()
259 (RawAddress*)&p_data->conn.bda, BTHD_CONN_STATE_DISCONNECTED); in btif_hd_upstreams_evt()
260 if (bta_dm_check_if_only_hd_connected(p_data->conn.bda)) { in btif_hd_upstreams_evt()
263 BTA_DmRemoveDevice(p_data->conn.bda); in btif_hd_upstreams_evt()
265 RawAddress* bd_addr = (RawAddress*)&p_data->conn.bda; in btif_hd_upstreams_evt()
277 (RawAddress*)&p_data->conn.bda, in btif_hd_upstreams_evt()
[all …]
|
| D | btif_hh.cc | 789 p_data->conn.handle, p_data->conn.status); in btif_hh_upstreams_evt()
791 if (p_data->conn.status == BTA_HH_OK) { in btif_hh_upstreams_evt()
792 p_dev = btif_hh_find_connected_dev_by_handle(p_data->conn.handle); in btif_hh_upstreams_evt()
796 p_data->conn.handle); in btif_hh_upstreams_evt()
801 BTA_HhClose(p_data->conn.handle); in btif_hh_upstreams_evt()
803 (RawAddress*)&p_data->conn.bda, in btif_hh_upstreams_evt()
808 p_dev->bd_addr = p_data->conn.bda; in btif_hh_upstreams_evt()
809 p_dev->le_hid = p_data->conn.le_hid; in btif_hh_upstreams_evt()
813 BTA_HhClose(p_data->conn.handle); in btif_hh_upstreams_evt()
818 p_data->conn.handle); in btif_hh_upstreams_evt()
[all …]
|
| D | btif_gatt_server.cc | 147 btif_gatt_check_encrypted_link(p_data->conn.remote_bda, in btapp_gatts_handle_cback()
148 p_data->conn.transport); in btapp_gatts_handle_cback()
150 HAL_CBACK(bt_gatt_callbacks, server->connection_cb, p_data->conn.conn_id, in btapp_gatts_handle_cback()
151 p_data->conn.server_if, true, p_data->conn.remote_bda); in btapp_gatts_handle_cback()
156 HAL_CBACK(bt_gatt_callbacks, server->connection_cb, p_data->conn.conn_id, in btapp_gatts_handle_cback()
157 p_data->conn.server_if, false, p_data->conn.remote_bda); in btapp_gatts_handle_cback()
|
| /packages/modules/Bluetooth/system/blueberry/tests/gd/cert/ |
| D | os_utils.py | 72 …lambda conn: (conn and conn.status == psutil.CONN_LISTEN and conn.laddr and conn.laddr.port in por…
76 for conn in listening_conns_for_port:
77 logging.warning("Freeing port %d used by %s" % (conn.laddr.port, str(conn)))
78 if not conn.pid:
79 … 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 if conn.pid in killed_pids:
83 logging.warning("Pid %d is already killed in previous iteration" % (conn.pid))
86 process = psutil.Process(conn.pid)
89 killed_pids.add(conn.pid)
[all …]
|
| /packages/modules/Bluetooth/system/btif/co/ |
| D | bta_pan_co.cc | 79 btpan_conn_t* conn = btpan_find_conn_handle(handle); in bta_pan_co_close() local
80 if (conn && conn->state == PAN_STATE_OPEN) { in bta_pan_co_close()
86 conn->state = PAN_STATE_CLOSE; in bta_pan_co_close()
123 btpan_conn_t* conn = btpan_find_conn_handle(handle); in bta_pan_co_tx_path() local
124 if (!conn) { in bta_pan_co_tx_path()
127 } else if (conn->state != PAN_STATE_OPEN) { in bta_pan_co_tx_path()
129 __func__, conn, conn->state); in bta_pan_co_tx_path()
141 if (is_empty_eth_addr(conn->eth_addr) && is_valid_bt_eth_addr(src)) { in bta_pan_co_tx_path()
142 VLOG(1) << __func__ << " pan bt peer addr: " << conn->peer in bta_pan_co_tx_path()
144 conn->eth_addr = src; in bta_pan_co_tx_path()
[all …]
|
| /packages/modules/DnsResolver/tests/doh/src/ |
| D | client.rs | 39 conn: Pin<Box<quiche::Connection>>, field
60 fn new(conn: Pin<Box<quiche::Connection>>, addr: &SocketAddr, id: ConnectionID) -> Client { in new()
62 conn, in new()
75 let conn = quiche::h3::Connection::with_transport(&mut self.conn, &config)?; in create_http3_connection() localVariable
76 self.h3_conn = Some(conn); in create_http3_connection()
88 match h3_conn.poll(&mut self.conn) { in handle_http3_request()
108 if let Ok(read) = h3_conn.recv_body(&mut self.conn, stream_id, &mut buf) { in handle_http3_request()
148 h3_conn.send_response(&mut self.conn, stream_id, &headers, false)?; in handle_backend_message()
154 h3_conn.send_body(&mut self.conn, stream_id, first, false)?; in handle_backend_message()
164 h3_conn.send_body(&mut self.conn, stream_id, &ans, true)?; in process_pending_answers()
[all …]
|
| /packages/providers/DownloadProvider/src/com/android/providers/downloads/ |
| D | DownloadThread.java | 429 HttpURLConnection conn = null; in executeDownload() local
434 conn = (HttpURLConnection) mNetwork.openConnection(url); in executeDownload()
435 conn.setInstanceFollowRedirects(false); in executeDownload()
436 conn.setConnectTimeout(DEFAULT_TIMEOUT); in executeDownload()
437 conn.setReadTimeout(DEFAULT_TIMEOUT); in executeDownload()
440 if (conn instanceof HttpsURLConnection) { in executeDownload()
441 ((HttpsURLConnection)conn).setSSLSocketFactory(appContext.getSocketFactory()); in executeDownload()
444 addRequestHeaders(conn, resuming); in executeDownload()
446 final int responseCode = conn.getResponseCode(); in executeDownload()
453 parseOkHeaders(conn); in executeDownload()
[all …]
|
| /packages/modules/Bluetooth/system/service/ |
| D | gatt_server.cc | 208 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 ->send_indication(server_id_, handle, conn->conn_id, confirm, in SendNotification()
234 pending_indications_[conn->conn_id] = pending_ind; in SendNotification()
345 auto conn = GetConnection(conn_id, bda, trans_id); in RequestReadCharacteristicCallback() local
346 if (!conn) return; in RequestReadCharacteristicCallback()
355 conn->request_id_to_handle[trans_id] = attribute_handle; in RequestReadCharacteristicCallback()
378 auto conn = GetConnection(conn_id, bda, trans_id); in RequestReadDescriptorCallback() local
379 if (!conn) return; in RequestReadDescriptorCallback()
[all …]
|
| /packages/modules/Bluetooth/system/stack/hid/ |
| D | hidh_conn.cc | 120 hh_cb.devices[xx].conn.conn_state = HID_CONN_STATE_UNUSED; in hidh_conn_reg()
136 tHID_CONN* p_hcon = &hh_cb.devices[dhandle].conn; in hidh_conn_disconnect()
185 tHID_CONN* p_hcon = &hh_cb.devices[i].conn; in hidh_l2cif_connect_ind()
321 p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_connect_cfm()
377 p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_config_ind()
417 if (dhandle < kHID_HOST_MAX_DEVICES) p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_config_cfm()
490 if (dhandle < kHID_HOST_MAX_DEVICES) p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_disconnect_ind()
525 alarm_set_on_mloop(hh_cb.devices[dhandle].conn.process_repage_timer, in hidh_l2cif_disconnect_ind()
565 tHID_CONN* p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_disconnect()
601 if (dhandle < kHID_HOST_MAX_DEVICES) p_hcon = &hh_cb.devices[dhandle].conn; in hidh_l2cif_cong_ind()
[all …]
|
| D | hidd_conn.cc | 75 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_check_config_done()
118 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_connect_ind()
197 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_connect_cfm()
243 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_config_ind()
272 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_config_cfm()
316 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_disconnect_ind()
353 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_disconnect()
404 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_cong_ind()
441 tHID_CONN* p_hcon = &hd_cb.device.conn; in hidd_l2cif_data_ind()
631 if (p_dev->conn.conn_state != HID_CONN_STATE_UNUSED) { in hidd_conn_initiate()
[all …]
|
| /packages/services/Car/car-usb-handler/src/android/car/usb/handler/ |
| D | AoapInterface.java | 124 public static int getProtocol(UsbDeviceConnection conn) { in getProtocol() argument
127 int len = transfer(conn, READ, ACCESSORY_GET_PROTOCOL, 0, buffer, buffer.length); in getProtocol()
133 len = transfer(conn, READ, ACCESSORY_GET_PROTOCOL, 0, buffer, buffer.length); in getProtocol()
141 public static boolean isSupported(Context context, UsbDevice device, UsbDeviceConnection conn) { in isSupported() argument
142 return !isDeviceDenylisted(context, device) && getProtocol(conn) >= 1; in isSupported()
145 public static void sendString(UsbDeviceConnection conn, int index, String string) in sendString() argument
148 int len = transfer(conn, WRITE, ACCESSORY_SEND_STRING, index, buffer, in sendString()
152 len = transfer(conn, WRITE, ACCESSORY_SEND_STRING, index, buffer, in sendString()
162 public static void sendAoapStart(UsbDeviceConnection conn) throws IOException { in sendAoapStart() argument
163 int len = transfer(conn, WRITE, ACCESSORY_START, 0, null, 0); in sendAoapStart()
[all …]
|
| /packages/apps/Dialer/java/com/android/incallui/calllocation/impl/ |
| D | HttpFetcher.java | 66 HttpURLConnection conn = null; in sendRequestAsByteArray() local
71 conn = (HttpURLConnection) url.openConnection(); in sendRequestAsByteArray()
72 setMethodAndHeaders(conn, requestMethod, headers); in sendRequestAsByteArray()
73 int responseCode = conn.getResponseCode(); in sendRequestAsByteArray()
77 is = conn.getInputStream(); in sendRequestAsByteArray()
79 is = conn.getErrorStream(); in sendRequestAsByteArray()
106 if (conn != null) { in sendRequestAsByteArray()
107 conn.disconnect(); in sendRequestAsByteArray()
164 HttpURLConnection conn, String requestMethod, List<Pair<String, String>> headers) in setMethodAndHeaders() argument
166 conn.setRequestMethod(requestMethod); in setMethodAndHeaders()
[all …]
|
| /packages/modules/Bluetooth/system/stack/gap/ |
| D | gap_conn.cc | 83 tGAP_CONN conn; variable
117 memset(&conn, 0, sizeof(tGAP_CONN)); in gap_conn_init()
118 conn.reg_info.pL2CA_ConnectInd_Cb = gap_connect_ind; in gap_conn_init()
119 conn.reg_info.pL2CA_ConnectCfm_Cb = gap_connect_cfm; in gap_conn_init()
120 conn.reg_info.pL2CA_ConfigInd_Cb = gap_config_ind; in gap_conn_init()
121 conn.reg_info.pL2CA_ConfigCfm_Cb = gap_config_cfm; in gap_conn_init()
122 conn.reg_info.pL2CA_DisconnectInd_Cb = gap_disconnect_ind; in gap_conn_init()
123 conn.reg_info.pL2CA_DataInd_Cb = gap_data_ind; in gap_conn_init()
124 conn.reg_info.pL2CA_CongestionStatus_Cb = gap_congestion_ind; in gap_conn_init()
125 conn.reg_info.pL2CA_TxComplete_Cb = gap_tx_complete_ind; in gap_conn_init()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/linux/service/src/ |
| D | main.rs | 81 let (resource, conn) = connection::new_system_sync()?; in main()
91 conn.request_name(DBUS_SERVICE_NAME, false, true, false).await?; in main()
96 conn.clone(), in main()
113 disconnect_watcher.lock().unwrap().setup_watch(conn.clone()).await; in main()
118 conn.clone(), in main()
126 conn.clone(), in main()
134 conn.clone(), in main()
142 conn.clone(), in main()
164 conn.start_receive( in main()
166 Box::new(move |msg, conn| { in main()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/linux/mgmt/src/bin/btmanagerd/ |
| D | main.rs | 41 let (resource, conn) = connection::new_system_sync()?; in main()
69 conn.request_name("org.chromium.bluetooth.Manager", false, true, false).await?; in main()
78 conn.clone(), in main()
87 cr.set_object_manager_support(Some(conn.clone())); in main()
94 disconnect_watcher.lock().unwrap().setup_watch(conn.clone()).await; in main()
100 conn.clone(), in main()
107 conn.start_receive( in main()
109 Box::new(move |msg, conn| { in main()
110 cr.handle_message(msg, conn).unwrap(); in main()
|
| /packages/modules/Bluetooth/system/gd/rust/linux/client/src/ |
| D | main.rs | 134 let conn = self.dbus_connection.clone(); in create_adapter_proxy() localVariable
136 let dbus = BluetoothDBus::new(conn.clone(), idx); in create_adapter_proxy()
139 let gatt_dbus = BluetoothGattDBus::new(conn.clone(), idx); in create_adapter_proxy()
142 self.suspend_dbus = Some(SuspendDBus::new(conn.clone(), idx)); in create_adapter_proxy()
190 let (resource, conn) = dbus_tokio::connection::new_system_sync()?; in main()
202 conn.clone(), in main()
208 conn.start_receive( in main()
210 Box::new(move |msg, conn| { in main()
211 cr_clone.lock().unwrap().handle_message(msg, conn).unwrap(); in main()
221 Arc::new(Mutex::new(ClientContext::new(conn.clone(), cr.clone(), tx.clone()))); in main()
[all …]
|
| D | dbus_iface.rs | 104 conn: Arc<SyncConnection>, field
112 let conn = self.conn.clone(); in create_proxy() localVariable
117 conn, in create_proxy()
240 pub(crate) fn new(conn: Arc<SyncConnection>, index: i32) -> BluetoothDBus { in new()
243 conn: conn.clone(), in new()
469 pub(crate) fn new(conn: Arc<SyncConnection>) -> BluetoothManagerDBus { in new()
472 conn: conn.clone(), in new()
558 pub(crate) fn new(conn: Arc<SyncConnection>, index: i32) -> BluetoothGattDBus { in new()
561 conn: conn.clone(), in new()
830 pub(crate) fn new(conn: Arc<SyncConnection>, index: i32) -> SuspendDBus { in new()
[all …]
|
| /packages/services/Car/tests/usb/AoapHostApp/src/com/google/android/car/usb/aoap/host/ |
| D | SpeedMeasurementController.java | 64 UsbDevice device, UsbDeviceConnection conn, in SpeedMeasurementController() argument
74 mUsbConnection = conn; in SpeedMeasurementController()
163 private ReaderThread(UsbDevice device, UsbDeviceConnection conn, int testMode) { in ReaderThread() argument
166 mUsbConnection = conn; in ReaderThread()
219 private BaseWriterThread(UsbDevice device, UsbDeviceConnection conn, int bufferSize) { in BaseWriterThread() argument
222 mUsbConnection = conn; in BaseWriterThread()
270 private WriterSyncThread(UsbDevice device, UsbDeviceConnection conn, int bufferSize) { in WriterSyncThread() argument
271 super(device, conn, bufferSize); in WriterSyncThread()
316 private WriterAsyncThread(UsbDevice device, UsbDeviceConnection conn, int bufferSize) { in WriterAsyncThread() argument
317 super(device, conn, bufferSize); in WriterAsyncThread()
|
| /packages/services/Telephony/src/com/android/phone/ |
| D | CarrierConfigLoader.java | 314 final CarrierServiceConnection conn = (CarrierServiceConnection) msg.obj; in handleMessage() local
316 if (mServiceConnection[phoneId] != conn || conn.service == null) { in handleMessage()
317 unbindIfBound(mContext, conn, phoneId); in handleMessage()
326 unbindIfBound(mContext, conn, phoneId); in handleMessage()
330 if (mServiceConnection[phoneId] != conn) { in handleMessage()
353 ICarrierService.Stub.asInterface(conn.service); in handleMessage()
361 unbindIfBound(mContext, conn, phoneId); in handleMessage()
444 final CarrierServiceConnection conn = (CarrierServiceConnection) msg.obj; in handleMessage() local
446 if (mServiceConnection[phoneId] != conn || conn.service == null) { in handleMessage()
447 unbindIfBound(mContext, conn, phoneId); in handleMessage()
[all …]
|
| /packages/services/Telephony/src/com/android/phone/callcomposer/ |
| D | CallComposerPictureTransfer.java | 160 .thenComposeAsync((conn) -> { in downloadPicture()
162 if (conn.getResponseCode() != 200) { in downloadPicture()
169 return CompletableFuture.completedFuture(downloadImageFromConnection(conn)); in downloadPicture()
173 .thenComposeAsync((conn) -> { in downloadPicture()
175 if (conn.getResponseCode() == 200) { in downloadPicture()
184 obtainAuthenticateHeader(conn) in downloadPicture()
307 private ImageData downloadImageFromConnection(HttpURLConnection conn) { in downloadImageFromConnection() argument
309 if (conn.getResponseCode() != 200) { in downloadImageFromConnection()
310 Log.w(TAG, "Got response code " + conn.getResponseCode() + " when trying" in downloadImageFromConnection()
312 if (conn.getResponseCode() == 401) { in downloadImageFromConnection()
[all …]
|
| /packages/modules/Connectivity/tests/cts/hostside/app2/src/com/android/cts/net/hostside/app2/ |
| D | MyBroadcastReceiver.java | 173 final HttpURLConnection conn = (HttpURLConnection) url.openConnection(); in checkNetworkStatus() local
174 conn.setReadTimeout(NETWORK_TIMEOUT_MS); in checkNetworkStatus()
175 conn.setConnectTimeout(NETWORK_TIMEOUT_MS / 2); in checkNetworkStatus()
176 conn.setRequestMethod("GET"); in checkNetworkStatus()
177 conn.setDoInput(true); in checkNetworkStatus()
178 conn.connect(); in checkNetworkStatus()
179 final int response = conn.getResponseCode(); in checkNetworkStatus()
|
| /packages/apps/Launcher3/tools/ |
| D | print_db.py | 52 def get_favorites(conn): argument
53 c = conn.cursor()
61 def get_screens(conn): argument
62 c = conn.cursor()
154 conn = sqlite3.connect(fn)
155 columns,rows = get_favorites(conn)
156 screenCols, screenRows = get_screens(conn)
|
| /packages/modules/Bluetooth/system/bta/hh/ |
| D | bta_hh_act.cc | 515 tBTA_HH_CONN conn; in bta_hh_open_cmpl_act() local
519 memset((void*)&conn, 0, sizeof(tBTA_HH_CONN)); in bta_hh_open_cmpl_act()
520 conn.handle = dev_handle; in bta_hh_open_cmpl_act()
521 conn.bda = p_cb->addr; in bta_hh_open_cmpl_act()
530 conn.status = p_cb->status; in bta_hh_open_cmpl_act()
531 conn.le_hid = p_cb->is_le_device; in bta_hh_open_cmpl_act()
532 conn.scps_supported = p_cb->scps_supported; in bta_hh_open_cmpl_act()
552 conn.status = BTA_HH_ERR_PROTO; in bta_hh_open_cmpl_act()
553 (*bta_hh_cb.p_cback)(BTA_HH_OPEN_EVT, (tBTA_HH*)&conn); in bta_hh_open_cmpl_act()
555 conn.status = BTA_HH_OK; in bta_hh_open_cmpl_act()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/linux/stack/src/ |
| D | bluetooth_gatt.rs | 65 match self.connections.iter().find(|conn| conn.conn_id == conn_id) { in get_address_by_conn_id()
67 Some(conn) => Some(conn.address.clone()), in get_address_by_conn_id()
72 match self.connections.iter().find(|conn| conn.conn_id == conn_id) { in get_client_by_conn_id()
74 Some(conn) => self.get_by_client_id(conn.client_id), in get_client_by_conn_id()
79 let client_id = match self.connections.iter().find(|conn| conn.conn_id == conn_id) { in get_client_by_conn_id_mut()
81 Some(conn) => conn.client_id, in get_client_by_conn_id_mut()
123 self.connections.retain(|conn| conn.conn_id != conn_id); in remove_connection()
130 .find(|conn| conn.client_id == client_id && conn.address == *address) in get_conn_id_from_address()
133 Some(conn) => Some(conn.conn_id), in get_conn_id_from_address()
|