Searched refs:evt_rx (Results 1 – 8 of 8) sorted by relevance
| /system/bt/gd/rust/hal/src/ |
| D | lib.rs | 54 pub evt_rx: Arc<Mutex<UnboundedReceiver<EventPacket>>>, field
73 let (evt_tx, evt_rx) = unbounded_channel(); in new()
81 evt_rx: Arc::new(Mutex::new(evt_rx)), in new()
|
| D | facade.rs | 23 evt_rx: RxAdapter::from_arc(control.rx.clone()), in provide_facade()
35 evt_rx: RxAdapter<EventPacket>, field
79 self.evt_rx.stream_grpc(ctx, sink); in stream_events()
|
| D | snoop.rs | 145 Some(evt) = consume(&raw_hal.evt_rx) => { in provide_snooped_hal()
|
| /system/bt/gd/rust/hci/src/ |
| D | facade.rs | 34 let (evt_tx, evt_rx) = channel::<EventPacket>(10); in provide_facade()
40 evt_rx: RxAdapter::new(evt_rx), in provide_facade()
57 pub evt_rx: RxAdapter<EventPacket>, field
128 self.evt_rx.stream_grpc(ctx, sink); in stream_events()
|
| D | lib.rs | 171 evt_rx: Arc<Mutex<Receiver<EventPacket>>>, in dispatch()
179 Some(evt) = consume(&evt_rx) => { in dispatch()
248 async fn consume(evt_rx: &Arc<Mutex<Receiver<EventPacket>>>) -> Option<EventPacket> { in consume()
249 evt_rx.lock().await.recv().await in consume()
|
| /system/bt/gd/rust/link/src/acl/classic/ |
| D | mod.rs | 37 pub evt_rx: Arc<Mutex<Receiver<Event>>>, field
62 evt_rx: Receiver<ConnectionEvent>, field
149 let (evt_tx, mut evt_rx) = channel(3); in provide_acl_manager()
179 Some(evt) = evt_rx.recv() => { in provide_acl_manager()
195 let (evt_tx, evt_rx) = channel(10); in provide_acl_manager()
203 evt_rx, in provide_acl_manager()
241 AclManager { req_tx, evt_rx: Arc::new(Mutex::new(conn_evt_rx)) } in provide_acl_manager()
275 Some(evt) = core.evt_rx.recv() => { in run_connection()
|
| /system/bt/gd/rust/link/src/acl/ |
| D | core.rs | 35 pub evt_rx: Receiver<EventPacket>, field
86 let (evt_tx, mut evt_rx) = channel(3); in provide_acl_dispatch()
97 let (evt_tx, evt_rx) = channel(3); in provide_acl_dispatch()
125 evt_rx, in provide_acl_dispatch()
146 Some(evt) = evt_rx.recv() => { in provide_acl_dispatch()
|
| /system/bt/gd/rust/shim/src/ |
| D | hci.rs | 84 hci.internal.evt_rx.stream_runnable(&hci.rt, CallbackWrapper { cb }); in hci_set_evt_callback()
|