| /packages/modules/Bluetooth/system/gd/rust/stack/src/hci/ |
| D | controller.rs | 29 ($hci:ident.send($builder:expr)) => {{
30 let response = $hci.send($builder).await;
39 assert_success!(hci.send(LeSetEventMaskBuilder { le_event_mask: 0x000000004d021e7f })); in provide_controller()
40 assert_success!(hci.send(SetEventMaskBuilder { event_mask: 0x3dbfffffffffffff })); in provide_controller()
42 hci.send(WriteSimplePairingModeBuilder { simple_pairing_mode: Enable::Enabled }) in provide_controller()
44 assert_success!(hci.send(WriteLeHostSupportBuilder { in provide_controller()
50 assert_success!(hci.send(ReadLocalNameBuilder {})).get_local_name(), in provide_controller()
53 let version_info = assert_success!(hci.send(ReadLocalVersionInformationBuilder {})) in provide_controller()
58 supported: *assert_success!(hci.send(ReadLocalSupportedCommandsBuilder {})) in provide_controller()
64 let buffer_size = assert_success!(hci.send(ReadBufferSizeBuilder {})); in provide_controller()
[all …]
|
| D | mod.rs | 74 commands.send(ResetBuilder {}).await.get_status() == ErrorCode::Success, in provide_hci()
97 pub async fn send(&mut self, cmd: CommandPacket) -> Result<EventPacket> { in send() method
99 self.cmd_tx.send(QueuedCommand { cmd, fut: tx }).await?; in send()
113 pub async fn send<T: Into<CommandPacket> + CommandExpectations>( in send() method
117 T::_to_response_type(self.raw.send(cmd.into()).await.unwrap()) in send()
186 if let Err(e) = fut.send(evt.into()) { in dispatch()
199 if let Err(e) = fut.send(evt.into()) { in dispatch()
211 if let Err(e) = sender.send(evt).await { in dispatch()
225 if let Err(e) = sender.send(evt).await { in dispatch()
236 if let Err(e) = cmd_tx.send(queued.cmd.clone()).await { in dispatch()
|
| /packages/services/Car/tests/carservice_unit_test/src/com/android/car/ |
| D | CarInputServiceTest.java | 246 KeyEvent event = send(Key.DOWN, KeyEvent.KEYCODE_ENTER, Display.MAIN); in ordinaryEvents_onMainDisplay_routedToInputManager()
253 send(Key.DOWN, KeyEvent.KEYCODE_ENTER, Display.INSTRUMENT_CLUSTER); in ordinaryEvents_onInstrumentClusterDisplay_notRoutedToInputManager()
263 KeyEvent event = send(Key.DOWN, KeyEvent.KEYCODE_ENTER, Display.INSTRUMENT_CLUSTER); in ordinaryEvents_onInstrumentClusterDisplay_routedToListener()
275 KeyEvent event = send(Key.DOWN, KeyEvent.KEYCODE_ENTER, Display.MAIN); in customEventHandler_capturesDisplayMainEvent_capturedByInputController()
289 KeyEvent event = send(Key.DOWN, KeyEvent.KEYCODE_ENTER, Display.MAIN); in customEventHandler_capturesDisplayMainEvent_missedByInputController()
303 KeyEvent event = send(Key.DOWN, KeyEvent.KEYCODE_ENTER, Display.INSTRUMENT_CLUSTER); in customEventHandler_capturesClusterEvents_capturedByInstrumentCluster()
322 send(Key.DOWN, KeyEvent.KEYCODE_VOICE_ASSIST, Display.MAIN); in voiceKey_shortPress_withRegisteredEventHandler_triggersEventHandler()
323 send(Key.UP, KeyEvent.KEYCODE_VOICE_ASSIST, Display.MAIN); in voiceKey_shortPress_withRegisteredEventHandler_triggersEventHandler()
336 send(Key.DOWN, KeyEvent.KEYCODE_VOICE_ASSIST, Display.MAIN); in voiceKey_longPress_withRegisteredEventHandler_triggersEventHandler()
345 send(Key.UP, KeyEvent.KEYCODE_VOICE_ASSIST, Display.MAIN); in voiceKey_longPress_withRegisteredEventHandler_triggersEventHandler()
[all …]
|
| /packages/modules/Wifi/service/tests/wifitests/src/com/android/server/wifi/ |
| D | ClientModeManagerBroadcastQueueTest.java | 78 verify(mQueuedBroadcast1).send(); in primaryManagerSendBroadcast_sentImmediately()
86 verify(mQueuedBroadcast1).send(); in scanOnlyModeManagerSendBroadcast_sentImmediately()
93 verify(mQueuedBroadcast1, never()).send(); in nonPrimaryManagerSendBroadcast_notSentImmediately()
103 order.verify(mQueuedBroadcast1, never()).send(); in secondaryManagerSendBroadcast_queuedAndSentOnPrimaryChangeInOrderAndCleared()
107 order.verify(mQueuedBroadcast1, never()).send(); in secondaryManagerSendBroadcast_queuedAndSentOnPrimaryChangeInOrderAndCleared()
108 order.verify(mQueuedBroadcast2, never()).send(); in secondaryManagerSendBroadcast_queuedAndSentOnPrimaryChangeInOrderAndCleared()
118 order.verify(mQueuedBroadcast1).send(); in secondaryManagerSendBroadcast_queuedAndSentOnPrimaryChangeInOrderAndCleared()
119 order.verify(mQueuedBroadcast2).send(); in secondaryManagerSendBroadcast_queuedAndSentOnPrimaryChangeInOrderAndCleared()
123 order.verify(mQueuedBroadcast1, never()).send(); in secondaryManagerSendBroadcast_queuedAndSentOnPrimaryChangeInOrderAndCleared()
124 order.verify(mQueuedBroadcast2, never()).send(); in secondaryManagerSendBroadcast_queuedAndSentOnPrimaryChangeInOrderAndCleared()
[all …]
|
| /packages/modules/Connectivity/tests/cts/hostside/app/src/com/android/cts/net/hostside/ |
| D | MyNotificationListenerService.java | 50 sender.send("content", notification.contentIntent); in onNotificationPosted()
53 sender.send("delete", notification.deleteIntent); in onNotificationPosted()
56 sender.send("full screen", notification.fullScreenIntent); in onNotificationPosted()
60 sender.send("action", action.actionIntent); in onNotificationPosted()
61 sender.send("action extras", action.getExtras()); in onNotificationPosted()
65 sender.send("remote input extras", remoteInput.getExtras()); in onNotificationPosted()
70 sender.send("notification extras", notification.extras); in onNotificationPosted()
87 private void send(String reason, PendingIntent pendingIntent) { in send() method in MyNotificationListenerService.PendingIntentSender
103 pendingIntent.send(); in send()
111 private void send(String reason, Bundle extras) { in send() method in MyNotificationListenerService.PendingIntentSender
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/stack/src/link/acl/classic/ |
| D | mod.rs | 83 self.requests.send(ConnectionRequest::Disconnect { reason, fut: tx }).await.unwrap(); in disconnect()
109 self.req_tx.send(Request::Connect { addr }).await.unwrap(); in connect()
115 self.req_tx.send(Request::CancelConnect { addr, fut: tx }).await.unwrap(); in cancel_connect()
171 hci.send(build_create_connection(addr)).await; in provide_acl_manager()
179 hci.send(CreateConnectionCancelBuilder { bd_addr: addr }).await; in provide_acl_manager()
181 fut.send(()).unwrap(); in provide_acl_manager()
219 … conn_evt_tx.send(Event::ConnectSuccess(connection)).await.unwrap(); in provide_acl_manager()
221 … _ => conn_evt_tx.send(Event::ConnectFail { addr, reason: status }).await.unwrap(), in provide_acl_manager()
228 hci.send(RejectConnectionRequestBuilder { in provide_acl_manager()
233 hci.send(AcceptConnectionRequestBuilder { in provide_acl_manager()
[all …]
|
| /packages/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/sap/ |
| D | SapMessageTest.java | 197 public void send() throws Exception { in send() method in SapMessageTest
207 mMessage.send(sapProxy); in send()
212 mMessage.send(sapProxy); in send()
218 mMessage.send(sapProxy); in send()
225 mMessage.send(sapProxy); in send()
232 assertThrows(IllegalArgumentException.class, () -> mMessage.send(sapProxy)); in send()
236 mMessage.send(sapProxy); in send()
242 mMessage.send(sapProxy); in send()
247 mMessage.send(sapProxy); in send()
252 mMessage.send(sapProxy); in send()
[all …]
|
| /packages/modules/Bluetooth/system/blueberry/tests/gd/l2cap/classic/ |
| D | l2cap_test.py | 143 dut_channel.send(b'abc')
168 dut_channel.send(b'abc' * 34)
191 dut_channel.send(b'hello')
213 dut_channel.send(b'a' * 48)
339 dut_channel.send(b"a" * 44)
422 self.cert_l2cap.get_control_channel().send(echo_request)
435 self.cert_l2cap.get_control_channel().send(invalid_command_packet)
552 dut_channel.send(b'abc')
566 dut_channel.send(b'abc')
582 dut_channel.send(b'abc')
[all …]
|
| D | cert_l2cap.py | 62 def send(self, packet): member in CertL2capChannel
64 self._acl.send(frame.Serialize())
77 self._acl.send(frame.Serialize())
81 self._acl.send(frame.Serialize())
89 self._control_channel.send(request)
95 self.send(information_request)
109 self._control_channel.send(config_response)
117 self._control_channel.send(config_response)
125 … self._control_channel.send(l2cap_packets.DisconnectionRequestBuilder(1, self._dcid, self._scid))
203 self.control_channel.send(l2cap_packets.ConnectionRequestBuilder(signal_id, psm, scid))
[all …]
|
| /packages/modules/DnsResolver/doh/network/ |
| D | driver.rs | 117 … if let Err(e) = self.probe(duration).await { self.status_tx.send(Status::Failed(Arc::new(e)))? }, in drive()
132 self.status_tx.send(Status::Unprobed)?; in probe()
149 Err(e) => self.status_tx.send(Status::Failed(Arc::new(anyhow!(e)))), in force_probe()
153 self.status_tx.send(Status::Live) in force_probe()
155 self.status_tx.send(Status::Failed(Arc::new(anyhow!("Empty response")))) in force_probe()
162 Err(time) => self.status_tx.send(Status::Failed(Arc::new(anyhow!( in force_probe()
199 query.response.send(Response::Error { error: QueryError::ConnectionError }); in send_query()
205 query.response.send(Response::Error { error: QueryError::Reset(err) }) in send_query()
207 query.response.send(Response::Success { answer: stream.data }) in send_query()
|
| /packages/modules/Bluetooth/system/blueberry/tests/gd/l2cap/le/ |
| D | cert_le_l2cap.py | 46 def send(self, packet): member in CertLeL2capChannel
48 self._acl.send(frame.Serialize())
53 self._acl.send(frame.Serialize())
58 … self._control_channel.send(l2cap_packets.LeDisconnectionRequestBuilder(1, self._dcid, self._scid))
66 … self._control_channel.send(l2cap_packets.LeFlowControlCreditBuilder(2, self._scid, num_credits))
108 self.control_channel.send(
121 …self.control_channel.send(l2cap_packets.LeCreditBasedConnectionRequestBuilder(1, psm, 0x40, 1000, …
144 self.control_channel.send(reject)
164 self.control_channel.send(response)
179 self.control_channel.send(response)
|
| D | le_l2cap_test.py | 140 dut_channel.send(b'hello' * 40)
147 cert_channel.send(SAMPLE_PACKET)
175 self.cert_l2cap.get_control_channel().send(
188 self.cert_l2cap.get_control_channel().send(
200 self.cert_l2cap.get_control_channel().send(
211 dut_channel.send(b'hello' * 20 + b'world')
225 dut_channel.send(b'hello' * 40)
233 dut_channel.send(b'hello' * 40)
245 cert_channel.send(SAMPLE_PACKET)
294 self.cert_l2cap.get_control_channel().send(
[all …]
|
| /packages/modules/Bluetooth/android/app/src/com/android/bluetooth/btservice/ |
| D | AdapterService.java | 1443 listenerData.mPendingIntent.send(); in handleIncomingRfcommConnections()
1630 receiver.send(getState()); in getState()
1649 receiver.send(enable(quietMode, source)); in enable()
1668 receiver.send(disable(source)); in disable()
1696 receiver.send(getAddressWithAttribution(source)); in getAddressWithAttribution()
1717 receiver.send(getUuids(source)); in getUuids()
1740 receiver.send(getIdentityAddress(address)); in getIdentityAddress()
1761 receiver.send(getName(source)); in getName()
1781 receiver.send(getNameLengthForAdvertise(source)); in getNameLengthForAdvertise()
1803 receiver.send(setName(name, source)); in setName()
[all …]
|
| /packages/modules/Bluetooth/android/app/src/com/android/bluetooth/hfpclient/ |
| D | HeadsetClientService.java | 301 receiver.send(defaultValue); in connect()
316 receiver.send(defaultValue); in disconnect()
331 receiver.send(defaultValue); in getConnectedDevices()
346 receiver.send(defaultValue); in getDevicesMatchingConnectionStates()
361 receiver.send(defaultValue); in getConnectionState()
376 receiver.send(defaultValue); in setConnectionPolicy()
391 receiver.send(defaultValue); in getConnectionPolicy()
406 receiver.send(defaultValue); in startVoiceRecognition()
421 receiver.send(defaultValue); in stopVoiceRecognition()
436 receiver.send(defaultValue); in getAudioState()
[all …]
|
| /packages/apps/Nfc/src/com/android/nfc/snep/ |
| D | SnepMessenger.java | 63 mSocket.send(tmpBuffer); in sendMessage()
91 mSocket.send(tmpBuffer); in sendMessage()
114 mSocket.send(tmpBuffer); in sendMessage()
159 mSocket.send(SnepMessage.getMessage(fieldReject).toByteArray()); in getMessage()
170 mSocket.send(SnepMessage.getMessage(fieldReject).toByteArray()); in getMessage()
173 mSocket.send(SnepMessage.getMessage(fieldReject).toByteArray()); in getMessage()
239 mSocket.send(SnepMessage.getMessage(fieldContinue).toByteArray()); in getMessage()
251 mSocket.send(SnepMessage.getMessage(fieldReject).toByteArray()); in getMessage()
265 mSocket.send(SnepMessage.getMessage(fieldReject).toByteArray()); in getMessage()
|
| /packages/apps/ThemePicker/src/com/android/customization/picker/clock/data/repository/ |
| D | ClockPickerRepositoryImpl.kt | 51 fun send() { in <lambda>() method
63 send() in <lambda>()
67 send() in <lambda>()
81 fun send() { in <lambda>() method
100 send() in <lambda>()
104 send() in <lambda>()
108 send() in <lambda>()
|
| /packages/modules/Bluetooth/system/gd/rust/stack/src/hal/ |
| D | snoop.rs | 158 if let Err(e) = evt_up_tx.send(evt.clone()).await { in provide_snooped_hal()
165 if let Err(e) = raw_hal.cmd_tx.send(cmd.clone()) { in provide_snooped_hal()
172 if let Err(e) = raw_hal.acl_tx.send(acl.clone()) { in provide_snooped_hal()
179 if let Err(e) = acl_up_tx.send(acl.clone()).await { in provide_snooped_hal()
186 if let Err(e) = raw_hal.sco_tx.send(sco.clone()) { in provide_snooped_hal()
193 if let Err(e) = sco_up_tx.send(sco.clone()).await { in provide_snooped_hal()
200 if let Err(e) = raw_hal.iso_tx.send(iso.clone()) { in provide_snooped_hal()
207 if let Err(e) = iso_up_tx.send(iso.clone()).await { in provide_snooped_hal()
|
| D | hidl_hal.rs | 79 callbacks.as_ref().unwrap().init_tx.send(()).unwrap(); in on_init_complete()
86 Ok(p) => callbacks.as_ref().unwrap().evt_tx.send(p).unwrap(), in on_event()
94 Ok(p) => callbacks.as_ref().unwrap().acl_tx.send(p).unwrap(), in on_acl()
102 Ok(p) => callbacks.as_ref().unwrap().sco_tx.send(p).unwrap(), in on_sco()
110 Ok(p) => callbacks.as_ref().unwrap().iso_tx.send(p).unwrap(), in on_iso()
|
| /packages/apps/TV/tuner/src/com/android/tv/tuner/hdhomerun/ |
| D | HdHomeRunDiscover.java | 75 int localIpSent = send(targetIp, deviceType, deviceId); in findDevices()
196 private int send(int targetIp, int deviceType, int deviceId) { in send() method in HdHomeRunDiscover
211 localIpSent += discoverSocket.send(targetIp, deviceType, deviceId) ? 1 : 0; in sendWildcardIp()
217 localIpSent = mSockets.get(0).send(0xFFFFFFFF, deviceType, deviceId) ? 1 : 0; in sendWildcardIp()
236 localIpSent += discoverSocket.send(targetIp, deviceType, deviceId) ? 1 : 0; in sendTargetIp()
241 localIpSent = mSockets.get(0).send(targetIp, deviceType, deviceId) ? 1 : 0; in sendTargetIp()
317 private boolean send(int targetIp, int deviceType, int deviceId) { in send() method in HdHomeRunDiscover.HdHomeRunDiscoverSocket
334 mSocket.send(packet); in send()
|
| /packages/apps/Settings/src/com/android/settings/biometrics/ |
| D | BiometricEnrollSidecar.java | 58 public abstract void send(Listener listener); in send() method in BiometricEnrollSidecar.QueuedEvent
70 public void send(Listener listener) { in send() method in BiometricEnrollSidecar.QueuedEnrollmentProgress
84 public void send(Listener listener) { in send() method in BiometricEnrollSidecar.QueuedEnrollmentHelp
98 public void send(Listener listener) { in send() method in BiometricEnrollSidecar.QueuedEnrollmentError
197 event.send(mListener); in setListener()
|
| /packages/modules/Bluetooth/system/gd/rust/stack/src/link/acl/ |
| D | core.rs | 59 self.requests.send(Request::Register { handle, bt, fut: tx }).await.unwrap(); in register()
122 fut.send(Connection { in provide_acl_dispatch()
141 acl.tx.send(p).await.unwrap(); in provide_acl_dispatch()
145 acl.tx.send(p).await.unwrap(); in provide_acl_dispatch()
168 c.close_tx.send(()).unwrap(); in provide_acl_dispatch()
169 c.evt_tx.send(evt.into()).await.unwrap(); in provide_acl_dispatch()
|
| /packages/modules/DnsResolver/tests/doh/src/ |
| D | dns_https_frontend.rs | 141 self.command_tx.as_ref().unwrap().send(ControlCommand::CloseConnection)?; in stop()
200 command_tx.send(ControlCommand::Stats { resp: resp_tx })?; in request_stats()
225 .send(ControlCommand::StatsClearQueries) in stats_clear_queries()
301 event_tx.send(InternalCommand::MaybeWrite{connection_id})?; in worker_thread()
343 backend_socket.send(&query).await?; in worker_thread()
348 event_tx.send(InternalCommand::MaybeWrite{connection_id})?; in worker_thread()
365 event_tx.send(InternalCommand::MaybeWrite{connection_id})?; in worker_thread()
399 if let Err(e) = resp.send(stats) { in worker_thread()
407 … event_tx.send(InternalCommand::MaybeWrite { connection_id: client.connection_id().clone() })?; in worker_thread()
|
| /packages/modules/Bluetooth/android/app/src/com/android/bluetooth/mapclient/ |
| D | MapClientService.java | 511 receiver.send(result); in isConnected()
529 receiver.send(result); in connect()
547 receiver.send(result); in disconnect()
565 receiver.send(connectedDevices); in getConnectedDevices()
583 receiver.send(devices); in getDevicesMatchingConnectionStates()
601 receiver.send(state); in getConnectionState()
619 receiver.send(result); in setConnectionPolicy()
637 receiver.send(policy); in getConnectionPolicy()
660 receiver.send(result); in sendMessage()
680 receiver.send(result); in getUnreadMessages()
[all …]
|
| /packages/modules/Bluetooth/android/app/src/com/android/bluetooth/gatt/ |
| D | GattService.java | 607 receiver.send(getDevicesMatchingConnectionStates(states, attributionSource)); in getDevicesMatchingConnectionStates()
627 receiver.send(null); in registerClient()
646 receiver.send(null); in unregisterClient()
665 receiver.send(null); in registerScanner()
684 receiver.send(null); in unregisterScanner()
703 receiver.send(null); in startScan()
725 receiver.send(null); in startScanForIntent()
745 receiver.send(null); in stopScanForIntent()
764 receiver.send(null); in stopScan()
782 receiver.send(null); in flushPendingBatchResults()
[all …]
|
| /packages/modules/Bluetooth/android/app/src/com/android/bluetooth/vc/ |
| D | VolumeControlService.java | 1101 receiver.send(defaultValue); in connect()
1120 receiver.send(defaultValue); in disconnect()
1139 receiver.send(defaultValue); in getConnectedDevices()
1157 receiver.send(defaultValue); in getDevicesMatchingConnectionStates()
1176 receiver.send(defaultValue); in getConnectionState()
1195 receiver.send(defaultValue); in setConnectionPolicy()
1214 receiver.send(defaultValue); in getConnectionPolicy()
1233 receiver.send(defaultValue); in isVolumeOffsetAvailable()
1251 receiver.send(null); in setVolumeOffset()
1268 receiver.send(null); in setGroupVolume()
[all …]
|