Searched refs:Receiver (Results 1 – 7 of 7) sorted by relevance
| /system/memory/libmemunreachable/ |
| D | ScopedPipe.h | 56 int Receiver() { return pipefd_[0]; } in Receiver() function
60 int ret = Receiver(); in ReleaseReceiver()
|
| D | LeakPipe.h | 67 if (!SendFd(sv_[1], pipe.Receiver())) { in OpenSender()
179 LeakPipeReceiver& Receiver() { return receiver_; } in Receiver() function
|
| D | MemUnreachable.cpp | 453 ok = ok && pipe.Receiver().Receive(&info.num_allocations); in GetUnreachableMemory()
454 ok = ok && pipe.Receiver().Receive(&info.allocation_bytes); in GetUnreachableMemory()
455 ok = ok && pipe.Receiver().Receive(&info.num_leaks); in GetUnreachableMemory()
456 ok = ok && pipe.Receiver().Receive(&info.leak_bytes); in GetUnreachableMemory()
457 ok = ok && pipe.Receiver().ReceiveVector(info.leaks); in GetUnreachableMemory()
|
| /system/nfc/src/rust/nci/ |
| D | nci.rs | 26 use tokio::sync::mpsc::{channel, Receiver, Sender};
64 pub in_data_ext: Receiver<DataPacket>,
68 out_data_int: Receiver<DataPacket>,
95 pub notification: oneshot::Receiver<NotificationPacket>,
164 mut cmd_rx: Receiver<QueuedCommand>, in dispatch()
|
| /system/security/keystore2/src/ |
| D | enforcements.rs | 43 mpsc::{channel, Receiver, Sender, TryRecvError},
54 TimeStampedOpAuth(Receiver<Result<TimeStampToken, Error>>),
56 TimeStamp(Receiver<Result<TimeStampToken, Error>>),
74 fn timestamped_op_auth(receiver: Receiver<Result<TimeStampToken, Error>>) -> Arc<Self> { in timestamped_op_auth()
83 receiver: Receiver<Result<TimeStampToken, Error>>, in timestamp()
151 confirmation_token_receiver: Option<Arc<Mutex<Option<Receiver<Vec<u8>>>>>>,
377 confirmation_token_receiver: Arc<Mutex<Option<Receiver<Vec<u8>>>>>,
386 confirmation_token_receiver: Receiver<Vec<u8>>, in install_confirmation_token_receiver()
477 let mut confirmation_token_receiver: Option<Arc<Mutex<Option<Receiver<Vec<u8>>>>>> = None; in authorize_create()
|
| /system/memory/libmemunreachable/tests/ |
| D | ThreadCapture_test.cpp | 191 EXPECT_EQ(1, TEMP_FAILURE_RETRY(read(stop_pipe.Receiver(), &buf, 1))) << strerror(errno); in Fork()
198 ASSERT_EQ(1, TEMP_FAILURE_RETRY(read(start_pipe.Receiver(), &buf, 1))) << strerror(errno); in Fork()
341 ASSERT_EQ(1, TEMP_FAILURE_RETRY(read(pipe.Receiver(), &buf, 1))); in TEST_F()
|
| /system/nfc/src/rust/hal/ |
| D | hidl_hal.rs | 160 hal_close_evt_rx: oneshot::Receiver<ffi::NfcStatus>, in dispatch_outgoing()
|