Searched refs:read_buf (Results 1 - 9 of 9) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | uds_cargo_test.rs | 60 let mut read_buf = [0_u8; 12]; in sdv_uds_listener_read_write_test() variables
69 let mut read_buf = [0_u8; 12]; in sdv_uds_listener_read_write_test() variables
70 stream.read_exact(&mut read_buf).await.unwrap(); in sdv_uds_listener_read_write_test()
72 std::str::from_utf8(&read_buf).unwrap(), in sdv_uds_listener_read_write_test()
81 stream.read_exact(&mut read_buf).await.unwrap(); in sdv_uds_listener_read_write_test()
83 std::str::from_utf8(&read_buf).unwrap(), in sdv_uds_listener_read_write_test()
111 let mut read_buf = [0_u8; 12]; in sdv_uds_stream_test() variables
116 let n = stream.read(&mut read_buf).await.unwrap(); in sdv_uds_stream_test()
119 std::str::from_utf8(&read_buf).unwrap(), in sdv_uds_stream_test()
125 let mut read_buf in sdv_uds_stream_test() variables
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | http_body.rs | 140 let mut read_buf = [0_u8; TRAILER_SIZE]; in poll_trailer() variables
145 match chunk.data(cx, &mut read_buf) { in poll_trailer()
238 let mut read_buf = ReadBuf::new(&mut buf[read..]); in poll_read_io() variables
239 match Pin::new(&mut io).poll_read(cx, &mut read_buf) { in poll_read_io()
242 let filled = read_buf.filled().len(); in poll_read_io()
362 let mut read_buf = ReadBuf::new(&mut buf[read..]); in poll_read_io() variables
363 match Pin::new(&mut io).poll_read(cx, &mut read_buf) { in poll_read_io()
366 let filled = read_buf.filled().len(); in poll_read_io()
375 let (text, rem) = self.decoder.decode(read_buf.filled()); in poll_read_io()
376 self.interceptors.intercept_output(read_buf in poll_read_io()
468 let mut read_buf = ReadBuf::new(&mut buf[read..]); data() variables
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | mod.rs | 23 mod read_buf; modules
37 pub use read_buf::ReadBuf;
|
| H A D | read_task.rs | 26 use crate::io::read_buf::ReadBuf;
109 let mut read_buf = ReadBuf::uninit(unsafe { in poll_read_to_end() variables
112 read_buf.assume_init(len); in poll_read_to_end()
113 read_buf.set_filled(len); in poll_read_to_end()
115 let poll = Pin::new(&mut reader).poll_read(cx, &mut read_buf); in poll_read_to_end()
116 let new_len = read_buf.filled_len(); in poll_read_to_end()
|
| H A D | async_read.rs | 19 use crate::io::read_buf::ReadBuf;
|
| H A D | read_buf.rs | 273 let mut read_buf: ReadBuf<'_> = ReadBuf::new(&mut buf); in ut_test_readbuf_new() variables
275 assert_eq!(read_buf.filled().len(), 0); in ut_test_readbuf_new()
276 assert_eq!(read_buf.initialized_len(), 16); in ut_test_readbuf_new()
277 assert_eq!(read_buf.capacity(), 16); in ut_test_readbuf_new()
278 assert_eq!(read_buf.initialized().len(), 16); in ut_test_readbuf_new()
280 read_buf.set_filled(9); in ut_test_readbuf_new()
281 assert_eq!(read_buf.filled().len(), 9); in ut_test_readbuf_new()
284 let borrow = read_buf.filled_mut(); in ut_test_readbuf_new()
287 assert_eq!(read_buf.filled()[0], 1); in ut_test_readbuf_new()
290 let borrow = read_buf in ut_test_readbuf_new()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| H A D | simple.rs | 742 let mut read_buf = ReadBuf::new(&mut buf); variables
743 poll_fn(|cx| Pin::new(&mut mp).poll_read(cx, &mut read_buf))
747 let len = read_buf.filled_len();
793 let mut read_buf = ReadBuf::new(&mut buf); variables
794 poll_fn(|cx| Pin::new(&mut mp).poll_read(cx, &mut read_buf))
798 let len = read_buf.filled().len();
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | output.rs | 84 let mut read_buf = ReadBuf::new(&mut buf); variables
85 match Pin::new(&mut self.reader).poll_read(cx, &mut read_buf) {
94 let read = read_buf.filled().len();
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| H A D | chunk.rs | 200 let mut read_buf = ReadBuf::new(&mut self.chunk_data.chunk_buf); in poll_partial() variables
202 match Pin::new(&mut *self.from).poll_read(_cx, &mut read_buf) { in poll_partial()
204 let size = read_buf.filled().len(); in poll_partial()
|
Completed in 7 milliseconds