Searched refs:cmd_rx (Results 1 – 4 of 4) sorted by relevance
| /system/bt/gd/rust/hal/src/ |
| D | lib.rs | 62 pub cmd_rx: UnboundedReceiver<CommandPacket>, field
72 let (cmd_tx, cmd_rx) = unbounded_channel(); in new()
88 cmd_rx, in new()
|
| 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()
103 mut cmd_rx: UnboundedReceiver<CommandPacket>, in dispatch_outgoing()
109 Some(cmd) = cmd_rx.recv() => ffi::send_command(&cmd.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()
133 mut cmd_rx: UnboundedReceiver<CommandPacket>, in dispatch_outgoing()
143 …Some(cmd) = cmd_rx.recv() => write_with_type(&mut writer, HciPacketType::Command, cmd.to_bytes()).… in dispatch_outgoing()
|
| /system/bt/gd/rust/hci/src/ |
| D | lib.rs | 58 let (cmd_tx, cmd_rx) = channel::<QueuedCommand>(10); in provide_hci()
67 cmd_rx, in provide_hci()
173 mut cmd_rx: Receiver<QueuedCommand>, in dispatch()
235 Some(queued) = cmd_rx.recv(), if pending.is_none() => { in dispatch()
|