Searched refs:wr (Results 1 - 12 of 12) sorted by relevance
| /developtools/hdc/hdc_rust/src/daemon_lib/ |
| H A D | bridge.rs | 156 let wr = arc_wr.lock().await;
157 let _ = wr.write_all(send);
176 let wr = guard.lock().await;
177 let _ = wr.write_all(send);
183 pub async fn start(id: u32, wr: BridgeWriter) {
186 let arc_wr = Arc::new(Mutex::new(wr));
|
| H A D | mod.rs | 133 let wr = bridge::BridgeWriter { ptr, fd };
137 bridge::BridgeMap::start(session_id, wr).await;
167 let (mut rd, wr) = stream.into_split();
174 transfer::TcpMap::start(session_id, wr).await;
242 let wr = transfer::uart::UartWriter { fd };
243 transfer::start_uart(session_id, wr).await;
386 let wr = transfer::usb::UsbWriter { fd: bulkout_fd };
387 transfer::UsbMap::start(session_id_in_msg, wr).await;
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| H A D | buffer.rs | 137 let mut wr = arc_wr.lock().await; variables
138 let _ = wr.write_all(send.as_slice()).await;
157 let mut wr = guard.lock().await; variables
158 let _ = wr.write_all(send.as_slice()).await;
164 pub async fn start(id: u32, wr: SplitWriteHalf) {
167 let arc_wr = Arc::new(Mutex::new(wr));
177 let mut wr = arc_wr.lock().await; variables
178 let _ = wr.shutdown().await;
255 pub async fn start(session_id: u32, wr: UsbWriter) {
263 map.insert(session_id, wr);
[all...] |
| H A D | uart_wrapper.rs | 513 pub async fn start_uart(session_id: u32, wr: UartWriter) {
514 UartMap::start(session_id, wr).await;
|
| /developtools/hdc/hdc_rust/src/common/ |
| H A D | forward.rs | 205 async fn put(id: u32, wr: SplitWriteHalf) {
208 let arc_wr = Arc::new(Mutex::new(wr));
219 let mut wr = arc_wr.lock().await; variables
220 let write_result = wr.write_all(data.as_slice()).await;
231 let mut wr = arc_wr.lock().await; variables
232 let _ = wr.shutdown().await;
673 let (rd, wr) = stream.into_split();
679 TcpWriteStreamMap::put(client_context.id, wr).await;
738 let (rd, wr) = stream.into_split();
739 TcpWriteStreamMap::put(ctx.id, wr)
[all...] |
| /developtools/hdc/hdc_rust/src/host/ |
| H A D | server.rs | 246 let (mut rd, wr) = stream.into_split();
247 let (connect_key, channel_id) = handshake_with_client(&mut rd, wr).await?;
322 wr: SplitWriteHalf,
325 transfer::TcpMap::start(channel_id, wr).await;
|
| H A D | client.rs | 54 wr: SplitWriteHalf,
103 let (rd, wr) = stream.into_split();
111 wr,
179 let _ = self.wr.write_all(msg.as_slice()).await;
|
| H A D | task.rs | 487 let wr = host_usb::HostUsbWriter {
491 host_usb::HostUsbMap::start(session_id, wr).await;
513 let (rd, wr) = stream.into_split();
514 transfer::TcpMap::start(session_id, wr).await;
|
| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/disk_io_parser/ |
| H A D | pbreader_disk_io_parser.cpp | 72 row.wr = itor->wrSectorsKb; in Finish()
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/trace_stdtype/htrace/ |
| H A D | activity_monitor_stdtype.h | 35 uint64_t wr = INVALID_UINT64; member
|
| H A D | activity_monitor_stdtype.cpp | 40 wrDatas_.emplace_back(diskioRow.wr); in AppendNewData()
|
| /developtools/smartperf_host/trace_streamer/test/unittest/table/ |
| H A D | table_test.cpp | 357 row.wr = 5; in HWTEST_F()
|
Completed in 12 milliseconds