| /system/bt/gd/l2cap/internal/ |
| D | sender.cc | 32 Sender::Sender(os::Handler* handler, ILink* link, Scheduler* scheduler, std::shared_ptr<ChannelImpl… in Sender() function in bluetooth::l2cap::internal::Sender
40 Sender::Sender(os::Handler* handler, ILink* link, Scheduler* scheduler, std::shared_ptr<ChannelImpl… in Sender() function in bluetooth::l2cap::internal::Sender
57 Sender::~Sender() { in ~Sender()
63 void Sender::OnPacketSent() { in OnPacketSent()
68 std::unique_ptr<Sender::UpperDequeue> Sender::GetNextPacket() { in GetNextPacket()
72 DataController* Sender::GetDataController() { in GetDataController()
76 void Sender::try_register_dequeue() { in try_register_dequeue()
80 …queue_end_->RegisterDequeue(handler_, common::Bind(&Sender::dequeue_callback, common::Unretained(t… in try_register_dequeue()
84 void Sender::dequeue_callback() { in dequeue_callback()
95 void Sender::UpdateClassicConfiguration(classic::internal::ChannelConfigurationState config) { in UpdateClassicConfiguration()
|
| D | sender.h | 47 class Sender {
59 …Sender(os::Handler* handler, ILink* link, Scheduler* scheduler, std::shared_ptr<ChannelImpl> chann…
60 …Sender(os::Handler* handler, ILink* link, Scheduler* scheduler, std::shared_ptr<ChannelImpl> chann…
62 ~Sender();
|
| D | sender_test.cc | 66 std::unique_ptr<Sender::UpperDequeue> enqueue_callback() { in enqueue_callback()
81 sender_ = new Sender(queue_handler_, &link_, &scheduler_, mock_channel_); in SetUp()
96 common::BidiQueue<Sender::UpperEnqueue, Sender::UpperDequeue> channel_queue_{10};
98 Sender* sender_ = nullptr;
|
| D | data_pipeline_manager.h | 62 using ChannelMode = Sender::ChannelMode;
75 std::unordered_map<Cid, Sender> sender_map_;
|
| D | channel_impl.h | 26 class Sender; variable
|
| /system/bt/gd/rust/hci/src/ |
| D | lib.rs | 33 use tokio::sync::mpsc::{channel, Receiver, Sender};
84 fut: oneshot::Sender<EventPacket>,
90 cmd_tx: Sender<QueuedCommand>,
124 evt_handlers: Arc<Mutex<HashMap<EventCode, Sender<EventPacket>>>>,
125 le_evt_handlers: Arc<Mutex<HashMap<SubeventCode, Sender<LeMetaEventPacket>>>>,
130 pub async fn register(&mut self, code: EventCode, sender: Sender<EventPacket>) { in register()
154 pub async fn register_le(&mut self, code: SubeventCode, sender: Sender<LeMetaEventPacket>) { in register_le()
169 evt_handlers: Arc<Mutex<HashMap<EventCode, Sender<EventPacket>>>>, in dispatch()
170 le_evt_handlers: Arc<Mutex<HashMap<SubeventCode, Sender<LeMetaEventPacket>>>>, in dispatch()
172 cmd_tx: Sender<CommandPacket>, in dispatch()
|
| D | facade.rs | 18 use tokio::sync::mpsc::{channel, Sender};
56 evt_tx: Sender<EventPacket>,
58 le_evt_tx: Sender<LeMetaEventPacket>,
60 pub acl_tx: Sender<AclPacket>,
62 pub iso_tx: Sender<IsoPacket>,
|
| /system/bt/gd/rust/link/src/acl/ |
| D | core.rs | 17 use tokio::sync::mpsc::{channel, Receiver, Sender};
32 pub tx: Option<Sender<Bytes>>,
34 requests: Sender<Request>,
36 pub evt_tx: Sender<EventPacket>,
42 close_tx: oneshot::Sender<()>,
43 evt_tx: Sender<EventPacket>,
49 requests: Sender<Request>,
64 Register { handle: u16, bt: Bluetooth, fut: oneshot::Sender<Connection> },
|
| D | fragment.rs | 11 use tokio::sync::mpsc::Sender;
20 out: Sender<Bytes>,
25 pub fn new(out: Sender<Bytes>) -> Self { in new()
|
| /system/bt/gd/rust/link/src/acl/classic/ |
| D | mod.rs | 22 use tokio::sync::mpsc::{channel, Receiver, Sender};
35 req_tx: Sender<Request>,
59 tx: Sender<Bytes>,
61 requests: Sender<ConnectionRequest>,
85 Disconnect { reason: DisconnectReason, fut: oneshot::Sender<()> },
92 hci_evt_tx: Sender<EventPacket>,
117 CancelConnect { addr: Address, fut: oneshot::Sender<()> },
267 evt_tx: Sender<ConnectionEvent>, in run_connection()
|
| /system/memory/libmemunreachable/ |
| D | ScopedPipe.h | 57 int Sender() { return pipefd_[1]; } in Sender() function
66 int ret = Sender(); in ReleaseSender()
|
| D | MemUnreachable.cpp | 371 ok = ok && pipe.Sender().Send(num_allocations); in GetUnreachableMemory()
372 ok = ok && pipe.Sender().Send(allocation_bytes); in GetUnreachableMemory()
373 ok = ok && pipe.Sender().Send(num_leaks); in GetUnreachableMemory()
374 ok = ok && pipe.Sender().Send(leak_bytes); in GetUnreachableMemory()
375 ok = ok && pipe.Sender().SendVector(leaks); in GetUnreachableMemory()
|
| D | LeakPipe.h | 181 LeakPipeSender& Sender() { return sender_; } in Sender() function
|
| /system/bt/gd/rust/facade/src/ |
| D | lib.rs | 13 use tokio::sync::mpsc::{channel, Sender};
62 Start { req: StartStackRequest, done: oneshot::Sender<()> },
63 Stop { done: oneshot::Sender<()> },
68 lifecycle_tx: Sender<LifecycleCommand>,
|
| /system/bt/gd/rust/linux/stack/src/ |
| D | bluetooth.rs | 17 use tokio::sync::mpsc::Sender;
55 tx: Sender<Message>,
61 pub fn new(tx: Sender<Message>, intf: Arc<Mutex<BluetoothInterface>>) -> Bluetooth { in new()
|
| D | lib.rs | 20 use tokio::sync::mpsc::{Receiver, Sender};
68 pub fn create_channel() -> (Sender<Message>, Receiver<Message>) { in create_channel()
|
| /system/security/keystore2/src/ |
| D | apc.rs | 21 sync::{mpsc::Sender, Arc, Mutex},
185 confirmation_token_sender: Sender<Vec<u8>>,
189 fn new(confirmation_token_sender: Sender<Vec<u8>>) -> Self { in new()
204 confirmation_token_sender: Sender<Vec<u8>>, in new_native_binder()
|
| /system/bt/gd/rust/hal/src/ |
| D | snoop.rs | 16 use tokio::sync::mpsc::{channel, Receiver, Sender, UnboundedReceiver};
31 pub tx: Sender<CommandPacket>,
40 pub tx: Sender<AclPacket>,
49 pub tx: Sender<IsoPacket>,
|
| /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/bt/gd/rust/linux/adapter/src/ |
| D | main.rs | 10 use tokio::sync::mpsc::{Receiver, Sender};
25 tx: Sender<Callbacks>,
|
| /system/bt/gd/rust/linux/stack/btif_macros/src/ |
| D | lib.rs | 116 pub fn #fn_ident(tx: tokio::sync::mpsc::Sender<Message>) -> #callbacks_struct_ident { in btif_callbacks_generator()
|
| /system/bt/gd/rust/linux/mgmt/src/bin/btmanagerd/ |
| D | state_machine.rs | 27 tx: mpsc::Sender<StateMachineActions>,
56 tx: mpsc::Sender<StateMachineActions>,
|
| /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/27.0/private/ |
| D | mls | 30 # Datagram send: Sender must be equivalent to the receiver unless one of them
|
| /system/sepolicy/prebuilts/api/26.0/private/ |
| D | mls | 30 # Datagram send: Sender must be equivalent to the receiver unless one of them
|