Searched refs:Sender (Results 1 – 11 of 11) sorted by relevance
| /system/memory/libmemunreachable/ |
| D | ScopedPipe.h | 57 int Sender() { return pipefd_[1]; } in Sender() function
66 int ret = Sender(); in ReleaseSender()
|
| D | MemUnreachable.cpp | 396 ok = ok && pipe.Sender().Send(num_allocations); in GetUnreachableMemory()
397 ok = ok && pipe.Sender().Send(allocation_bytes); in GetUnreachableMemory()
398 ok = ok && pipe.Sender().Send(num_leaks); in GetUnreachableMemory()
399 ok = ok && pipe.Sender().Send(leak_bytes); in GetUnreachableMemory()
400 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 | 113 hal_open_evt_tx: Option<oneshot::Sender<ffi::NfcStatus>>,
114 hal_close_evt_tx: Option<oneshot::Sender<ffi::NfcStatus>>,
|
| /system/nfc/src/rust/nci/ |
| D | nci.rs | 32 use tokio::sync::mpsc::{channel, Receiver, Sender, UnboundedSender};
76 response: oneshot::Sender<Response>,
82 notification: Option<oneshot::Sender<Notification>>,
87 cmd_tx: Sender<QueuedCommand>,
297 handlers: Arc<Mutex<HashMap<Opcode, oneshot::Sender<Notification>>>>,
302 pub async fn register(&mut self, code: Opcode, sender: oneshot::Sender<Notification>) { in register()
311 pub async fn unregister(&mut self, code: Opcode) -> Option<oneshot::Sender<Notification>> { in unregister()
|
| /system/security/keystore2/src/ |
| D | apc.rs | 21 sync::{mpsc::Sender, Arc, Mutex},
162 confirmation_token_sender: Sender<Vec<u8>>,
166 fn new(confirmation_token_sender: Sender<Vec<u8>>) -> Self { in new()
181 confirmation_token_sender: Sender<Vec<u8>>, in new_native_binder()
|
| D | enforcements.rs | 43 mpsc::{channel, Receiver, Sender, TryRecvError},
234 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/security/keystore2/rkpd_client/src/ |
| D | lib.rs | 84 inner: Mutex<Option<oneshot::Sender<T>>>,
88 fn new(sender: oneshot::Sender<T>) -> Self { in new()
109 registration_tx: oneshot::Sender<Result<binder::Strong<dyn IRegistration>>>, in new_native_binder()
168 key_tx: oneshot::Sender<Result<RemotelyProvisionedKey>>, in new_native_binder()
243 completer: oneshot::Sender<Result<()>>, in new_native_binder()
|
| /system/sepolicy/private/ |
| D | mls | 30 # Datagram send: Sender must be equivalent to the receiver unless one of them
|