Home
last modified time | relevance | path

Searched refs:Sender (Results 1 – 25 of 42) sorted by relevance

12

/packages/modules/Bluetooth/system/gd/l2cap/internal/
Dsender.cc32 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()
Dsender.h47 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();
Dsender_test.cc66 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;
Ddata_pipeline_manager.h62 using ChannelMode = Sender::ChannelMode;
75 std::unordered_map<Cid, Sender> sender_map_;
Dchannel_impl.h26 class Sender; variable
/packages/modules/Bluetooth/system/gd/rust/linux/stack/src/
Dbattery_service.rs21 use tokio::sync::mpsc::Sender;
33 tx: Sender<Message>,
35 api_tx: Sender<APIMessage>,
102 tx: Sender<Message>, in new()
103 api_tx: Sender<APIMessage>, in new()
378 tx: Sender<Message>,
382 fn new(tx: Sender<Message>) -> Self { in new()
403 tx: Sender<Message>,
404 api_tx: Sender<APIMessage>,
408 fn new(tx: Sender<Message>, api_tx: Sender<APIMessage>) -> Self { in new()
Ddis.rs5 use tokio::sync::mpsc::Sender;
35 tx: Sender<Message>,
39 pub fn new(bluetooth_gatt: Arc<Mutex<Box<BluetoothGatt>>>, tx: Sender<Message>) -> Self { in new()
153 tx: Sender<Message>,
157 fn new(tx: Sender<Message>) -> Self { in new()
Dbattery_provider_manager.rs7 use tokio::sync::mpsc::Sender;
38 tx: Sender<Message>,
46 pub fn new(tx: Sender<Message>) -> BatteryProviderManager { in new()
Dcallbacks.rs4 use tokio::sync::mpsc::Sender;
12 tx: Sender<Message>,
22 pub fn new(tx: Sender<Message>, disconnected_message: fn(u32) -> Message) -> Self { in new()
Dbluetooth_qa.rs7 use tokio::sync::mpsc::Sender;
56 tx: Sender<Message>,
61 pub fn new(tx: Sender<Message>) -> BluetoothQA { in new()
Dbattery_manager.rs9 use tokio::sync::mpsc::Sender;
70 tx: Sender<Message>, in new()
Dsocket_manager.rs19 use tokio::sync::mpsc::{channel, Receiver, Sender};
405 tx: Sender<SocketRunnerActions>,
418 tx: Sender<SocketRunnerActions>, in new()
517 tx: Sender<Message>,
525 pub fn new(tx: Sender<Message>, admin: Arc<Mutex<Box<BluetoothAdmin>>>) -> Self { in new()
763 rpc_tx: Sender<Message>, in listening_task()
1054 tx: Sender<Message>, in connecting_task()
1216 .collect::<Vec<(u64, Sender<SocketRunnerActions>, Uuid)>>(); in handle_admin_policy_changed()
Dlib.rs28 use tokio::sync::mpsc::{Receiver, Sender};
205 pub fn create_channel() -> (Sender<Message>, Receiver<Message>) { in create_channel()
212 tx: Sender<Message>, in dispatch()
213 api_tx: Sender<APIMessage>, in dispatch()
Dbluetooth_admin.rs16 use tokio::sync::mpsc::Sender;
67 tx: Sender<Message>,
71 pub fn new(path: String, tx: Sender<Message>) -> BluetoothAdmin { in new()
Dsuspend.rs12 use tokio::sync::mpsc::Sender;
134 tx: Sender<Message>,
154 tx: Sender<Message>, in new()
Dasync_helper.rs18 senders: Arc<Mutex<HashMap<u32, oneshot::Sender<R>>>>,
Dbluetooth_media.rs52 use tokio::sync::mpsc::Sender;
455 tx: Sender<Message>,
499 tx: Sender<Message>, in new()
1259 fn disconnect_device(txl: Sender<Message>, addr: RawAddress) { in disconnect_device()
2167 txl: &Sender<Message>, in wait_retry()
2190 txl: &Sender<Message>, in wait_disconnect()
2205 txl: &Sender<Message>, in async_disconnect()
2221 txl: &Sender<Message>, in wait_force_enter_connected()
3031 fn get_a2dp_dispatcher(tx: Sender<Message>) -> A2dpCallbacksDispatcher { in get_a2dp_dispatcher()
3042 fn get_avrcp_dispatcher(tx: Sender<Message>) -> AvrcpCallbacksDispatcher { in get_avrcp_dispatcher()
[all …]
/packages/modules/Bluetooth/system/rust/src/gatt/mocks/
Dmock_raw_datastore.rs39 oneshot::Sender<Result<Vec<u8>, AttErrorCode>>,
49 oneshot::Sender<Result<(), AttErrorCode>>,
55 Execute(TransportIndex, TransactionDecision, oneshot::Sender<Result<(), AttErrorCode>>),
Dmock_datastore.rs38 oneshot::Sender<Result<Vec<u8>, AttErrorCode>>,
47 oneshot::Sender<Result<(), AttErrorCode>>,
/packages/modules/DnsResolver/doh/dispatcher/
Dmod.rs62 resp: oneshot::Sender<Response>,
73 cmd_sender: mpsc::Sender<Command>,
/packages/modules/DnsResolver/doh/network/
Dmod.rs63 pub response: oneshot::Sender<Response>,
72 command_tx: mpsc::Sender<Command>,
Ddriver.rs38 status_tx: watch::Sender<Status>,
94 ) -> Result<(Self, mpsc::Sender<Command>, watch::Receiver<Status>)> { in new()
/packages/modules/Bluetooth/system/gd/rust/linux/service/src/
Dinterface_manager.rs6 use tokio::sync::mpsc::{channel, Receiver, Sender};
35 pub fn create_channel() -> (Sender<APIMessage>, Receiver<APIMessage>) { in create_channel()
54 tx: Sender<Message>, in dispatch()
/packages/modules/DnsResolver/doh/connection/
Ddriver.rs103 pub response_tx: oneshot::Sender<Stream>,
127 status_tx: watch::Sender<Status>,
168 status_tx: watch::Sender<Status>, in drive()
180 status_tx: watch::Sender<Status>, in new()
/packages/modules/Bluetooth/system/gd/rust/topshim/facade/src/
Dhfp_service.rs21 tx: Arc<Mutex<Option<mpsc::Sender<HfpCallbacks>>>>, in get_hfp_dispatcher()
50 event_tx: Arc<Mutex<Option<mpsc::Sender<HfpCallbacks>>>>,

12