| /system/bt/gd/rust/facade/helpers/ |
| D | lib.rs | 21 rx: Arc<Mutex<Receiver<T>>>, field
27 pub fn new(rx: Receiver<T>) -> Self { in new()
28 Self::from_arc(Arc::new(Mutex::new(rx))) in new()
32 pub fn from_arc(rx: Arc<Mutex<Receiver<T>>>) -> Self { in from_arc()
33 Self { rx, running: false } in from_arc()
41 let clone_rx = self.rx.clone(); in stream_grpc()
62 let clone_rx = self.rx.clone(); in stream_runnable()
|
| /system/bt/stack/rfcomm/ |
| D | port_utils.cc | 123 memset(&p_port->rx, 0, sizeof(p_port->rx)); in port_set_defaults()
127 p_port->rx.queue = fixed_queue_new(SIZE_MAX); in port_set_defaults()
211 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue)) != in port_release_port()
215 p_port->rx.queue_size = 0; in port_release_port()
241 fixed_queue_free(p_port->rx.queue, nullptr); in port_release_port()
242 p_port->rx.queue = nullptr; in port_release_port()
472 if ((p_port->credit_rx <= p_port->credit_rx_low) && !p_port->rx.user_fc && in port_flow_control_peer()
479 p_port->rx.peer_fc = false; in port_flow_control_peer()
486 p_port->rx.peer_fc = true; in port_flow_control_peer()
489 else if (fixed_queue_length(p_port->rx.queue) >= p_port->credit_rx_max) { in port_flow_control_peer()
[all …]
|
| D | port_api.cc | 648 p_port->rx.user_fc = !enable; in PORT_FlowControl_MaxCredit()
651 if (!p_port->rx.user_fc) { in PORT_FlowControl_MaxCredit()
658 p_port->local_ctrl.fc = (p_port->rx.user_fc | p_port->rx.peer_fc); in PORT_FlowControl_MaxCredit()
665 if (enable && (p_port->rx.queue_size != 0)) { in PORT_FlowControl_MaxCredit()
719 if (fixed_queue_is_empty(p_port->rx.queue)) return (PORT_SUCCESS); in PORT_ReadData()
724 p_buf = (BT_HDR*)fixed_queue_try_peek_first(p_port->rx.queue); in PORT_ReadData()
736 p_port->rx.queue_size -= max_len; in PORT_ReadData()
749 p_port->rx.queue_size -= p_buf->len; in PORT_ReadData()
755 osi_free(fixed_queue_try_dequeue(p_port->rx.queue)); in PORT_ReadData()
765 p_port->rx.queue_size, *p_len, (p_data[0])); in PORT_ReadData()
[all …]
|
| D | port_rfc.cc | 792 if ((p_port->rx.queue_size + p_buf->len > PORT_RX_CRITICAL_WM) || in PORT_DataInd()
793 (fixed_queue_length(p_port->rx.queue) + 1 > p_port->rx_buf_critical)) { in PORT_DataInd()
814 fixed_queue_enqueue(p_port->rx.queue, p_buf); in PORT_DataInd()
815 p_port->rx.queue_size += p_buf->len; in PORT_DataInd()
823 if (p_port->rx.user_fc) { in PORT_DataInd()
|
| D | port_int.h | 154 tPORT_DATA rx; /* Control block for data from peer to app */ member
|
| /system/core/trusty/storage/lib/ |
| D | storage.c | 150 struct iovec rx[2] = {{&msg, sizeof(msg)}, {&rsp, sizeof(rsp)}}; in storage_open_file() local
152 ssize_t rc = send_reqv(session, tx, 3, rx, 2); in storage_open_file()
171 struct iovec rx[1] = {{&msg, sizeof(msg)}}; in storage_close_file() local
173 ssize_t rc = send_reqv(_to_session(fh), tx, 2, rx, 1); in storage_close_file()
185 struct iovec rx[1] = {{&msg, sizeof(msg)}}; in storage_delete_file() local
187 ssize_t rc = send_reqv(session, tx, 3, rx, 1); in storage_delete_file()
196 struct iovec rx[2] = {{&msg, sizeof(msg)}, {buf, size}}; in _read_chunk() local
198 ssize_t rc = send_reqv(_to_session(fh), tx, 2, rx, 2); in _read_chunk()
231 struct iovec rx[1] = {{&msg, sizeof(msg)}}; in _write_req() local
233 ssize_t rc = send_reqv(_to_session(fh), tx, 3, rx, 1); in _write_req()
[all …]
|
| /system/bt/gd/rust/facade/src/ |
| D | lib.rs | 121 let (tx, mut rx) = channel::<LifecycleCommand>(1); in create()
125 while let Some(cmd) = rx.recv().await { in create()
149 let (tx, rx) = oneshot::channel(); in start()
151 rx.await?; in start()
156 let (tx, rx) = oneshot::channel(); in stop()
158 rx.await?; in stop()
|
| D | main.rs | 82 let (tx, rx) = mpsc::unbounded(); in install_sigint()
94 rx in install_sigint()
|
| /system/bt/gd/rust/link/src/acl/ |
| D | core.rs | 31 pub rx: Option<Receiver<Bytes>>, field
56 let (tx, rx) = oneshot::channel(); in register()
58 rx.await.unwrap() in register()
121 rx: Some(out_rx), in provide_acl_dispatch()
131 Some(p) = consume(&acl.rx) => { in provide_acl_dispatch()
180 async fn consume(rx: &Arc<Mutex<Receiver<AclPacket>>>) -> Option<AclPacket> { in consume()
181 rx.lock().await.recv().await in consume()
|
| D | fragment.rs | 91 rx: ReceiverStream<Bytes>, in fragmenting_stream()
99 rx.flat_map(move |data| { in fragmenting_stream()
|
| /system/bt/gd/rust/hal/src/ |
| D | snoop.rs | 33 pub rx: Arc<Mutex<Receiver<EventPacket>>>, field
42 pub rx: Arc<Mutex<Receiver<AclPacket>>>, field
51 pub rx: Arc<Mutex<Receiver<IsoPacket>>>, field
193 control: ControlHal { tx: cmd_down_tx, rx: Arc::new(Mutex::new(evt_up_rx)) }, in provide_snooped_hal()
194 acl: AclHal { tx: acl_down_tx, rx: Arc::new(Mutex::new(acl_up_rx)) }, in provide_snooped_hal()
195 iso: IsoHal { tx: iso_down_tx, rx: Arc::new(Mutex::new(iso_up_rx)) }, in provide_snooped_hal()
199 async fn consume<T>(rx: &Arc<Mutex<UnboundedReceiver<T>>>) -> Option<T> { in consume()
200 rx.lock().await.recv().await in consume()
|
| D | facade.rs | 23 evt_rx: RxAdapter::from_arc(control.rx.clone()), in provide_facade()
24 acl_rx: RxAdapter::from_arc(acl.rx.clone()), in provide_facade()
25 iso_rx: RxAdapter::from_arc(iso.rx.clone()), in provide_facade()
|
| /system/bt/gd/rust/link/src/acl/classic/ |
| D | mod.rs | 58 rx: Receiver<Bytes>, field
77 let (tx, rx) = oneshot::channel(); in disconnect()
79 rx.await.unwrap() in disconnect()
108 let (tx, rx) = oneshot::channel(); in cancel_connect()
110 rx.await.unwrap(); in cancel_connect()
200 rx: core_conn.rx.take().unwrap(), in provide_acl_manager()
|
| /system/netd/server/ |
| D | NetlinkListener.cpp | 136 auto rx = sys.recvfrom(mSock, makeSlice(rxbuf), 0); in run() local
137 int err = rx.status().code(); in run()
146 forEachNetlinkMessage(rx.value(), rxHandler); in run()
|
| /system/iorap/src/inode2filename/ |
| D | data_source.cc | 26 namespace rx = rxcpp;
103 return rx::observable<>::create<InodeResult>( in EmitInodes()
104 [file_name](rx::subscriber<InodeResult> dest) { in EmitInodes()
|
| D | search_directories.cc | 50 namespace rx = rxcpp;
301 using ObservableT = rx::observable<ResultT>;
607 void TreeTraversalPreOrderObservableImpl(rx::subscriber<TSimple> dest, T&& node, F&& fn) { in TreeTraversalPreOrderObservableImpl()
669 return rx::observable<>::create<T_simple>( in TreeTraversalPreOrderObservable()
671 [node=node,fn=std::forward<F>(fn)](rx::subscriber<T_simple> dest) { in TreeTraversalPreOrderObservable()
|
| D | inode_resolver.cc | 26 namespace rx = rxcpp;
|
| /system/bt/gd/rust/shim/src/ |
| D | message_loop_thread.rs | 43 let (tx, mut rx) = unbounded_channel::<cxx::UniquePtr<ffi::OnceClosure>>(); in main_message_loop_thread_create()
45 while let Some(c) = rx.recv().await { in main_message_loop_thread_create()
|
| /system/bt/gd/common/ |
| D | bidi_queue.h | 33 …ueueEnd(::bluetooth::os::IQueueEnqueue<TENQUEUE>* tx, ::bluetooth::os::IQueueDequeue<TDEQUEUE>* rx) in BidiQueueEnd() argument
34 : tx_(tx), rx_(rx) {} in BidiQueueEnd()
|
| /system/bt/gd/rust/linux/adapter/src/ |
| D | main.rs | 26 rx: Receiver<Callbacks>, field
32 let (tx, rx) = mpsc::channel::<Callbacks>(1); in make_context()
80 return Context { tx, rx, callbacks: cb, intf }; in make_context()
84 'main: while let Some(cb) = context.rx.recv().await { in mainloop()
|
| /system/bt/gd/rust/linux/stack/src/ |
| D | lib.rs | 73 pub async fn dispatch(mut rx: Receiver<Message>, bluetooth: Arc<Mutex<Bluetooth>>) { in dispatch()
75 let m = rx.recv().await; in dispatch()
|
| /system/bt/gd/rust/linux/service/src/ |
| D | main.rs | 33 let (tx, rx) = Stack::create_channel(); in main()
65 topstack::get_runtime().spawn(Stack::dispatch(rx, bluetooth.clone())); in main()
|
| /system/bt/gd/rust/hci/src/ |
| D | lib.rs | 65 control.rx, in provide_hci()
98 let (tx, rx) = oneshot::channel::<EventPacket>(); in send()
100 let event = rx.await?; in send()
|
| D | facade.rs | 44 acl_rx: RxAdapter::from_arc(acl.rx), in provide_facade()
46 iso_rx: RxAdapter::from_arc(iso.rx), in provide_facade()
|
| /system/bt/gd/rust/linux/mgmt/src/bin/btmanagerd/ |
| D | state_machine.rs | 28 rx: mpsc::Receiver<StateMachineActions>, field
37 let (tx, rx) = mpsc::channel::<StateMachineActions>(1); in new()
38 StateMachineContext { tx: tx, rx: rx, state_machine: state_machine } in new()
111 Some(action) = context.rx.recv() => { in mainloop()
|