| /system/bt/gd/l2cap/internal/ |
| D | receiver.cc | 28 Receiver::Receiver(LowerQueueUpEnd* link_queue_up_end, os::Handler* handler, in Receiver() function in bluetooth::l2cap::internal::Receiver
33 … common::Bind(&Receiver::link_queue_dequeue_callback, common::Unretained(this))); in Receiver()
37 Receiver::~Receiver() { in ~Receiver()
42 void Receiver::link_queue_dequeue_callback() { in link_queue_dequeue_callback()
|
| D | receiver.h | 47 class Receiver {
56 …Receiver(LowerQueueUpEnd* link_queue_up_end, os::Handler* handler, DataPipelineManager* data_pipel…
57 ~Receiver();
|
| D | data_pipeline_manager.h | 77 Receiver receiver_;
|
| /system/bt/gd/rust/facade/helpers/ |
| D | lib.rs | 9 use tokio::sync::mpsc::Receiver;
21 rx: Arc<Mutex<Receiver<T>>>,
27 pub fn new(rx: Receiver<T>) -> Self { in new()
32 pub fn from_arc(rx: Arc<Mutex<Receiver<T>>>) -> Self { in from_arc()
|
| /system/bt/gd/rust/linux/stack/src/ |
| D | lib.rs | 20 use tokio::sync::mpsc::{Receiver, Sender};
68 pub fn create_channel() -> (Sender<Message>, Receiver<Message>) { in create_channel()
73 pub async fn dispatch(mut rx: Receiver<Message>, bluetooth: Arc<Mutex<Bluetooth>>) { in dispatch()
|
| /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 | 422 ok = ok && pipe.Receiver().Receive(&info.num_allocations); in GetUnreachableMemory()
423 ok = ok && pipe.Receiver().Receive(&info.allocation_bytes); in GetUnreachableMemory()
424 ok = ok && pipe.Receiver().Receive(&info.num_leaks); in GetUnreachableMemory()
425 ok = ok && pipe.Receiver().Receive(&info.leak_bytes); in GetUnreachableMemory()
426 ok = ok && pipe.Receiver().ReceiveVector(info.leaks); in GetUnreachableMemory()
|
| /system/bt/gd/rust/link/src/acl/ |
| D | core.rs | 17 use tokio::sync::mpsc::{channel, Receiver, Sender};
31 pub rx: Option<Receiver<Bytes>>,
35 pub evt_rx: Receiver<EventPacket>,
180 async fn consume(rx: &Arc<Mutex<Receiver<AclPacket>>>) -> Option<AclPacket> { in consume()
|
| D | fragment.rs | 95 close_rx: oneshot::Receiver<()>, in fragmenting_stream() argument
|
| /system/bt/gd/rust/link/src/acl/classic/ |
| D | mod.rs | 22 use tokio::sync::mpsc::{channel, Receiver, Sender};
37 pub evt_rx: Arc<Mutex<Receiver<Event>>>,
58 rx: Receiver<Bytes>,
62 evt_rx: Receiver<ConnectionEvent>,
268 mut req_rx: Receiver<ConnectionRequest>, in run_connection()
|
| /system/bt/gd/rust/hci/src/ |
| D | lib.rs | 33 use tokio::sync::mpsc::{channel, Receiver, Sender};
171 evt_rx: Arc<Mutex<Receiver<EventPacket>>>, in dispatch()
173 mut cmd_rx: Receiver<QueuedCommand>, in dispatch()
248 async fn consume(evt_rx: &Arc<Mutex<Receiver<EventPacket>>>) -> Option<EventPacket> { in consume()
|
| /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>>>>>>,
383 confirmation_token_receiver: Arc<Mutex<Option<Receiver<Vec<u8>>>>>,
392 confirmation_token_receiver: Receiver<Vec<u8>>, in install_confirmation_token_receiver()
484 let mut confirmation_token_receiver: Option<Arc<Mutex<Option<Receiver<Vec<u8>>>>>> = None; in authorize_create()
|
| /system/bt/gd/rust/hal/src/ |
| D | snoop.rs | 16 use tokio::sync::mpsc::{channel, Receiver, Sender, UnboundedReceiver};
33 pub rx: Arc<Mutex<Receiver<EventPacket>>>,
42 pub rx: Arc<Mutex<Receiver<AclPacket>>>,
51 pub rx: Arc<Mutex<Receiver<IsoPacket>>>,
|
| /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/bt/gd/rust/linux/adapter/src/ |
| D | main.rs | 10 use tokio::sync::mpsc::{Receiver, Sender};
26 rx: Receiver<Callbacks>,
|
| /system/bt/gd/l2cap/ |
| D | l2cap_packets.pdl | 541 cid : 16, // Receiver's destination CID
693 cid : 16, // Receiver's destination CID
|
| /system/bt/gd/rust/linux/mgmt/src/bin/btmanagerd/ |
| D | state_machine.rs | 28 rx: mpsc::Receiver<StateMachineActions>,
|