Searched refs:acl_rx (Results 1 – 7 of 7) sorted by relevance
/system/bt/gd/rust/hal/src/ |
D | lib.rs | 56 pub acl_rx: Arc<Mutex<UnboundedReceiver<AclPacket>>>, field 64 pub acl_rx: UnboundedReceiver<AclPacket>, field 83 acl_rx: Arc::new(Mutex::new(acl_up_rx)), in new() 90 acl_rx: acl_down_rx, in new()
|
D | facade.rs | 24 acl_rx: RxAdapter::from_arc(acl.rx.clone()), in provide_facade() 36 acl_rx: RxAdapter<AclPacket>, field 83 self.acl_rx.stream_grpc(ctx, sink); in stream_acl()
|
D | hidl_hal.rs | 31 rt.spawn(dispatch_outgoing(inner_hal.cmd_rx, inner_hal.acl_rx, inner_hal.iso_rx)); in provide_hidl_hal() 104 mut acl_rx: UnboundedReceiver<AclPacket>, in dispatch_outgoing() 110 Some(acl) = acl_rx.recv() => ffi::send_acl(&acl.to_bytes()), in dispatch_outgoing()
|
D | rootcanal_hal.rs | 50 rt.spawn(dispatch_outgoing(inner_hal.cmd_rx, inner_hal.acl_rx, inner_hal.iso_rx, writer)); in provide_rootcanal_hal() 134 mut acl_rx: UnboundedReceiver<AclPacket>, in dispatch_outgoing() 144 …Some(acl) = acl_rx.recv() => write_with_type(&mut writer, HciPacketType::Acl, acl.to_bytes()).awai… in dispatch_outgoing()
|
D | snoop.rs | 166 Some(acl) = consume(&raw_hal.acl_rx) => { in provide_snooped_hal()
|
/system/bt/gd/rust/hci/src/ |
D | facade.rs | 44 acl_rx: RxAdapter::from_arc(acl.rx), in provide_facade() 61 pub acl_rx: RxAdapter<AclPacket>, field 141 self.acl_rx.stream_grpc(ctx, sink); in stream_acl()
|
/system/bt/gd/rust/shim/src/ |
D | hci.rs | 80 hci.internal.acl_rx.stream_runnable(&hci.rt, CallbackWrapper { cb }); in hci_set_acl_callback()
|