Searched refs:Sender (Results 1 – 16 of 16) sorted by relevance
| /system/nfc/src/rust/nci/ |
| D | nci.rs | 26 use tokio::sync::mpsc::{channel, Receiver, Sender};
62 pub out_data_ext: Sender<DataPacket>,
69 in_data_int: Sender<DataPacket>,
75 response: oneshot::Sender<ResponsePacket>,
81 notification: Option<oneshot::Sender<NotificationPacket>>,
87 cmd_tx: Sender<QueuedCommand>,
138 handlers: Arc<Mutex<HashMap<Opcode, oneshot::Sender<NotificationPacket>>>>,
143 pub async fn register(&mut self, code: Opcode, sender: oneshot::Sender<NotificationPacket>) { in register()
155 ) -> Option<oneshot::Sender<NotificationPacket>> { in unregister()
|
| /system/memory/libmemunreachable/ |
| D | ScopedPipe.h | 57 int Sender() { return pipefd_[1]; } in Sender() function
66 int ret = Sender(); in ReleaseSender()
|
| D | MemUnreachable.cpp | 394 ok = ok && pipe.Sender().Send(num_allocations); in GetUnreachableMemory()
395 ok = ok && pipe.Sender().Send(allocation_bytes); in GetUnreachableMemory()
396 ok = ok && pipe.Sender().Send(num_leaks); in GetUnreachableMemory()
397 ok = ok && pipe.Sender().Send(leak_bytes); in GetUnreachableMemory()
398 ok = ok && pipe.Sender().SendVector(leaks); in GetUnreachableMemory()
|
| D | LeakPipe.h | 181 LeakPipeSender& Sender() { return sender_; } in Sender() function
|
| /system/nfc/src/rust/hal/ |
| D | hal.rs | 78 handlers: Arc<Mutex<HashMap<HalEvent, oneshot::Sender<HalEventStatus>>>>,
83 pub async fn register(&mut self, event: HalEvent, sender: oneshot::Sender<HalEventStatus>) { in register()
92 pub async fn unregister(&mut self, event: HalEvent) -> Option<oneshot::Sender<HalEventStatus>> { in unregister()
|
| D | hidl_hal.rs | 112 hal_open_evt_tx: Option<oneshot::Sender<ffi::NfcStatus>>,
113 hal_close_evt_tx: Option<oneshot::Sender<ffi::NfcStatus>>,
|
| /system/security/keystore2/src/ |
| D | apc.rs | 21 sync::{mpsc::Sender, Arc, Mutex},
189 confirmation_token_sender: Sender<Vec<u8>>,
193 fn new(confirmation_token_sender: Sender<Vec<u8>>) -> Self { in new()
208 confirmation_token_sender: Sender<Vec<u8>>, in new_native_binder()
|
| D | enforcements.rs | 42 mpsc::{channel, Receiver, Sender, TryRecvError},
228 fn timestamp_token_request(challenge: i64, sender: Sender<Result<TimeStampToken, Error>>) { in timestamp_token_request()
|
| /system/memory/libmemunreachable/tests/ |
| D | ThreadCapture_test.cpp | 189 EXPECT_EQ(1, TEMP_FAILURE_RETRY(write(start_pipe.Sender(), "+", 1))) << strerror(errno); in Fork()
202 ASSERT_EQ(1, TEMP_FAILURE_RETRY(write(stop_pipe.Sender(), "+", 1))) << strerror(errno); in Fork()
300 write(g_pipe->Sender(), &buf, 1); in TEST_F()
|
| /system/sepolicy/prebuilts/api/28.0/private/ |
| D | mls | 30 # Datagram send: Sender must be equivalent to the receiver unless one of them
|
| /system/sepolicy/prebuilts/api/29.0/private/ |
| D | mls | 30 # Datagram send: Sender must be equivalent to the receiver unless one of them
|
| /system/sepolicy/prebuilts/api/30.0/private/ |
| D | mls | 30 # Datagram send: Sender must be equivalent to the receiver unless one of them
|
| /system/sepolicy/prebuilts/api/33.0/private/ |
| D | mls | 30 # Datagram send: Sender must be equivalent to the receiver unless one of them
|
| /system/sepolicy/prebuilts/api/31.0/private/ |
| D | mls | 30 # Datagram send: Sender must be equivalent to the receiver unless one of them
|
| /system/sepolicy/private/ |
| D | mls | 30 # Datagram send: Sender must be equivalent to the receiver unless one of them
|
| /system/sepolicy/prebuilts/api/32.0/private/ |
| D | mls | 30 # Datagram send: Sender must be equivalent to the receiver unless one of them
|