Searched refs:write_vectored (Results 1 - 11 of 11) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | split.rs | 217 /// UT test cases for `TcpStream` of split() and write_vectored(). in poll_flush()
243 write_half.write_vectored(&[slice1, slice2]).await.unwrap(); in poll_flush()
261 stream.write_vectored(&[slice1, slice2]).await.unwrap(); in poll_flush()
267 /// UT test cases for `TcpStream` of into_split() and write_vectored(). in poll_flush()
293 write_half.write_vectored(&[slice1, slice2]).await.unwrap(); in poll_flush()
311 stream.write_vectored(&[slice1, slice2]).await.unwrap(); in poll_flush()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | stream.rs | 235 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in read_vectored() functions
236 self.inner.write_vectored(bufs) in read_vectored()
262 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored() functions
264 inner.write_vectored(bufs)
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | stream.rs | 177 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in read_vectored() functions
178 self.inner.write_vectored(bufs) in read_vectored()
203 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored() functions
205 inner.write_vectored(bufs)
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | async_buf_write.rs | 59 /// SDV test cases for AsyncBufWriter `write_vectored`
64 /// `write_vectored` to send segmented data.
93 buf_writer.write_vectored(bufs).await.unwrap(); in sdv_buf_writer_write_vectored()
155 /// SDV test cases for AsyncBufWriter `write_vectored`
160 /// `write_vectored` to send segmented data.
189 buf_writer.write_vectored(bufs).await.unwrap(); in sdv_buf_writer_write_vectored_2()
|
| H A D | tcp_test.rs | 327 write_half.write_vectored(&[slice1, slice2]).await.unwrap(); in sdv_tcp_split_borrow_half()
397 write_half.write_vectored(&[slice1, slice2]).await.unwrap(); in sdv_tcp_split_owned_half()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | async_write.rs | 63 /// `write_vectored`. The default implementation is not.
182 /// `write_vectored`, 'write_all'. Every method in this trait returns a future in poll_flush()
228 /// let n = io.write_vectored(&[slice1, slice2]).await?; in poll_flush()
230 fn write_vectored<'a, 'b>( in poll_flush() functions
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| H A D | stream.rs | 285 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in fmt() functions
286 self.state.try_io(|mut inner| inner.write_vectored(bufs), &self.inner) in fmt()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
| H A D | pipe.rs | 45 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored() functions
46 (&self.fd).write_vectored(bufs) in write_vectored()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | tcp_test.rs | 90 /// SDV for TcpStream read_vectored and write_vectored
113 let mut ret = stream.write_vectored(&[slice]); in sdv_tcp_server_vectored()
|
| H A D | uds_test.rs | 61 let n = stream.write_vectored(&[slice]).unwrap(); in sdv_uds_stream_test()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | command.rs | 670 .write_vectored(&[IoSlice::new(b"Hello, world!")]) in ut_process_child_stdio_test()
|
Completed in 6 milliseconds