| /packages/modules/Bluetooth/system/rust/src/gatt/server/ |
| D | att_server_bearer.rs | 276 let (tx, rx) = unbounded_channel(); in open_connection()
282 (conn, rx) in open_connection()
288 let (conn, mut rx) = open_connection(); in test_single_transaction()
295 assert_eq!(rx.recv().await.unwrap().opcode, AttOpcode::READ_RESPONSE); in test_single_transaction()
296 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in test_single_transaction()
303 let (conn, mut rx) = open_connection(); in test_sequential_transactions()
310 assert_eq!(rx.recv().await.unwrap().opcode, AttOpcode::ERROR_RESPONSE); in test_sequential_transactions()
311 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in test_sequential_transactions()
319 assert_eq!(rx.recv().await.unwrap().opcode, AttOpcode::READ_RESPONSE); in test_sequential_transactions()
320 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in test_sequential_transactions()
[all …]
|
| 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()
186 let AttChild::AttHandleValueIndication(indication) = rx.await.unwrap() else { in test_indication_sent()
239 let (tx, rx) = oneshot::channel(); in test_confirmation_handled()
251 rx.await.unwrap(); in test_confirmation_handled()
265 let (tx, rx) = oneshot::channel(); in test_unblock_on_disconnect()
278 rx.await.unwrap(); in test_unblock_on_disconnect()
295 let (tx, rx) = oneshot::channel(); in test_spurious_confirmations()
310 rx.await.unwrap(); in test_spurious_confirmations()
[all …]
|
| D | gatt_database.rs | 1285 let (callbacks, mut rx) = MockCallbacks::new(); in test_connection_listener()
1293 let event = rx.blocking_recv().unwrap(); in test_connection_listener()
1301 let (callbacks, mut rx) = MockCallbacks::new(); in test_disconnection_listener()
1308 let event = rx.blocking_recv().unwrap(); in test_disconnection_listener()
1335 let (callbacks, mut rx) = MockCallbacks::new(); in test_add_service_changed_listener()
1357 let event = rx.blocking_recv().unwrap(); in test_add_service_changed_listener()
1369 let (callbacks, mut rx) = MockCallbacks::new(); in test_partial_remove_service_changed_listener()
1408 let event = rx.blocking_recv().unwrap(); in test_partial_remove_service_changed_listener()
1420 let (callbacks, mut rx) = MockCallbacks::new(); in test_full_remove_service_changed_listener()
1443 let event = rx.blocking_recv().unwrap(); in test_full_remove_service_changed_listener()
[all …]
|
| /packages/modules/Bluetooth/system/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()
209 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue)) != in port_release_port()
213 p_port->rx.queue_size = 0; in port_release_port()
239 fixed_queue_free(p_port->rx.queue, nullptr); in port_release_port()
240 p_port->rx.queue = nullptr; in port_release_port()
468 if ((p_port->credit_rx <= p_port->credit_rx_low) && !p_port->rx.user_fc && in port_flow_control_peer()
475 p_port->rx.peer_fc = false; in port_flow_control_peer()
482 p_port->rx.peer_fc = true; in port_flow_control_peer()
485 else if (fixed_queue_length(p_port->rx.queue) >= p_port->credit_rx_max) { in port_flow_control_peer()
[all …]
|
| D | port_api.cc | 645 p_port->rx.user_fc = !enable; in PORT_FlowControl_MaxCredit()
648 if (!p_port->rx.user_fc) { in PORT_FlowControl_MaxCredit()
655 p_port->local_ctrl.fc = (p_port->rx.user_fc | p_port->rx.peer_fc); in PORT_FlowControl_MaxCredit()
662 if (enable && (p_port->rx.queue_size != 0)) { in PORT_FlowControl_MaxCredit()
718 if (fixed_queue_is_empty(p_port->rx.queue)) { in PORT_ReadData()
726 p_buf = (BT_HDR*)fixed_queue_try_peek_first(p_port->rx.queue); in PORT_ReadData()
738 p_port->rx.queue_size -= max_len; in PORT_ReadData()
751 p_port->rx.queue_size -= p_buf->len; in PORT_ReadData()
757 osi_free(fixed_queue_try_dequeue(p_port->rx.queue)); in PORT_ReadData()
767 p_port->rx.queue_size, *p_len, p_data[0]); in PORT_ReadData()
[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()
213 .rx = in LogDataTransfer()
215 .bytes = l2c.rx.bytes_, in LogDataTransfer()
225 if ((rfc.rx.bytes_ != 0) || (rfc.tx.bytes_ != 0)) { in LogDataTransfer()
227 .rx = in LogDataTransfer()
[all …]
|
| /packages/modules/Bluetooth/system/rust/src/gatt/ |
| D | callbacks.rs | 229 let (datastore, mut rx) = MockDatastore::new(); in test_regular_read_invoke()
242 let resp = rx.recv().await.unwrap(); in test_regular_read_invoke()
256 let (datastore, mut rx) = MockDatastore::new(); in test_regular_read_response()
269 let resp = rx.recv().await.unwrap(); in test_regular_read_response()
283 let (datastore, mut rx) = MockDatastore::new(); in test_rejected_read_blob()
297 assert_eq!(rx.try_recv().unwrap_err(), TryRecvError::Empty); in test_rejected_read_blob()
304 let (datastore, mut rx) = MockDatastore::new(); in test_write_request_invoke()
318 let resp = rx.recv().await.unwrap(); in test_write_request_invoke()
338 let (datastore, mut rx) = MockDatastore::new(); in test_write_request_response()
352 let resp = rx.recv().await.unwrap(); in test_write_request_response()
[all …]
|
| /packages/services/Car/tests/CarTelemetryApp/res/raw/ |
| D | conn_sessions.lua | 33 rx = {}
41 if rx[ps] == nil then
42 rx[ps] = 0
46 rx[ps] = rx[ps] + published_data['conn.rxBytes'][i]
51 for p, v in pairs(rx) do
52 res[p] = 'rx: ' .. rx[p] .. ', tx: ' .. tx[p] .. ', uid: ' .. uids[p]
|
| /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()
69 let resp = rx.await.unwrap(); in read()
82 let (tx, rx) = oneshot::channel(); in write()
93 rx.await.unwrap() in write()
118 let (tx, rx) = oneshot::channel(); in execute()
120 rx.await.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()
61 let resp = rx.await.unwrap(); in read()
73 let (tx, rx) = oneshot::channel(); in write()
77 rx.await.unwrap() in write()
|
| D | mock_transport.rs | 16 let (tx, rx) = unbounded_channel(); in new()
17 (Self(tx), rx) in new()
|
| D | mock_database_callbacks.rs | 23 let (tx, rx) = unbounded_channel(); in new()
24 (Self(tx), rx) in new()
|
| D | mock_callbacks.rs | 18 let (tx, rx) = unbounded_channel(); in new()
19 (Self(tx), rx) in new()
|
| /packages/apps/Gallery2/src/com/android/gallery3d/filtershow/imageshow/ |
| D | EclipseControl.java | 179 float rx = oval.getRadiusX(); in actionMove() local
181 float r = (Math.abs(rx) + Math.abs(ry)) * sin45; in actionMove()
185 oval.setRadius((rx * nr / r), (ry * nr / r)); in actionMove()
225 void paintRadius(Canvas canvas, float cx, float cy, float rx, float ry) { in paintRadius() argument
231 RectF rect = new RectF(cx - rx, cy - ry, cx + rx, cy + ry); in paintRadius()
236 paintOvallines(canvas, rect, paint, cx, cy, rx, ry); in paintRadius()
240 paintOvallines(canvas, rect, paint, cx, cy, rx, ry); in paintRadius()
244 Canvas canvas, RectF rect, Paint paint, float cx, float cy, float rx, float ry) { in paintOvallines() argument
252 float dx = rx + 10; in paintOvallines()
259 dx = rx - 10; in paintOvallines()
[all …]
|
| /packages/modules/Bluetooth/tools/rootcanal/model/controller/ |
| D | sco_connection.cc | 110 for (auto rx : accepted_packets) { in GetLinkParameters() local
111 if (rx.length == 0) { in GetLinkParameters()
115 INFO("Testing combination {}/{} : {}/{}", tx.length, tx.slots, rx.length, in GetLinkParameters()
116 rx.slots); in GetLinkParameters()
118 unsigned rx_max_interval = (1600 * rx.length) / receive_bandwidth; 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 | 137 long rx = 0; in calculateTraffic() local
143 rx += displayBucket.getRxBytes(); in calculateTraffic()
146 return new Pair(rx, tx); in calculateTraffic()
162 long rx = 0; in combinedTrafficFor() local
167 rx += traffic.first; in combinedTrafficFor()
171 return new Pair(rx, tx); in combinedTrafficFor()
|
| /packages/modules/Uwb/service/java/com/android/server/uwb/correction/math/ |
| D | Quaternion.java | 237 float rx = y * vz - z * vy + w * vx; in rotateVector() local
241 float sy = z * rx - x * rz; in rotateVector()
242 float sz = x * ry - y * rx; in rotateVector()
256 float rx = rhs.x; in multiply() local
262 lw * rx + lx * rw + ly * rz - lz * ry, in multiply()
263 lw * ry - lx * rz + ly * rw + lz * rx, in multiply()
264 lw * rz + lx * ry - ly * rx + lz * rw, in multiply()
265 lw * rw - lx * rx - ly * ry - lz * rz); in multiply()
|
| /packages/modules/Bluetooth/system/rust/src/gatt/callbacks/ |
| D | callback_transaction_manager.rs | 28 rx: oneshot::Receiver<Result<Vec<u8>, AttErrorCode>>, field
105 let (tx, rx) = oneshot::channel(); in start_new_transaction()
107 PendingTransactionWatcher { conn_id, trans_id, rx } in start_new_transaction()
115 if let Ok(Ok(result)) = timeout(TIMEOUT, self.rx).await { in wait()
|
| /packages/services/Car/tests/NetworkPreferenceApp/src/com/google/android/car/networking/preferenceupdater/fragments/ |
| D | ManagerFragment.java | 87 long rx = bundle.getLong(METRIC_MSG_OEM_PREFERENCE_RX_KEY);
89 updateMetricIndicatorByType(oem_preference, rx, tx);
176 private void updateMetricIndicatorByType(int type, long rx, long tx) { in updateMetricIndicatorByType() argument
179 mOemPaidRxBytesTextView.setText("RX: " + rx); in updateMetricIndicatorByType()
183 mOemPrivateRxBytesTextView.setText("RX: " + rx); in updateMetricIndicatorByType()
187 mOemTotalRxBytesTextView.setText("RX: " + rx); in updateMetricIndicatorByType()
|
| /packages/modules/Bluetooth/system/osi/test/ |
| D | stack_power_telemetry_test.cc | 228 ASSERT_EQ(1, (int)power_telemetry::GetInstance().pimpl_->rx.pkt_); in TEST_F()
229 ASSERT_EQ(11, (int)power_telemetry::GetInstance().pimpl_->rx.len_); in TEST_F()
277 ASSERT_EQ(10, (int)power_telemetry::GetInstance().pimpl_->rfc.rx.bytes_); in TEST_F()
280 ASSERT_EQ(11, (int)power_telemetry::GetInstance().pimpl_->l2c.rx.bytes_); in TEST_F()
305 ASSERT_EQ(0, (int)power_telemetry::GetInstance().pimpl_->rfc.rx.bytes_); in TEST_F()
320 ASSERT_EQ(0, (int)power_telemetry::GetInstance().pimpl_->rx.pkt_); in TEST_F()
|
| /packages/services/Car/tools/emulator/ |
| D | gui.py | 138 rx = Thread(target=rxThread, args=(vhal,)) variable
139 rx.setDaemon(True)
140 rx.start()
|
| /packages/modules/Connectivity/staticlibs/netd/libnetdutils/ |
| D | NetlinkListener.cpp | 135 auto rx = sys.recvfrom(mSock, makeSlice(rxbuf), 0); in run() local
136 int err = rx.status().code(); in run()
145 forEachNetlinkMessage(rx.value(), rxHandler); in run()
|
| /packages/modules/Bluetooth/framework/java/android/bluetooth/ |
| D | UidTraffic.java | 35 public UidTraffic(int appUid, long rx, long tx) { in UidTraffic() argument
37 mRxBytes = rx; in UidTraffic()
|
| /packages/modules/Bluetooth/system/gd/rust/linux/stack/src/ |
| D | async_helper.rs | 39 let (tx, rx) = oneshot::channel(); in call_method()
70 rx.await.map_err(|_| ()) in call_method()
|
| /packages/modules/Bluetooth/system/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()
|