Searched refs:SplitReadHalf (Results 1 – 6 of 6) sorted by relevance
| /developtools/hdc/hdc_rust/src/transfer/ |
| D | tcp.rs | 26 use ylong_runtime::net::SplitReadHalf;
28 async fn read_frame(rd: &mut SplitReadHalf, expected_size: usize) -> io::Result<Vec<u8>> { in read_frame() argument
54 pub async fn unpack_task_message(rd: &mut SplitReadHalf) -> io::Result<TaskMessage> { in unpack_task_message()
87 pub async fn recv_channel_message(rd: &mut SplitReadHalf) -> io::Result<Vec<u8>> { in recv_channel_message()
|
| D | buffer.rs | 34 use ylong_runtime::net::{SplitReadHalf, SplitWriteHalf};
234 type TcpRecver_ = Arc<Mutex<SplitReadHalf>>;
248 pub async fn start(rd: SplitReadHalf) { in start() argument
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | auth.rs | 30 use ylong_runtime::net::SplitReadHalf;
36 rd: &mut SplitReadHalf, in handshake_with_daemon() argument
|
| D | server.rs | 29 use ylong_runtime::net::{SplitReadHalf, SplitWriteHalf, TcpListener, TcpStream};
186 rd: &mut SplitReadHalf, in handshake_with_client() argument
|
| D | task.rs | 28 use ylong_runtime::net::SplitReadHalf;
345 mut rd: SplitReadHalf, in tcp_handle_deamon() argument
|
| /developtools/hdc/hdc_rust/src/common/ |
| D | forward.rs | 38 use ylong_runtime::net::{SplitReadHalf, SplitWriteHalf, TcpListener, TcpStream};
46 type TcpRead = Arc<Mutex<SplitReadHalf>>;
59 async fn put(id: u32, rd: SplitReadHalf) { in put() argument
367 pub async fn recv_tcp_msg(session_id: u32, channel_id: u32, mut rd: SplitReadHalf, cid: u32) { in recv_tcp_msg() argument
|