Searched refs:evt_tx (Results 1 – 6 of 6) sorted by relevance
| /system/bt/gd/rust/link/src/acl/ |
| D | core.rs | 36 pub evt_tx: Sender<EventPacket>, field
43 evt_tx: Sender<EventPacket>, field
86 let (evt_tx, mut evt_rx) = channel(3); in provide_acl_dispatch()
87 events.register(EventCode::NumberOfCompletedPackets, evt_tx.clone()).await; in provide_acl_dispatch()
88 events.register(EventCode::DisconnectionComplete, evt_tx).await; in provide_acl_dispatch()
97 let (evt_tx, evt_rx) = channel(3); in provide_acl_dispatch()
106 evt_tx: evt_tx.clone(), in provide_acl_dispatch()
126 evt_tx, in provide_acl_dispatch()
167 c.evt_tx.send(evt.into()).await.unwrap(); in provide_acl_dispatch()
|
| /system/bt/gd/rust/hci/src/ |
| D | facade.rs | 34 let (evt_tx, evt_rx) = channel::<EventPacket>(10); in provide_facade()
39 evt_tx, in provide_facade()
56 evt_tx: Sender<EventPacket>, field
69 self.events.register(EventCode::from_u32(code).unwrap(), self.evt_tx.clone()).await; in register_event()
90 let evt_tx = self.evt_tx.clone(); in send_command() localVariable
94 evt_tx.send(response).await.unwrap(); in send_command()
|
| /system/bt/gd/rust/link/src/acl/classic/ |
| D | mod.rs | 149 let (evt_tx, mut evt_rx) = channel(3); in provide_acl_manager()
150 events.register(EventCode::ConnectionComplete, evt_tx.clone()).await; in provide_acl_manager()
151 events.register(EventCode::ConnectionRequest, evt_tx.clone()).await; in provide_acl_manager()
152 events.register(EventCode::AuthenticationComplete, evt_tx).await; in provide_acl_manager()
195 let (evt_tx, evt_rx) = channel(10); in provide_acl_manager()
208 hci_evt_tx: core_conn.evt_tx.clone(), in provide_acl_manager()
212 … rt.spawn(run_connection(handle, evt_tx, req_rx, core_conn, connections.clone(), hci.clone())); in provide_acl_manager()
267 evt_tx: Sender<ConnectionEvent>, in run_connection()
279 evt_tx.send(ConnectionEvent::Disconnected(evt.get_reason())).await.unwrap(); in run_connection()
282 … AuthenticationComplete(_) => evt_tx.send(ConnectionEvent::AuthenticationComplete).await.unwrap(), in run_connection()
|
| /system/bt/gd/rust/hal/src/ |
| D | hidl_hal.rs | 24 evt_tx: inner_hal.evt_tx, in provide_hidl_hal()
61 evt_tx: UnboundedSender<EventPacket>, field
79 Ok(p) => callbacks.as_ref().unwrap().evt_tx.send(p).unwrap(), in on_event()
|
| D | lib.rs | 63 pub evt_tx: UnboundedSender<EventPacket>, field
73 let (evt_tx, evt_rx) = unbounded_channel(); in new()
89 evt_tx, in new()
|
| D | rootcanal_hal.rs | 49 rt.spawn(dispatch_incoming(inner_hal.evt_tx, inner_hal.acl_tx, inner_hal.iso_tx, reader)); in provide_rootcanal_hal()
75 evt_tx: UnboundedSender<EventPacket>, in dispatch_incoming()
98 Ok(p) => evt_tx.send(p).unwrap(), in dispatch_incoming()
|