Home
last modified time | relevance | path

Searched refs:buf (Results 1 - 25 of 159) sorted by relevance

1234567

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/
H A Dasync_buf_writer.rs34 buf: Vec<u8>,
75 buf: Vec::with_capacity(cap), in with_capacity()
145 &self.buf in buffer()
170 self.buf.capacity() in capacity()
175 let len = this.buf.len();
180 Pin::new_unchecked(&mut this.inner).poll_write(cx, &this.buf[this.written..])
185 "unwritten data remains in buf",
198 this.buf.drain(..this.written);
209 buf: &[u8], in poll_write()
211 if self.buf in poll_write()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dread_buf.rs16 /// This buf comes from std::io::ReadBuf, an unstable std lib. This buffer is a
31 pub(crate) buf: &'a mut [MaybeUninit<u8>],
39 pub fn new(buf: &'a mut [u8]) -> ReadBuf<'a> { in new()
41 buf: unsafe { &mut *(buf as *mut [u8] as *mut [MaybeUninit<u8>]) }, in new()
43 initialized: buf.len(), in new()
50 buf: &'a mut [MaybeUninit<u8>], in create()
55 buf, in create()
63 pub fn uninit(buf: &mut [MaybeUninit<u8>]) -> ReadBuf<'_> { in uninit()
65 buf, in uninit()
271 let mut buf = [0; 16]; ut_test_readbuf_new() variables
[all...]
H A Dread_task.rs42 buf: &'a mut [u8],
47 pub(crate) fn new(reader: &'a mut R, buf: &'a mut [u8]) -> ReadTask<'a, R> {
50 buf,
64 let mut buf = ReadBuf::new(self.buf); variables
65 match Pin::new(&mut reader).poll_read(cx, &mut buf) {
67 Poll::Ready(_) => Poll::Ready(Ok(buf.filled_len())),
81 buf: &'a mut Vec<u8>,
87 pub(crate) fn new(reader: &'a mut R, buf: &'a mut Vec<u8>) -> ReadToEndTask<'a, R> {
90 buf,
507 let mut buf = String::new(); ut_io_string_result() variables
[all...]
H A Dasync_read.rs30 /// guaranteed that `n <= buf.len()`.
36 /// 2. The buf passed in is empty
44 buf: &mut ReadBuf<'_>, in poll_read()
53 buf: &mut ReadBuf<'_>, in poll_read()
55 Pin::new(&mut **self).poll_read(cx, buf) in poll_read()
64 buf: &mut ReadBuf<'_>, in poll_read()
66 Pin::new(&mut **self).poll_read(cx, buf) in poll_read()
79 buf: &mut ReadBuf<'_>, in poll_read()
81 self.get_mut().as_mut().poll_read(cx, buf) in poll_read()
95 /// guarantees `0 <= n < buf
[all...]
/commonlibrary/ets_utils/js_api_module/buffer/test/
H A Dtest_napi.cpp40 void FillZero(OHOS::buffer::Buffer *buf, size_t size) in FillZero() argument
43 buf->Set(i, 0); in FillZero()
55 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); in HWTEST_F() local
56 buf->Init(10); in HWTEST_F()
57 ASSERT_EQ(buf->GetLength(), 10); in HWTEST_F()
120 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); in HWTEST_F() local
121 buf->Init(1); in HWTEST_F()
122 ASSERT_EQ(buf->GetLength(), 1); in HWTEST_F()
123 uint32_t res = buf->Copy(nullptr, 0, 0, 0); in HWTEST_F()
125 int result = buf in HWTEST_F()
157 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
173 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
185 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
198 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
214 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
227 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
242 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
260 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
277 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
294 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
312 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
332 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
350 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
368 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
386 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
404 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
422 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
440 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
458 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
474 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
495 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
514 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
529 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
550 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
571 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
592 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
613 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
641 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
695 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
717 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
730 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
757 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
773 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
790 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
807 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
824 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
840 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
855 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
870 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
885 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
900 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
916 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
931 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
946 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
961 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
1038 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
1056 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
1080 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
1102 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
1122 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
1451 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
1467 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
1484 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
1501 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer(); HWTEST_F() local
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A Dtext.rs94 /// let mut buf = [0u8; 1024];
96 /// let size = body.data(&mut buf).unwrap();
114 /// let mut buf = [0u8; 1024];
116 /// let size = body.data(&mut buf).await.unwrap();
187 fn data(&mut self, buf: &mut [u8]) -> Result<usize, Self::Error> { in data()
188 Read::read(&mut *self.from, buf) in data()
198 buf: &mut [u8], in poll_data()
200 Poll::Ready(Read::read(&mut *self.from, buf)) in poll_data()
207 fn data(&mut self, buf: &mut [u8]) -> Result<usize, Self::Error> { in data()
208 self.from.read(buf) in data()
220 let mut buf = ReadBuf::new(buf); poll_data() variables
499 let mut buf = [0u8; 5]; ut_text_body_from_bytes_syn_data() variables
535 let mut buf = [0u8; 5]; global() variables
561 let mut buf = [0u8; 5]; ut_text_body_from_reader_syn_data() variables
598 let mut buf = [0u8; 5]; global() variables
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dtcp_test.rs26 /// 2. `TcpStream` connect to listener and try to read buf.
40 let mut buf = vec![0; 5]; in sdv_tcp_ipv6_connect() variables
41 let _ = stream.read(&mut buf).await; in sdv_tcp_ipv6_connect()
42 assert_eq!(buf, b"hello"); in sdv_tcp_ipv6_connect()
76 /// 2. After accept, try to write buf.
77 /// 2. `TcpStream` connect to listener and try to read buf.
91 let mut buf = vec![0; 5]; in sdv_tcp_stream_try() variables
93 stream.try_read(&mut buf).unwrap(); in sdv_tcp_stream_try()
94 assert_eq!(buf, b"hello"); in sdv_tcp_stream_try()
174 let mut buf in sdv_tcp_stream_peek() variables
223 let mut buf = [0_u8; 12]; sdv_tcp_global_runtime() variables
264 let mut buf = [0; 100]; sdv_tcp_multi_runtime() variables
270 let mut buf = [0; 100]; sdv_tcp_multi_runtime() variables
307 let mut buf = [0; 6]; sdv_tcp_split_borrow_half() variables
315 let mut buf = [0; 16]; sdv_tcp_split_borrow_half() variables
377 let mut buf = [0; 6]; sdv_tcp_split_owned_half() variables
386 let mut buf = [0; 16]; sdv_tcp_split_owned_half() variables
421 let mut buf = [0; 10]; sdv_tcp_drop_out_context() variables
440 let mut buf = [0; 10]; sdv_tcp_drop_out_context() variables
474 let mut buf = [0; 100]; sdv_tcp_cancel() variables
499 let mut buf = [0; 100]; sdv_tcp_cancel() variables
518 let mut buf = [0; 100]; sdv_tcp_cancel() variables
536 let mut buf = [0; 100]; sdv_tcp_cancel() variables
565 let mut buf = [0; 10]; sdv_tcp_unexpected_eof() variables
[all...]
H A Dasync_fs.rs33 let buf = "hello".as_bytes().to_vec(); in sdv_async_fs_write()
34 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_write()
42 let mut buf = [0; 5]; in sdv_async_fs_write() variables
43 let res = file.read(&mut buf).await.unwrap(); in sdv_async_fs_write()
45 assert_eq!(&buf, "hello".as_bytes()); in sdv_async_fs_write()
62 let buf = vec![1, 2, 3, 4, 5]; in sdv_async_fs_read()
63 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_read()
68 let mut buf = [0; 5]; in sdv_async_fs_read() variables
69 let res = file.read(&mut buf).await.unwrap(); in sdv_async_fs_read()
71 assert_eq!(buf, [ in sdv_async_fs_read()
77 let mut buf = [0; 5]; sdv_async_fs_read() variables
110 let mut buf = [0; 16384]; sdv_async_fs_rw() variables
127 let mut buf = [0; 3]; sdv_async_fs_rw() variables
134 let mut buf = [0; 2]; sdv_async_fs_rw() variables
138 let mut buf = Vec::new(); sdv_async_fs_rw() variables
203 let mut buf = [0; 1]; sdv_async_fs_seek() variables
211 let mut buf = [0; 1]; sdv_async_fs_seek() variables
219 let mut buf = [0; 2]; sdv_async_fs_seek() variables
226 let mut buf = [0; 9]; sdv_async_fs_seek() variables
233 let mut buf = [0; 2]; sdv_async_fs_seek() variables
363 let mut buf = [0; 11]; sdv_async_fs_open_options() variables
[all...]
H A Dasync_buf_write.rs27 /// 4. Check the read buf.
35 let mut buf = [0; 6]; in sdv_buf_writer_write() variables
36 let ret = stream.read(&mut buf).await.unwrap(); in sdv_buf_writer_write()
38 assert_eq!(buf, [1, 2, 3, 4, 5, 6]); in sdv_buf_writer_write()
48 let buf = [1, 2, 3, 4, 5, 6]; in sdv_buf_writer_write()
51 buf_writer.write(&buf).await.unwrap(); in sdv_buf_writer_write()
66 /// 4. Check the read buf.
74 let mut buf = [0; 17]; in sdv_buf_writer_write_vectored() variables
75 let ret = stream.read(&mut buf).await.unwrap(); in sdv_buf_writer_write_vectored()
77 assert_eq!(buf, "lore in sdv_buf_writer_write_vectored()
130 let mut buf = [0; 12]; sdv_buf_writer_seek() variables
138 let mut buf = [0; 5]; sdv_buf_writer_seek() variables
145 let mut buf = [0; 5]; sdv_buf_writer_seek() variables
170 let mut buf = [0; 17]; sdv_buf_writer_write_vectored_2() variables
[all...]
H A Dasync_buf_read.rs27 /// 5. Check the read buf.
29 /// 7. Check the read buf.
42 let mut buf = [0; 4]; in sdv_buf_reader_read_until() variables
43 let ret = buf_reader.read(&mut buf).await.unwrap(); in sdv_buf_reader_read_until()
45 assert_eq!(buf, [4, 5, 6, 0]); in sdv_buf_reader_read_until()
55 let buf = [1, 2, 3, b':', 4, 5, 6]; in sdv_buf_reader_read_until()
56 tcp.write_all(&buf).await.unwrap(); in sdv_buf_reader_read_until()
71 /// 5. Check the read buf.
73 /// 7. Check the read buf.
97 let buf in sdv_buf_reader_read_line()
225 let mut buf = [0; 6]; sdv_buf_reader_seek() variables
232 let mut buf = [0; 12]; sdv_buf_reader_seek() variables
239 let mut buf = [0; 5]; sdv_buf_reader_seek() variables
265 let mut buf = [0; 8193]; sdv_buf_reader_read() variables
[all...]
/commonlibrary/rust/ylong_http/ylong_http/tests/
H A Dsdv_http_body.rs62 let mut buf = [0_u8; 20]; in sdv_chunk_body_encode() variables
65 let mut size = buf.len(); in sdv_chunk_body_encode()
66 while size == buf.len() { in sdv_chunk_body_encode()
67 size = body.data(buf.as_mut_slice()).unwrap(); in sdv_chunk_body_encode()
68 output.extend_from_slice(&buf[..size]); in sdv_chunk_body_encode()
85 let mut buf = [0_u8; 1024]; in sdv_async_chunk_body_from_async_reader() variables
88 let mut size = buf.len(); in sdv_async_chunk_body_from_async_reader()
89 while size == buf.len() { in sdv_async_chunk_body_from_async_reader()
90 size = async_impl::Body::data(&mut task, buf.as_mut_slice()) in sdv_async_chunk_body_from_async_reader()
93 output.extend_from_slice(&buf[ in sdv_async_chunk_body_from_async_reader()
112 let mut buf = [0_u8; 20]; sdv_async_chunk_body_from_bytes() variables
141 let mut buf = [0_u8; 20]; sdv_chunk_body_encode_trailer_0() variables
215 let mut buf = [0u8; 1]; sdv_empty_body_async_impl_data() variables
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/
H A Dmod.rs72 // Pulls some bytes from this src into the buf, returning how many bytes were
74 pub(crate) fn data_copy(src: &[u8], src_idx: &mut usize, buf: &mut [u8]) -> TokenResult<usize> {
76 let output_len = buf.len();
78 let num = (&src[*src_idx..]).read(buf)?;
87 pub(crate) fn trim_front_lwsp(buf: &[u8]) -> &[u8] {
89 for b in buf.iter() {
95 &buf[idx..]
99 fn trim_back_lwsp(buf: &[u8]) -> &[u8] { in trim_back_lwsp()
101 for b in buf.iter().rev() { in trim_back_lwsp()
107 &buf[ in trim_back_lwsp()
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Dencoder.rs184 pub fn encode(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode()
187 while written_bytes < buf.len() { in encode()
195 let bytes = self.encode_headers_frame(&mut buf[written_bytes..])?; in encode()
202 let bytes = self.encode_headers_payload(&mut buf[written_bytes..])?; in encode()
209 let bytes = self.encode_padding(&mut buf[written_bytes..])?; in encode()
216 let bytes = self.encode_continuation_frames(&mut buf[written_bytes..])?; in encode()
223 let bytes = self.encode_data_header(&mut buf[written_bytes..])?; in encode()
230 let bytes = self.encode_data_payload(&mut buf[written_bytes..])?; in encode()
237 let bytes = self.encode_padding(&mut buf[written_bytes..])?; in encode()
244 let bytes = self.encode_settings_frame(&mut buf[written_byte in encode()
1395 let mut buf = vec![0; 50]; ut_headers_frame_encoding() variables
1614 let mut buf = vec![0; 50]; ut_rst_stream_frame_encoding() variables
1659 let mut buf = vec![0; 50]; ut_window_update_frame_encoding() variables
1698 let mut buf = [0u8; 14]; ut_priority_frame_encoding() variables
1857 let mut buf = [0u8; 5000]; ut_encode_continuation_frames() variables
1908 let mut buf = [0u8; 600]; ut_encode_padding() variables
1934 let mut buf = [0u8; 10]; ut_encode_small_data_frame() variables
1938 let mut buf = [0u8; 50]; ut_encode_small_data_frame() variables
1942 let mut buf = [0u8; 200]; ut_encode_small_data_frame() variables
1974 let mut buf = [0u8; 10]; ut_encode_large_data_frame() variables
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Dinput.rs32 buf: WriteBuf,
47 buf: [u8; 1024],
56 buf: [0; 1024],
130 buf: WriteBuf::new(),
136 if !self.buf.empty { in poll_writer_frame()
139 .poll_write(cx, &self.buf.buf[self.buf.start..self.buf.end]) in poll_writer_frame()
143 self.buf in poll_writer_frame()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dsplit.rs33 buf: &mut ReadBuf<'_>, in poll_read()
35 self.0.source.poll_read(cx, buf) in poll_read()
43 buf: &[u8], in poll_write()
45 self.0.source.poll_write(cx, buf) in poll_write()
79 buf: &mut ReadBuf<'_>, in poll_read()
81 self.0.source.poll_read(cx, buf) in poll_read()
89 buf: &[u8], in poll_write()
91 self.0.source.poll_write(cx, buf) in poll_write()
145 let mut buf = [0; 16]; in poll_flush() variables
148 let n = read_half.read(&mut buf) in poll_flush()
157 let mut buf = [0; 16]; poll_flush() variables
192 let mut buf = [0; 16]; poll_flush() variables
204 let mut buf = [0; 16]; poll_flush() variables
238 let mut buf = [0; 6]; poll_flush() variables
253 let mut buf = [0; 6]; poll_flush() variables
288 let mut buf = [0; 6]; poll_flush() variables
303 let mut buf = [0; 6]; poll_flush() variables
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/decode/
H A Dpart.rs72 buf: &'a [u8],
75 if buf.is_empty() {
80 let mut remains = buf;
101 fn start_decode<'a>(&mut self, buf: &'a [u8]) -> Result<&'a [u8], HttpError> { in start_decode()
102 let buf = trim_front_lwsp(buf); in start_decode()
104 Ok(buf)
108 fn headers_decode<'a>(&mut self, buf: &'a [u8]) -> Result<&'a [u8], HttpError> { in headers_decode()
109 let (elem, rest) = self.headers_decoder.decode(buf)?; in headers_decode()
119 fn body_decode<'a>(&mut self, buf
[all...]
H A Dmulti.rs39 /// let buf = b"--abc\r\nkey1:value1\r\n\r\n1111\r\n--abc--\r\nabcd";
41 /// let (elem, rest) = decoder.decode(buf).unwrap();
100 /// let buf = b"--abc\r\n\r\n--abc--\r\nabcd";
102 /// let (elem, rest) = decoder.decode(buf).unwrap();
117 buf: &'a [u8], in decode()
119 if buf.is_empty() { in decode()
124 let mut remains = buf;
155 buf: &'a [u8], in unknown_decode()
157 let (elem, rest) = headers_decoder.decode(buf)?; in unknown_decode()
200 buf in part_decode()
993 let mut buf = b"--abc\\r\\n\\r\\n--abc--\\r\\nabcd".to_vec(); ut_mime_multi_decoder_err() variables
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_tcp.rs29 let mut buf = [0; $buf_size]; variables
30 stream.read_exact(&mut buf).await.unwrap();
31 assert_eq!(buf, [3; $buf_size]);
33 let buf = [2; $buf_size];
34 stream.write_all(&buf).await.unwrap();
45 let buf = [3; $buf_size];
46 tcp.write_all(&buf).await.unwrap();
48 let mut buf = [0; $buf_size]; variables
49 tcp.read_exact(&mut buf).await.unwrap();
50 assert_eq!(buf, [
81 let mut buf = [0; $buf_size]; global() variables
100 let mut buf = [0; $buf_size]; global() variables
[all...]
H A Dylong_tokio_uds.rs30 let mut buf = [0; $buf_size]; variables
31 stream.read_exact(&mut buf).await.unwrap();
32 assert_eq!(buf, [3; $buf_size]);
34 let buf = [2; $buf_size];
35 stream.write_all(&buf).await.unwrap();
46 let buf = [3; $buf_size];
47 uds.write_all(&buf).await.unwrap();
49 let mut buf = [0; $buf_size]; variables
50 uds.read_exact(&mut buf).await.unwrap();
51 assert_eq!(buf, [
84 let mut buf = [0; $buf_size]; global() variables
103 let mut buf = [0; $buf_size]; global() variables
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/
H A Ddecoder.rs34 /// Decodes `buf`. Every time users call `decode`, it will try to
38 buf: &[u8],
41 if buf.is_empty() {
48 .decode(buf)
50 // If `buf` is not enough to continue decoding a complete
72 /// Decodes `self.buf`. Every time users call `decode`, it will try to
76 buf: &[u8],
79 // If buf is empty, leave the state unchanged.
80 let buf_len = buf.len();
81 if buf
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_tcp.rs28 let mut buf = [0; BUF_SIZE]; variables
29 stream.read_exact(&mut buf).await.unwrap();
30 assert_eq!(buf, [3; BUF_SIZE]);
32 let buf = [2; BUF_SIZE];
33 stream.write_all(&buf).await.unwrap();
44 let buf = [3; BUF_SIZE];
45 tcp.write_all(&buf).await.unwrap();
47 let mut buf = [0; BUF_SIZE]; variables
48 tcp.read_exact(&mut buf).await.unwrap();
49 assert_eq!(buf, [
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Dtcp_test.rs57 let mut buf = [0; 5]; in sdv_tcp_server() variables
59 let ret = read_stream.read(&mut buf); in sdv_tcp_server()
63 assert_eq!(&buf, b"hello"); in sdv_tcp_server()
79 let mut buf = [0; 5]; in sdv_tcp_server() variables
80 let ret = client.read(&mut buf).unwrap(); in sdv_tcp_server()
82 assert_eq!(&buf, b"hello"); in sdv_tcp_server()
84 let ret = client.write(&buf).unwrap(); in sdv_tcp_server()
131 let mut buf = [0; 5]; in sdv_tcp_server_vectored() variables
132 let slice = IoSliceMut::new(&mut buf); in sdv_tcp_server_vectored()
137 assert_eq!(&buf, in sdv_tcp_server_vectored()
153 let mut buf = [0; 5]; sdv_tcp_server_vectored() variables
[all...]
/commonlibrary/ets_utils/js_util_module/container/arraylist/
H A Dnative_module_arraylist.cpp31 __attribute__((visibility("default"))) void NAPI_util_ArrayList_GetJSCode(const char **buf, int *bufLen) in NAPI_util_ArrayList_GetJSCode() argument
33 if (buf != nullptr) { in NAPI_util_ArrayList_GetJSCode()
34 *buf = _binary_js_arraylist_js_start; in NAPI_util_ArrayList_GetJSCode()
41 __attribute__((visibility("default"))) void NAPI_util_ArrayList_GetABCCode(const char **buf, int *buflen) in NAPI_util_ArrayList_GetABCCode() argument
43 if (buf != nullptr) { in NAPI_util_ArrayList_GetABCCode()
44 *buf = _binary_arraylist_abc_start; in NAPI_util_ArrayList_GetABCCode()
/commonlibrary/ets_utils/js_util_module/container/hashmap/
H A Dnative_module_hashmap.cpp32 __attribute__((visibility("default"))) void NAPI_util_HashMap_GetJSCode(const char **buf, int *bufLen) in NAPI_util_HashMap_GetJSCode() argument
34 if (buf != nullptr) { in NAPI_util_HashMap_GetJSCode()
35 *buf = _binary_js_hashmap_js_start; in NAPI_util_HashMap_GetJSCode()
43 __attribute__((visibility("default"))) void NAPI_util_HashMap_GetABCCode(const char** buf, int* buflen) in NAPI_util_HashMap_GetABCCode() argument
45 if (buf != nullptr) { in NAPI_util_HashMap_GetABCCode()
46 *buf = _binary_hashmap_abc_start; in NAPI_util_HashMap_GetABCCode()
/commonlibrary/ets_utils/js_util_module/container/deque/
H A Dnative_module_deque.cpp30 __attribute__((visibility("default"))) void NAPI_util_Deque_GetJSCode(const char **buf, int *bufLen) in NAPI_util_Deque_GetJSCode() argument
32 if (buf != nullptr) { in NAPI_util_Deque_GetJSCode()
33 *buf = _binary_js_deque_js_start; in NAPI_util_Deque_GetJSCode()
41 __attribute__((visibility("default"))) void NAPI_util_Deque_GetABCCode(const char **buf, int *buflen) in NAPI_util_Deque_GetABCCode() argument
43 if (buf != nullptr) { in NAPI_util_Deque_GetABCCode()
44 *buf = _binary_deque_abc_start; in NAPI_util_Deque_GetABCCode()

Completed in 9 milliseconds

1234567