| /packages/modules/Bluetooth/system/gd/rust/linux/stack/src/ |
| D | battery_service.rs | 33 tx: Sender<Message>, field
102 tx: Sender<Message>, in new()
105 let tx = tx.clone(); in new() localVariable
106 let callbacks = Callbacks::new(tx.clone(), Message::BatteryServiceCallbackDisconnected); in new()
113 .register_battery_provider(Box::new(BatteryProviderCallback::new(tx.clone()))); in new()
118 tx, in new()
133 Box::new(GattCallback::new(self.tx.clone(), self.api_tx.clone())), in init()
378 tx: Sender<Message>, field
382 fn new(tx: Sender<Message>) -> Self { in new()
383 Self { tx } in new()
[all …]
|
| D | suspend.rs | 134 tx: Sender<Message>, field
154 tx: Sender<Message>, in new()
161 tx: tx.clone(), in new()
162 callbacks: Callbacks::new(tx.clone(), Message::SuspendCallbackDisconnected), in new()
212 let tx = self.tx.clone(); in register_callback() localVariable
214 let _result = tx.send(Message::SuspendCallbackRegistered(id)).await; in register_callback()
269 let tx = self.tx.clone(); in suspend() localVariable
277 let _result = tx.send(Message::SuspendReady(suspend_id)).await; in suspend()
322 let txl = self.tx.clone(); in resume()
360 let tx = self.tx.clone(); in resume() localVariable
[all …]
|
| D | bluetooth_qa.rs | 56 tx: Sender<Message>, field
61 pub fn new(tx: Sender<Message>) -> BluetoothQA { in new()
63 tx: tx.clone(), in new()
64 callbacks: Callbacks::new(tx.clone(), Message::QaCallbackDisconnected), in new()
113 let txl = self.tx.clone(); in add_media_player()
119 let txl = self.tx.clone(); in rfcomm_send_msc()
125 let txl = self.tx.clone(); in fetch_discoverable_mode()
131 let txl = self.tx.clone(); in fetch_connectable()
137 let txl = self.tx.clone(); in set_connectable()
143 let txl = self.tx.clone(); in fetch_alias()
[all …]
|
| D | callbacks.rs | 12 tx: Sender<Message>, field
22 pub fn new(tx: Sender<Message>, disconnected_message: fn(u32) -> Message) -> Self { in new()
26 tx, in new()
43 let tx = self.tx.clone(); in add_callback() localVariable
46 let tx = tx.clone(); in add_callback() localVariable
48 let _result = tx.send(disconnected_message(cb_id)).await; in add_callback()
124 let (tx, _rx) = crate::Stack::create_channel(); in test_add_and_remove()
125 let mut callbacks = Callbacks::new(tx.clone(), Message::AdapterCallbackDisconnected); in test_add_and_remove()
|
| D | socket_manager.rs | 405 tx: Sender<SocketRunnerActions>, field
418 tx: Sender<SocketRunnerActions>, in new()
422 InternalListeningSocket { _callback_id, socket_id, tx, uuid, joinhandle } in new()
517 tx: Sender<Message>, field
525 pub fn new(tx: Sender<Message>, admin: Arc<Mutex<Box<BluetoothAdmin>>>) -> Self { in new()
526 let callbacks = Callbacks::new(tx.clone(), Message::SocketManagerCallbackDisconnected); in new()
546 tx, in new()
565 let txl = self.tx.clone(); in trigger_update_connectable_mode()
635 let rpc_tx = self.tx.clone(); in socket_listen()
722 let tx = self.tx.clone(); in socket_connect() localVariable
[all …]
|
| D | battery_provider_manager.rs | 38 tx: Sender<Message>, field
46 pub fn new(tx: Sender<Message>) -> BatteryProviderManager { in new()
48 Callbacks::new(tx.clone(), Message::BatteryProviderManagerCallbackDisconnected); in new()
50 BatteryProviderManager { tx, battery_provider_callbacks, battery_info } in new()
114 let tx = self.tx.clone(); in set_battery_info() localVariable
116 let _ = tx in set_battery_info()
|
| D | dis.rs | 35 tx: Sender<Message>, field
39 pub fn new(bluetooth_gatt: Arc<Mutex<Box<BluetoothGatt>>>, tx: Sender<Message>) -> Self { in new()
40 Self { bluetooth_gatt, gatt_server_id: None, pnp_id_handle: None, tx } in new()
44 let callback = Box::new(DeviceInformationServerCallbacks::new(self.tx.clone())); in initialize()
153 tx: Sender<Message>, field
157 fn new(tx: Sender<Message>) -> Self { in new()
158 Self { tx } in new()
164 let txl = self.tx.clone(); in on_server_registered()
171 let txl = self.tx.clone(); in on_service_added()
185 let txl = self.tx.clone(); in on_characteristic_read_request()
|
| D | bluetooth_admin.rs | 67 tx: Sender<Message>, field
71 pub fn new(path: String, tx: Sender<Message>) -> BluetoothAdmin { in new()
77 callbacks: Callbacks::new(tx.clone(), Message::AdminCallbackDisconnected), in new()
79 tx: tx.clone(), in new()
226 let txl = self.tx.clone(); in set_allowed_services()
287 let (tx, _) = Stack::create_channel(); in test_set_service_allowed()
288 let mut admin = BluetoothAdmin::new(String::from(""), tx.clone()); in test_set_service_allowed()
339 let (tx, _) = Stack::create_channel(); in test_config()
340 let mut admin = BluetoothAdmin::new(String::from(""), tx.clone()); in test_config()
|
| D | bluetooth.rs | 616 tx: Sender<Message>, field
638 tx: Sender<Message>, in new()
650 callbacks: Callbacks::new(tx.clone(), Message::AdapterCallbackDisconnected), in new()
652 tx.clone(), in new()
677 tx, in new()
718 let txl = self.tx.clone(); in trigger_update_connectable_mode()
824 let txl = self.tx.clone(); in toggle_enabled_profiles()
843 let sdptx = self.tx.clone(); in init_profiles()
854 let hhtx = self.tx.clone(); in init_profiles()
1537 pub fn get_bt_dispatcher(tx: Sender<Message>) -> BaseCallbacksDispatcher { in get_bt_dispatcher()
[all …]
|
| /packages/modules/Bluetooth/system/osi/src/ |
| D | stack_power_telemetry.cc | 88 } rx, tx; member
110 } rx, tx; member
117 } rx, tx; member
187 } rx, tx; member
192 } rx, tx; member
211 if ((l2c.rx.bytes_ != 0) || (l2c.tx.bytes_ != 0)) { in LogDataTransfer()
217 .tx = in LogDataTransfer()
219 .bytes = l2c.tx.bytes_, in LogDataTransfer()
225 if ((rfc.rx.bytes_ != 0) || (rfc.tx.bytes_ != 0)) { in LogDataTransfer()
231 .tx = in LogDataTransfer()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/linux/service/src/ |
| D | main.rs | 125 let (tx, rx) = Stack::create_channel(); in main()
136 Arc::new(Mutex::new(Box::new(BluetoothGatt::new(intf.clone(), tx.clone())))); in main()
138 Arc::new(Mutex::new(Box::new(BatteryProviderManager::new(tx.clone())))); in main()
142 tx.clone(), in main()
147 tx.clone(), in main()
150 tx.clone(), in main()
156 tx.clone(), in main()
161 tx.clone(), in main()
174 tx.clone(), in main()
177 tx.clone(), in main()
[all …]
|
| /packages/modules/Bluetooth/system/rust/src/gatt/mocks/ |
| D | mock_raw_datastore.rs | 24 let (tx, rx) = unbounded_channel(); in new()
25 (Self(tx), rx) in new()
67 let (tx, rx) = oneshot::channel(); in read()
68 self.0.send(MockRawDatastoreEvents::Read(tcb_idx, handle, attr_type, offset, tx)).unwrap(); in read()
82 let (tx, rx) = oneshot::channel(); in write()
90 tx, in write()
118 let (tx, rx) = oneshot::channel(); in execute()
119 self.0.send(MockRawDatastoreEvents::Execute(tcb_idx, decision, tx)).unwrap(); in execute()
|
| D | mock_datastore.rs | 24 let (tx, rx) = unbounded_channel(); in new()
25 (Self(tx), rx) in new()
59 let (tx, rx) = oneshot::channel(); in read()
60 self.0.send(MockDatastoreEvents::Read(tcb_idx, handle, attr_type, tx)).unwrap(); in read()
73 let (tx, rx) = oneshot::channel(); in write()
75 .send(MockDatastoreEvents::Write(tcb_idx, handle, attr_type, data.to_vec(), tx)) in write()
|
| /packages/modules/Bluetooth/system/rust/src/gatt/server/ |
| D | indication_handler.rs | 48 let (tx, rx) = mpsc::channel(1); in new()
49 (Self { db, pending_confirmation: rx }, ConfirmationWatcher(tx)) in new()
173 let (tx, rx) = oneshot::channel(); in test_indication_sent()
179 tx.send(packet).unwrap(); in test_indication_sent()
239 let (tx, rx) = oneshot::channel(); in test_confirmation_handled()
245 tx.send(packet).unwrap(); in test_confirmation_handled()
265 let (tx, rx) = oneshot::channel(); in test_unblock_on_disconnect()
271 tx.send(packet).unwrap(); in test_unblock_on_disconnect()
295 let (tx, rx) = oneshot::channel(); in test_spurious_confirmations()
303 tx.send(packet).unwrap(); in test_spurious_confirmations()
[all …]
|
| /packages/services/Car/tests/CarTelemetryApp/res/raw/ |
| D | conn_sessions.lua | 34 tx = {}
43 tx[ps] = 0
47 tx[ps] = tx[ps] + published_data['conn.txBytes'][i]
52 res[p] = 'rx: ' .. rx[p] .. ', tx: ' .. tx[p] .. ', uid: ' .. uids[p]
|
| /packages/modules/Bluetooth/system/stack/rfcomm/ |
| D | port_utils.cc | 124 memset(&p_port->tx, 0, sizeof(p_port->tx)); in port_set_defaults()
126 p_port->tx.queue = fixed_queue_new(SIZE_MAX); in port_set_defaults()
215 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->tx.queue)) != in port_release_port()
219 p_port->tx.queue_size = 0; in port_release_port()
237 fixed_queue_free(p_port->tx.queue, nullptr); in port_release_port()
238 p_port->tx.queue = nullptr; in port_release_port()
386 bool fc = p_port->tx.peer_fc || !p_port->rfc.p_mcb || in port_flow_control_user()
388 (p_port->tx.queue_size > PORT_TX_HIGH_WM) || in port_flow_control_user()
389 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM); in port_flow_control_user()
391 if (p_port->tx.user_fc == fc) return (0); in port_flow_control_user()
[all …]
|
| D | port_api.cc | 802 if (p_port->tx.peer_fc || !p_port->rfc.p_mcb || in port_write()
807 if ((p_port->tx.queue_size > PORT_TX_CRITICAL_WM) || in port_write()
808 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_CRITICAL_WM)) { in port_write()
809 log::warn("PORT_Write: Queue size: {}", p_port->tx.queue_size); in port_write()
822 p_port->tx.peer_fc, p_port->rfc.p_mcb && p_port->rfc.p_mcb->peer_ready, in port_write()
825 fixed_queue_enqueue(p_port->tx.queue, p_buf); in port_write()
826 p_port->tx.queue_size += p_buf->len; in port_write()
894 p_buf = (BT_HDR*)fixed_queue_try_peek_last(p_port->tx.queue); in PORT_WriteDataCO()
914 p_port->tx.queue_size += (uint16_t)available; in PORT_WriteDataCO()
932 if ((p_port->tx.queue_size > PORT_TX_HIGH_WM) || in PORT_WriteDataCO()
[all …]
|
| /packages/modules/Bluetooth/system/rust/tests/ |
| D | gatt_server_test.rs | 197 let tx = if let MockDatastoreEvents::Read( in test_characteristic_read() localVariable
201 tx, in test_characteristic_read()
204 tx in test_characteristic_read()
208 tx.send(Ok(DATA.to_vec())).unwrap(); in test_characteristic_read()
241 let (tx, written_data) = if let MockDatastoreEvents::Write( in test_characteristic_write()
246 tx, in test_characteristic_write()
249 (tx, written_data) in test_characteristic_write()
253 tx.send(Ok(())).unwrap(); in test_characteristic_write()
349 let (tx, written_data) = if let MockDatastoreEvents::Write( in test_write_to_descriptor()
354 tx, in test_write_to_descriptor()
[all …]
|
| /packages/apps/Launcher3/quickstep/src/com/android/quickstep/util/ |
| D | SwipePipToHomeAnimator.java | 189 final SurfaceControl.Transaction tx = new SurfaceControl.Transaction(); in SwipePipToHomeAnimator() local
190 mPipContentOverlay.attach(tx, mLeash); in SwipePipToHomeAnimator()
230 final SurfaceControl.Transaction tx = in onAnimationUpdate()
233 onAnimationUpdate(tx, mCurrentBoundsF, progress); in onAnimationUpdate()
234 tx.apply(); in onAnimationUpdate()
237 private PictureInPictureSurfaceTransaction onAnimationUpdate(SurfaceControl.Transaction tx, in onAnimationUpdate() argument
241 mPipContentOverlay.onAnimationUpdate(tx, mCurrentBounds, progress); in onAnimationUpdate()
243 return onAnimationScaleAndCrop(progress, tx, mCurrentBounds); in onAnimationUpdate()
248 float progress, SurfaceControl.Transaction tx, in onAnimationScaleAndCrop() argument
254 return mSurfaceTransactionHelper.scaleAndRotate(tx, mLeash, mAppBounds, bounds, insets, in onAnimationScaleAndCrop()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/linux/mgmt/src/ |
| D | powerd_suspend_manager.rs | 196 tx: tokio::sync::mpsc::Sender<SuspendManagerMessage>, field
206 let (tx, rx) = tokio::sync::mpsc::channel::<SuspendManagerMessage>(10); in new()
216 tx, in new()
229 let tx1 = self.tx.clone(); in init()
230 let tx2 = self.tx.clone(); in init()
251 let tx1 = self.tx.clone(); in init()
252 let tx2 = self.tx.clone(); in init()
275 let tx1 = self.tx.clone(); in init()
276 let tx2 = self.tx.clone(); in init()
301 let tx = self.tx.clone(); in init() localVariable
[all …]
|
| /packages/modules/Bluetooth/tools/rootcanal/model/controller/ |
| D | sco_connection.cc | 103 for (auto tx : accepted_packets) { in GetLinkParameters() local
104 if (tx.length == 0) { in GetLinkParameters()
108 unsigned tx_max_interval = (1600 * tx.length) / transmit_bandwidth; in GetLinkParameters()
115 INFO("Testing combination {}/{} : {}/{}", tx.length, tx.slots, rx.length, in GetLinkParameters()
135 ? rx.slots + tx.slots in GetLinkParameters()
138 ? 2 * (rx.slots + tx.slots) in GetLinkParameters()
145 tx.slots + rx.slots + retransmission_window; in GetLinkParameters()
|
| /packages/services/Car/tests/NetworkPreferenceApp/src/com/google/android/car/networking/preferenceupdater/components/ |
| D | MetricDisplay.java | 138 long tx = 0; in calculateTraffic() local
144 tx += displayBucket.getTxBytes(); in calculateTraffic()
146 return new Pair(rx, tx); in calculateTraffic()
163 long tx = 0; in combinedTrafficFor() local
168 tx += traffic.second; in combinedTrafficFor()
171 return new Pair(rx, tx); in combinedTrafficFor()
|
| /packages/modules/Uwb/service/java/com/android/server/uwb/correction/math/ |
| D | Matrix.java | 174 float tx = 2 * q.x; in makeRotation() local
178 float mdsqx = 1 - tx * q.x; in makeRotation()
183 float dqxz = tx * q.z; in makeRotation()
184 float dqxw = tx * q.w; in makeRotation()
230 float tx = 2 * q.x; in makeTrs() local
234 float mdsqx = 1 - tx * q.x; in makeTrs()
239 float dqxz = tx * q.z; in makeTrs()
240 float dqxw = tx * q.w; in makeTrs()
|
| /packages/modules/Bluetooth/system/rust/src/ |
| D | lib.rs | 81 let (tx, mut rx) = mpsc::unbounded_channel(); in start()
82 let prev_registry = GLOBAL_MODULE_REGISTRY.lock().unwrap().replace(Self { task_tx: tx }); in start()
162 let ret = MAIN_THREAD_TX.with(|tx| tx.send(MainThreadTxMessage::Callback(Box::new(f)))); in do_in_rust_thread()
|
| /packages/apps/Car/SystemUI/src/com/android/systemui/car/input/ |
| D | DisplayInputSink.java | 83 SurfaceControl.Transaction tx = new SurfaceControl.Transaction(); in createSurface() local
84 tx.setLayer(surfaceControl, INPUT_LOCK_LAYER) in createSurface()
99 SurfaceControl.Transaction tx = new SurfaceControl.Transaction(); in release() local
100 tx.remove(mSurfaceControl).apply(); in release()
|