| /developtools/hdc/hdc_rust/src/transfer/ |
| D | buffer.rs | 82 let mut wr = arc_wr.lock().await; in put() localVariable
83 let _ = wr.write_all(send.as_slice()).await; in put()
96 let mut wr = guard.lock().await; in send_channel_message() localVariable
97 let _ = wr.write_all(send.as_slice()).await; in send_channel_message()
103 pub async fn start(id: u32, wr: SplitWriteHalf) { in start()
106 let arc_wr = Arc::new(Mutex::new(wr)); in start()
115 let mut wr = arc_wr.lock().await; in end() localVariable
116 let _ = wr.shutdown().await; in end()
144 let mut wr = arc_wr.lock().await; in put() localVariable
145 wr.write_all(head)?; in put()
[all …]
|
| D | uart_wrapper.rs | 494 pub async fn start_uart(session_id: u32, wr: UartWriter) { in start_uart()
495 UartMap::start(session_id, wr).await; in start_uart()
|
| /developtools/hdc/hdc_rust/src/daemon/ |
| D | main.rs | 81 let (mut rd, wr) = stream.into_split(); in tcp_handle_client()
87 transfer::TcpMap::start(session_id, wr).await; in tcp_handle_client()
138 let wr = transfer::uart::UartWriter { fd }; in uart_handshake() localVariable
139 transfer::start_uart(session_id, wr).await; in uart_handshake()
259 let wr = transfer::usb::UsbWriter { fd: bulkout_fd }; in usb_handle_client() localVariable
273 transfer::UsbMap::start(session_id, wr).await; in usb_handle_client()
297 let wr = transfer::usb::UsbWriter { fd: bulkout_fd }; in usb_handle_client() localVariable
298 transfer::UsbMap::start(new_session_id, wr).await; in usb_handle_client()
|
| /developtools/profiler/device/plugins/memory_plugin/test/utresources/proc/2/ |
| D | smaps | 69 VmFlags: rd wr mr mw me dw ac sd
92 VmFlags: rd wr mr mw me ac sd
184 VmFlags: rd wr mr mw me ac sd
207 VmFlags: rd wr mr mw me ac sd
253 VmFlags: rd wr mr mw me ac sd
299 VmFlags: rd wr mr mw me dw ac sd
322 VmFlags: rd wr mr mw me ac sd
345 VmFlags: rd wr mr mw me gd ac
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | server.rs | 116 let (mut rd, wr) = stream.into_split(); in handle_client()
117 let (connect_key, channel_id) = handshake_with_client(&mut rd, wr).await?; in handle_client()
187 wr: SplitWriteHalf, in handshake_with_client()
190 transfer::TcpMap::start(channel_id, wr).await; in handshake_with_client()
|
| D | client.rs | 43 wr: SplitWriteHalf, field
91 let (rd, wr) = stream.into_split(); in new()
99 wr, in new()
151 let _ = self.wr.write_all(msg.as_slice()).await; in send()
|
| D | task.rs | 284 let (mut rd, wr) = stream.into_split(); in channel_connect_task()
285 transfer::TcpMap::start(session_id, wr).await; in channel_connect_task()
|
| /developtools/profiler/device/plugins/memory_plugin/test/utresources/proc/11/ |
| D | smaps | 69 VmFlags: rd wr mr mw me dw ac sd
92 VmFlags: rd wr mr mw me ac sd
184 VmFlags: rd wr mr mw me ac sd
276 VmFlags: rd wr mr mw me ac sd
368 VmFlags: rd wr mr mw me ac sd
391 VmFlags: rd wr mr mw me ac sd
483 VmFlags: rd wr mr mw me ac sd
506 VmFlags: rd wr mr mw me ac sd
552 VmFlags: rd wr mr mw me ac sd
598 VmFlags: rd wr mr mw me dw ac sd
[all …]
|
| /developtools/profiler/device/plugins/memory_plugin/test/utresources/proc/1/ |
| D | smaps | 24 VmFlags: rd wr mr mw me ac
116 VmFlags: rd wr mr mw me dw ac
140 VmFlags: rd wr mr mw me ac
164 VmFlags: rd wr mr mw me ac
188 VmFlags: rd wr mr mw me ac
212 VmFlags: rd wr mr mw me ac
236 VmFlags: rd wr mr mw me ac
260 VmFlags: rd wr mr mw me ac
284 VmFlags: rd wr mr mw me ac
354 VmFlags: rd wr mr mw me ac
[all …]
|
| /developtools/hdc/hdc_rust/src/common/ |
| D | forward.rs | 117 async fn put(id: u32, wr: SplitWriteHalf) { in put()
120 let arc_wr = Arc::new(Mutex::new(wr)); in put()
131 let mut wr = arc_wr.lock().await; in write() localVariable
132 let _ = wr.write_all(data.as_slice()).await; in write()
139 let mut wr = arc_wr.lock().await; in end() localVariable
140 let _ = wr.shutdown().await; in end()
360 let (rd, wr) = stream.into_split(); in forward_tcp_accept()
361 TcpWriteStreamMap::put(cid, wr).await; in forward_tcp_accept()
428 let (rd, wr) = stream.into_split(); in daemon_connect_tcp()
429 TcpWriteStreamMap::put(cid, wr).await; in daemon_connect_tcp()
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/trace_stdtype/htrace/ |
| D | activity_monitor_stdtype.cpp | 38 uint64_t wr, in AppendNewData() argument
49 wrDatas_.emplace_back(wr); in AppendNewData()
|
| D | activity_monitor_stdtype.h | 39 uint64_t wr,
|
| /developtools/smartperf_host/trace_streamer/test/unittest/table/ |
| D | table_test.cpp | 349 uint64_t wr = 5; variable
357 …stream_.traceDataCache_->GetDiskIOData()->AppendNewData(ts, dur, rd, wr, rdPerSec, wrPerSec, rdCou…
|
| /developtools/smartperf_host/ide/src/doc/md/ |
| D | des_tables.md | 553 | wr | INT |
|
| /developtools/smartperf_host/trace_streamer/doc/ |
| D | des_tables.md | 463 |wr |INT |
|
| /developtools/ace_ets2bundle/compiler/codegen/ |
| D | codegen_ets.js | 15 …wr=Ua(Pr),Rr=Ua(br),xr=Ua(_r),Ir=Ua(Nr),Lr=Ua(Cr),Fr=Ge?Ge.prototype:n,Br=Fr?Fr.valueOf:n,kr=Fr?Fr…
|