| /system/nfc/tools/casimir/scripts/ |
| D | t4at.py | 66 receiver=packet.sender))
68 await self.active(packet.sender)
85 self._write(rf.T4ATSelectCommand(receiver=packet.sender, param=0))
87 self.wait_for_select_response(packet.sender), timeout=1.0)
89 await self.active(response.sender)
99 if isinstance(packet, rf.T4ATSelectResponse) and packet.sender == sender_id:
|
| D | rf_packets.py | 135 sender: int = field(kw_only=True, default=0) variable in RfPacket
200 if self.sender > 65535:
202 self.sender &= 65535
203 _span.extend(int.to_bytes((self.sender << 0), length=2, byteorder='little'))
|
| /system/nfc/src/rust/nci/ |
| D | nci.rs | 56 sender: hc.out_data_tx.clone(), in init()
152 sender: UnboundedSender<DataPacket>, field
201 self.sender.send(conn_params.sendq.pop_front().unwrap()).unwrap(); in add_credits()
239 self.sender.send(conn_params.sendq.pop_front().unwrap()).unwrap(); in send_packet()
302 pub async fn register(&mut self, code: Opcode, sender: oneshot::Sender<Notification>) { in register()
304 self.handlers.lock().unwrap().insert(code, sender).is_none(), in register()
357 Some(sender) => { in dispatch()
358 if let Err(e) = sender.send(ntfy) { in dispatch()
|
| /system/nfc/src/rust/hal/ |
| D | hal.rs | 83 pub async fn register(&mut self, event: HalEvent, sender: oneshot::Sender<HalEventStatus>) { in register()
85 self.handlers.lock().await.insert(event, sender).is_none(), in register()
|
| /system/extras/profcollectd/libprofcollectd/ |
| D | scheduler.rs | 59 let (sender, receiver) = sync_channel(1); in schedule_periodic()
60 self.termination_ch = Some(sender); in schedule_periodic()
|
| /system/security/keystore2/src/ |
| D | enforcements.rs | 234 fn timestamp_token_request(challenge: i64, sender: Sender<Result<TimeStampToken, Error>>) { in timestamp_token_request()
235 if let Err(e) = sender.send(get_timestamp_token(challenge)) { in timestamp_token_request()
258 let (sender, receiver) = channel::<Result<TimeStampToken, Error>>(); in finalize_create_authorization()
263 ASYNC_TASK.queue_hi(move |_| timestamp_token_request(challenge, sender)); in finalize_create_authorization()
269 let (sender, receiver) = channel::<Result<TimeStampToken, Error>>(); in finalize_create_authorization()
271 ASYNC_TASK.queue_hi(move |_| timestamp_token_request(challenge, sender)); in finalize_create_authorization()
|
| D | async_task.rs | 363 let (sender, receiver) = channel(); in test_async_task_chain()
369 sender.send(()).unwrap(); in test_async_task_chain()
|
| D | legacy_importer.rs | 244 let (sender, receiver) = channel(); in do_serialized()
267 if let Err(e) = sender.send((new_state, result)) { in do_serialized()
|
| /system/nfc/tools/casimir/src/ |
| D | rf_packets.pdl | 68 sender: 16,
152 /// The Listener is uniquely identified by the `sender` identifier
|
| D | controller.rs | 1235 sender: self.id, in rf_deactivate()
1448 sender: self.id, in rf_conn_data()
1639 sender: self.id, in poll_command()
1733 sender: self.id, in t4at_select_command()
1961 sender: self.id, in activate_poll_interface()
1970 sender: self.id, in activate_poll_interface()
1981 sender: self.id, in activate_poll_interface()
2059 sender: self.id, in tick()
|
| D | main.rs | 237 sender: id, in disconnect()
|
| D | main-grpc.rs | 254 sender: id, in disconnect()
|
| /system/security/keystore2/rkpd_client/src/ |
| D | lib.rs | 88 fn new(sender: oneshot::Sender<T>) -> Self { in new()
89 Self { inner: Mutex::new(Some(sender)) } in new()
|
| /system/security/keystore2/legacykeystore/ |
| D | lib.rs | 414 let (sender, receiver) = std::sync::mpsc::channel::<Result<T>>(); in do_serialized()
417 sender.send(f(state)).expect("Failed to send result."); in do_serialized()
|
| /system/chre/doc/ |
| D | compatibility.md | 62 * Reserved fields must be set to 0 by the sender and ignored by the recipient
|
| D | nanoapp_developer_guide.md | 117 the sender, and suppress double promotion warnings.
|