| /developtools/profiler/device/plugins/network_plugin/include/ |
| H A D | network_plugin.h | 42 uint64_t rx; member
49 uint64_t rx; member
|
| /developtools/profiler/device/plugins/network_plugin/test/unittest/ |
| H A D | network_plugin_test.cpp | 33 uint64_t rx; member
41 uint64_t rx; member
158 EXPECT_EQ(g_expectBegin.rx, networkData.mutable_networkinfo(i)->rx_bytes()); in HWTEST_F()
186 EXPECT_EQ(g_expectEnd.rx, networkData.mutable_networkinfo(i)->rx_bytes()); in HWTEST_F()
192 EXPECT_EQ(g_expectEnd.details[j].rx, networkData.mutable_networkinfo(i)->mutable_details(j)->rx_bytes()); in HWTEST_F()
|
| /developtools/hdc/hdc_rust/src/daemon_lib/ |
| H A D | mod.rs | 273 let (tx, mut rx) = mpsc::bounded_channel::<TaskMessage>(config::USB_QUEUE_LEN);
283 match rx.recv().await {
285 let _ = rx.recv().await;
316 let (tx, mut rx) = mpsc::bounded_channel::<TaskMessage>(config::USB_QUEUE_LEN);
327 match rx.recv().await {
376 let mut rx = transfer::usb_start_recv(bulkin_fd, 0); variables
379 match rx.recv().await {
|
| H A D | shell.rs | 170 mut rx: mpsc::BoundedReceiver<Vec<u8>>,
208 recv_res = rx.recv() => {
248 crate::debug!("rx recv failed: {e:?}");
320 let (tx, rx) = ylong_runtime::sync::mpsc::bounded_channel::<Vec<u8>>(16); in new()
328 rx, in new()
552 async fn watch_pipe_states(rx: &mut mpsc::BoundedReceiver<Vec<u8>>, child_in: &mut ChildStdin) -> io::Result<()> {
553 match rx.try_recv() {
602 mut rx: mpsc::BoundedReceiver<Vec<u8>>,
705 if (watch_pipe_states(&mut rx, &mut child_in).await).is_err() {
745 let (tx, rx) in new()
[all...] |
| /developtools/profiler/device/plugins/network_plugin/src/ |
| H A D | network_plugin.cpp | 82 data->set_rx_bytes(it.rx); in WriteNetWorkData()
87 info->set_rx_bytes(dataCell.rx); in WriteNetWorkData()
250 cache.rx = rxBytes; in ReadTxRxBytes()
251 cell.rx += rxBytes; in ReadTxRxBytes()
275 it->rx += data.rx; in AddNetDetails()
|
| /developtools/hdc/hdc_rust/src/host_transfer/ |
| H A D | host_usb.rs | 269 let (tx, rx) = mpsc::bounded_channel::<(TaskMessage, u32)>(config::USB_QUEUE_LEN); in start_recv()
279 rx in start_recv()
287 let (tx, rx) = mpsc::bounded_channel::<(TaskMessage, u32)>(config::USB_QUEUE_LEN); in start_recv_once()
294 rx in start_recv_once()
|
| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/network_parser/ |
| H A D | pbreader_network_parser.cpp | 75 row.rx = itor->rx_bytes; in Finish()
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| H A D | buffer.rs | 439 let (tx, rx) = mpsc::bounded_channel::<(TaskMessage, u32, u32)>(config::USB_QUEUE_LEN); in usb_start_recv()
449 rx in usb_start_recv()
|
| /developtools/ace_js2bundle/ace-loader/plugin/templater/ |
| H A D | rich_component_map.js | 535 rx: {},
591 rx: {},
|
| /developtools/hdc/hdc_rust/src/host/ |
| H A D | task.rs | 462 pub async fn usb_handle_deamon(ptr: u64, mut rx: mpsc::BoundedReceiver<(TaskMessage, u32)>, session_id: u32, connect_key: String) -> io::Result<()> {
464 match rx.recv().await {
492 let rx = host_usb::start_recv(ptr, connect_key.clone(), session_id);
496 let _ = ylong_runtime::spawn(usb_handle_deamon(ptr, rx, session_id, connect_key)).await;
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/trace_stdtype/htrace/ |
| H A D | activity_monitor_stdtype.h | 145 uint64_t rx = INVALID_UINT64; member
|
| H A D | activity_monitor_stdtype.cpp | 224 rxs_.emplace_back(netDetailRow.rx); in AppendNewNetData()
|
| /developtools/smartperf_host/trace_streamer/test/unittest/table/ |
| H A D | table_test.cpp | 830 row.rx = 1; in HWTEST_F()
|
| /developtools/profiler/hiebpf/include/ |
| H A D | vmlinux.h | 17202 int rx; member
68276 __u32 rx; global() member
105945 } rx; global() member
105967 } rx; global() member
108350 u8 rx[1024]; global() member
113884 struct mbox_chan___2 *rx; global() member
126198 void *rx; global() member
129713 struct fman_port_rx_bmi_regs rx; global() member
131043 struct xen_netif_rx_front_ring rx; global() member
131072 struct xen_netif_rx_response rx; global() member
140182 struct scmi_msg rx; global() member
141925 } rx; global() member
141963 } rx; global() member
142086 } rx; global() member
148003 struct xsk_queue *rx; global() member
148166 struct cipher_context rx; global() member
158404 u16 rx; global() member
159900 struct xdp_ring_offset rx; global() member
159965 struct xdp_ring_offset_v1 rx; global() member
[all...] |