| /system/bt/gd/rust/main/src/ |
| D | lib.rs | 26 pub async fn new(rt: Arc<Runtime>) -> Self { in new()
34 pub async fn set_rootcanal_port(&self, port: Option<u16>) { in set_rootcanal_port()
41 pub async fn use_default_snoop(&self) { in use_default_snoop()
46 pub async fn configure_snoop(&self, path: Option<String>) { in configure_snoop()
56 pub async fn get<T: 'static + Clone + Send + Sync + Stoppable>(&self) -> T { in get()
66 pub async fn get_grpc<T: 'static + Clone + Send + Sync + GrpcFacade + Stoppable>( in get_grpc()
73 pub async fn stop(&mut self) { in stop()
|
| /system/bt/gd/rust/linux/mgmt/src/bin/btmanagerd/ |
| D | main.rs | 9 pub async fn main() -> Result<(), Box<dyn std::error::Error>> { in main()
18 tokio::spawn(async { in main()
48 async move { in main()
63 async move { in main()
76 async move { in main()
94 async move { in main()
113 async move { in main()
140 tokio::spawn(async move { in main()
|
| /system/bt/gd/rust/common/src/ |
| D | time.rs | 34 pub async fn expired(&mut self) { in expired()
64 pub async fn tick(&mut self) { in tick()
91 runtime.block_on(async { in alarm_simple_case()
106 runtime.block_on(async { in alarm_clear_ready_after_expired()
111 let ready_in_10_ms = async { in alarm_clear_ready_after_expired()
125 runtime.block_on(async { in interval_schedule_and_then_drop()
133 runtime.block_on(async { in interval_simple_case()
|
| /system/bt/gd/rust/hci/src/ |
| D | facade.rs | 28 async fn provide_facade( in provide_facade()
68 pub async fn register_event(&mut self, code: u32) { in register_event()
73 pub async fn register_le_event(&mut self, code: u32) { in register_le_event()
91 ctx.spawn(async move { in send_command()
100 ctx.spawn(async move { in request_event()
113 ctx.spawn(async move { in request_le_subevent()
121 ctx.spawn(async move { in send_acl()
|
| D | lib.rs | 57 async fn provide_hci(control: ControlHal, rt: Arc<Runtime>) -> Hci { in provide_hci()
97 pub async fn send(&mut self, cmd: CommandPacket) -> Result<EventPacket> { in send()
113 pub async fn send<T: Into<CommandPacket> + CommandExpectations>( in send()
130 pub async fn register(&mut self, code: EventCode, sender: Sender<EventPacket>) { in register()
149 pub async fn unregister(&mut self, code: EventCode) { in unregister()
154 pub async fn register_le(&mut self, code: SubeventCode, sender: Sender<LeMetaEventPacket>) { in register_le()
163 pub async fn unregister_le(&mut self, code: SubeventCode) { in unregister_le()
168 async fn dispatch( in dispatch()
248 async fn consume(evt_rx: &Arc<Mutex<Receiver<EventPacket>>>) -> Option<EventPacket> { in consume()
|
| D | controller_facade.rs | 22 async fn provide_facade(exports: Arc<ControllerExports>, hci: Hci) -> ControllerFacadeService { in provide_facade()
43 ctx.spawn(async move { in get_mac_address()
54 ctx.spawn(async move { in write_local_name()
62 ctx.spawn(async move { in get_local_name()
|
| /system/bt/gd/rust/linux/adapter/src/ |
| D | main.rs | 38 topstack::get_runtime().spawn(async move { in make_context()
44 topstack::get_runtime().spawn(async move { in make_context()
50 topstack::get_runtime().spawn(async move { in make_context()
56 topstack::get_runtime().spawn(async move { in make_context()
62 topstack::get_runtime().spawn(async move { in make_context()
83 async fn mainloop(context: &mut Context) { in mainloop()
168 topstack::get_runtime().block_on(async move { in main()
|
| /system/bt/gd/rust/shim/src/ |
| D | hci.rs | 44 hci.rt.spawn(async move { in hci_send_command()
57 hci.rt.spawn(async move { in hci_send_acl()
67 hci.rt.spawn(async move { in hci_register_event()
74 hci.rt.spawn(async move { in hci_register_le_event()
|
| D | message_loop_thread.rs | 44 rt.spawn(async move { in main_message_loop_thread_create()
56 thread.rt.block_on(async move { nix::unistd::gettid().as_raw() }) in main_message_loop_thread_start()
70 thread.rt.spawn(async move { in main_message_loop_thread_do_delayed()
|
| /system/bt/gd/rust/facade/src/ |
| D | lib.rs | 77 async fn start(stack: Stack, req: StartStackRequest, grpc_port: u16) -> Self { in start()
105 async fn stop(&mut self) { in stop()
123 rt.spawn(async move { in create()
148 async fn start(&self, req: StartStackRequest) -> Result<()> { in start()
155 async fn stop(&self) -> Result<()> { in stop()
|
| D | main.rs | 30 async fn async_main(rt: Arc<Runtime>, mut sigint: mpsc::UnboundedReceiver<()>) { in async_main()
74 async fn indicate_started(signal_port: u16) { in indicate_started()
|
| /system/bt/gd/rust/hal/src/ |
| D | facade.rs | 21 async fn provide_facade(control: ControlHal, acl: AclHal, iso: IsoHal) -> HciHalFacadeService { in provide_facade()
52 ctx.spawn(async move { in send_command()
60 ctx.spawn(async move { in send_acl()
72 ctx.spawn(async move { in send_iso()
|
| D | snoop.rs | 133 async fn provide_snooped_hal(config: SnoopConfig, raw_hal: RawHal, rt: Arc<Runtime>) -> Hal { in provide_snooped_hal()
141 rt.spawn(async move { in provide_snooped_hal()
199 async fn consume<T>(rx: &Arc<Mutex<UnboundedReceiver<T>>>) -> Option<T> { in consume()
227 async fn new(mut config: SnoopConfig) -> Self { in new()
246 async fn log(&mut self, t: Type, dir: Direction, bytes: Bytes) { in log()
294 async fn close_file(&mut self) { in close_file()
302 async fn open_next_file(&mut self) { in open_next_file()
|
| D | rootcanal_hal.rs | 42 async fn provide_rootcanal_hal(config: RootcanalConfig, rt: Arc<Runtime>) -> RawHal { in provide_rootcanal_hal()
74 async fn dispatch_incoming<R>( in dispatch_incoming()
132 async fn dispatch_outgoing<W>( in dispatch_outgoing()
153 async fn write_with_type<W>(writer: &mut W, t: HciPacketType, b: Bytes) -> Result<()> in write_with_type()
|
| /system/iorap/src/common/ |
| D | async_pool.h | 79 auto future = std::async(std::launch::async, std::forward<T>(u)); in LaunchAsync()
|
| /system/bt/gd/rust/link/src/acl/classic/ |
| D | mod.rs | 76 pub async fn disconnect(&mut self, reason: DisconnectReason) { in disconnect()
102 pub async fn connect(&mut self, addr: Address) { in connect()
107 pub async fn cancel_connect(&mut self, addr: Address) { in cancel_connect()
134 async fn provide_acl_manager( in provide_acl_manager()
144 local_rt.spawn(async move { in provide_acl_manager()
255 async fn dispatch_to( in dispatch_to()
265 async fn run_connection( in run_connection()
|
| /system/bt/gd/rust/facade/helpers/ |
| D | lib.rs | 42 ctx.spawn(async move { in stream_grpc()
63 rt.spawn(async move { in stream_runnable()
|
| /system/bt/gd/rust/gddi/src/ |
| D | lib.rs | 79 pub async fn get<T: 'static + Clone + Send + Sync + Stoppable>(self: &Arc<Self>) -> T { in get()
104 pub async fn inject<T: 'static + Clone + Send + Sync>(self: &Arc<Self>, obj: T) { in inject()
110 pub async fn stop_all(self: &Arc<Self>) { in stop_all()
|
| /system/bt/gd/rust/link/src/acl/ |
| D | core.rs | 55 pub async fn register(&mut self, handle: u16, bt: Bluetooth) -> Connection { in register()
70 async fn provide_acl_dispatch( in provide_acl_dispatch()
79 rt.spawn(async move { in provide_acl_dispatch()
180 async fn consume(rx: &Arc<Mutex<Receiver<AclPacket>>>) -> Option<AclPacket> { in consume()
|
| /system/media/audio_utils/include/audio_utils/ |
| D | FdToString.h | 51 mOutput = std::async(std::launch::async, reader, mPipeFd[0], mTimeoutTimeNs, mPrefix); in mPrefix()
|
| /system/bt/gd/rust/linux/service/src/ |
| D | main.rs | 39 topstack::get_runtime().block_on(async { in main()
45 topstack::get_runtime().spawn(async { in main()
|
| /system/sepolicy/prebuilts/api/30.0/private/ |
| D | keystore.te | 11 # This is used for the ConfirmationUI async callback.
|
| /system/sepolicy/prebuilts/api/29.0/private/ |
| D | keystore.te | 11 # This is used for the ConfirmationUI async callback.
|
| /system/sepolicy/prebuilts/api/28.0/private/ |
| D | keystore.te | 11 # This is used for the ConfirmationUI async callback.
|
| /system/bt/vendor_libs/linux/interface/ |
| D | async_fd_watcher.h | 26 namespace async {
|