| /dports/www/xh/xh-0.14.1/cargo-crates/tokio-1.11.0/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/devel/pijul/pijul-1.0.0.a55/cargo-crates/tokio-1.12.0/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/www/miniserve/miniserve-0.18.0/cargo-crates/tokio-1.11.0/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/tokio/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/devel/desed/desed-1.2.0/cargo-crates/tokio-0.2.22/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/audio/ncspot/ncspot-0.9.3/cargo-crates/tokio-1.14.0/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/textproc/angle-grinder/angle-grinder-0.18.0/cargo-crates/tokio-0.2.25/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/audio/spotify-tui/spotify-tui-0.25.0/cargo-crates/tokio-0.2.25/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/devel/sentry-cli/sentry-cli-1.71.0/cargo-crates/tokio-1.13.0/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/sysutils/tealdeer/tealdeer-1.4.1/cargo-crates/tokio-0.2.22/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/www/monolith/monolith-2.6.1/cargo-crates/tokio-1.8.0/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/devel/py-maturin/maturin-0.11.3/cargo-crates/tokio-1.10.1/tests/ |
| H A D | tcp_into_split.rs | 30 let mut read_buf = vec![0u8; 32]; in split() localVariable
31 let read_len = stream2.read(&mut read_buf).await?; in split()
32 assert_eq!(&read_buf[..read_len], MSG); in split()
41 let mut read_buf = vec![0u8; 32]; in split() localVariable
48 assert_eq!(&read_buf[..read_len], MSG); in split()
95 let mut read_buf = [0u8; 32]; in drop_write() localVariable
96 let res = match stream.read(&mut read_buf) { in drop_write()
113 let mut read_buf = [0u8; 32]; in drop_write() localVariable
114 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
115 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/science/hdf5/hdf5-1.10.6/testpar/ |
| H A D | t_coll_md_read.c | 195 if (read_buf) { in test_partial_no_selection_coll_md_read()
196 HDfree(read_buf); in test_partial_no_selection_coll_md_read()
197 read_buf = NULL; in test_partial_no_selection_coll_md_read()
249 void *read_buf = NULL; in test_multi_chunk_io_addrmap_issue() local
314 if (read_buf) { in test_multi_chunk_io_addrmap_issue()
315 HDfree(read_buf); in test_multi_chunk_io_addrmap_issue()
316 read_buf = NULL; in test_multi_chunk_io_addrmap_issue()
386 void *read_buf = NULL; in test_link_chunk_io_sort_chunk_issue() local
495 if (read_buf) { in test_link_chunk_io_sort_chunk_issue()
496 HDfree(read_buf); in test_link_chunk_io_sort_chunk_issue()
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/tokio-0.2.21/tests/ |
| H A D | tcp_into_split.rs | 31 let mut read_buf = vec![0u8; 32]; in split() localVariable
32 let read_len = stream2.read(&mut read_buf).await?; in split()
33 assert_eq!(&read_buf[..read_len], MSG); in split()
42 let mut read_buf = vec![0u8; 32]; in split() localVariable
49 assert_eq!(&read_buf[..read_len], MSG); in split()
99 let mut read_buf = [0u8; 32]; in drop_write() localVariable
100 let res = match stream.read(&mut read_buf) { in drop_write()
119 let mut read_buf = [0u8; 32]; in drop_write() localVariable
120 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
121 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/tokio-0.2.21/tests/ |
| H A D | tcp_into_split.rs | 31 let mut read_buf = vec![0u8; 32]; in split() localVariable
32 let read_len = stream2.read(&mut read_buf).await?; in split()
33 assert_eq!(&read_buf[..read_len], MSG); in split()
42 let mut read_buf = vec![0u8; 32]; in split() localVariable
49 assert_eq!(&read_buf[..read_len], MSG); in split()
99 let mut read_buf = [0u8; 32]; in drop_write() localVariable
100 let res = match stream.read(&mut read_buf) { in drop_write()
119 let mut read_buf = [0u8; 32]; in drop_write() localVariable
120 let read_len = read_half.read(&mut read_buf[..]).await?; in drop_write()
121 assert_eq!(&read_buf[..read_len], MSG); in drop_write()
[all …]
|
| /dports/devel/aws-c-io/aws-c-io-0.10.12/tests/ |
| H A D | stream_test.c | 60 struct aws_byte_buf read_buf; in s_do_simple_input_stream_test() local
76 if (starting_len - read_buf.len > 0) { in s_do_simple_input_stream_test()
81 read_buf.len = 0; in s_do_simple_input_stream_test()
89 aws_byte_buf_clean_up(&read_buf); in s_do_simple_input_stream_test()
161 struct aws_byte_buf read_buf; in s_do_input_stream_seek_test() local
171 aws_byte_buf_clean_up(&read_buf); in s_do_input_stream_seek_test()
245 read_buf.len = 0; in s_test_input_stream_memory_seek_multiple_times()
251 read_buf.len = 0; in s_test_input_stream_memory_seek_multiple_times()
257 read_buf.len = 0; in s_test_input_stream_memory_seek_multiple_times()
263 read_buf.len = 0; in s_test_input_stream_memory_seek_multiple_times()
[all …]
|
| /dports/net/proby/proby-1.0.2/cargo-crates/actix-codec-0.2.0/src/ |
| H A D | framed.rs | 27 read_buf: BytesMut, field
56 read_buf: BytesMut::with_capacity(HW), in new()
86 read_buf: parts.read_buf, in from_parts()
136 read_buf: self.read_buf, in into_framed()
150 read_buf: self.read_buf, in map_io()
164 read_buf: self.read_buf, in map_codec()
180 read_buf: self.read_buf, in into_parts()
248 let remaining = self.read_buf.capacity() - self.read_buf.len(); in next_item()
390 pub read_buf: BytesMut, field
405 read_buf: BytesMut::new(), in new()
[all …]
|
| /dports/www/miniserve/miniserve-0.18.0/cargo-crates/actix-codec-0.4.0/src/ |
| H A D | framed.rs | 37 read_buf: BytesMut,
99 self.read_buf.is_empty() in is_read_buf_empty()
125 read_buf: self.read_buf, in replace_codec()
139 read_buf: self.read_buf, in into_map_io()
153 read_buf: self.read_buf, in into_map_codec()
219 let remaining = this.read_buf.capacity() - this.read_buf.len(); in next_item()
357 read_buf: parts.read_buf, in from_parts()
372 read_buf: self.read_buf, in into_parts()
390 pub read_buf: BytesMut, field
405 read_buf: BytesMut::new(), in new()
[all …]
|
| /dports/emulators/dosbox-staging/dosbox-staging-0.78.0/src/dos/ |
| H A D | dos_keyboard_layout.cpp | 281 static Bit8u read_buf[65535]; in read_keyboard_file() local
335 if ((dr<4) || (read_buf[0]!=0x4b) || (read_buf[1]!=0x4c) || (read_buf[2]!=0x46)) { in read_keyboard_file()
347 data_len=read_buf[start_pos++]; in read_keyboard_file()
368 submappings=read_buf[start_pos]; in read_keyboard_file()
452 Bit16u kchar=read_buf[charptr]; in read_keyboard_file()
455 if (read_buf[read_buf_pos-2]&0x80) kchar|=read_buf[charptr+1]<<8; // scancode/char pair in read_keyboard_file()
467 if ((read_buf[read_buf_pos-2]&0x7) > new_flags) new_flags = read_buf[read_buf_pos-2]&0x7; in read_keyboard_file()
640 static Bit8u read_buf[65535]; in extract_codepage() local
692 if ((dr<4) || (read_buf[0]!=0x4b) || (read_buf[1]!=0x4c) || (read_buf[2]!=0x46)) { in extract_codepage()
704 data_len=read_buf[start_pos++]; in extract_codepage()
[all …]
|
| /dports/games/libretro-dosbox/dosbox-libretro-aa71b67/src/dos/ |
| H A D | dos_keyboard_layout.cpp | 265 static Bit8u read_buf[65535]; in read_keyboard_file() local
318 if ((dr<4) || (read_buf[0]!=0x4b) || (read_buf[1]!=0x4c) || (read_buf[2]!=0x46)) { in read_keyboard_file()
329 data_len=read_buf[start_pos++]; in read_keyboard_file()
350 submappings=read_buf[start_pos]; in read_keyboard_file()
432 Bit16u kchar=read_buf[charptr]; in read_keyboard_file()
435 if (read_buf[read_buf_pos-2]&0x80) kchar|=read_buf[charptr+1]<<8; // scancode/char pair in read_keyboard_file()
447 if ((read_buf[read_buf_pos-2]&0x7) > new_flags) new_flags = read_buf[read_buf_pos-2]&0x7; in read_keyboard_file()
619 static Bit8u read_buf[65535]; in extract_codepage() local
671 if ((dr<4) || (read_buf[0]!=0x4b) || (read_buf[1]!=0x4c) || (read_buf[2]!=0x46)) { in extract_codepage()
682 data_len=read_buf[start_pos++]; in extract_codepage()
[all …]
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/hyper-0.12.35/src/common/io/ |
| H A D | rewind.rs | 113 self.inner.read_buf(buf) in read_buf()
156 stream.rewind(read_buf); in async_partial_rewind()
161 stream.read_buf(&mut o2_cursor).unwrap(); in async_partial_rewind()
162 stream.read_buf(&mut o2_cursor).unwrap(); in async_partial_rewind()
183 stream.rewind(read_buf); in async_full_rewind()
186 stream.read_buf(&mut o2_cursor).unwrap(); in async_full_rewind()
187 stream.read_buf(&mut o2_cursor).unwrap(); in async_full_rewind()
201 let read_buf = Bytes::from(&o1[..]); in partial_rewind() localVariable
202 stream.rewind(read_buf); in partial_rewind()
216 let read_buf = Bytes::from(&o1[..]); in full_rewind() localVariable
[all …]
|
| /dports/net-mgmt/nfs-exporter/freebsd-nfs-exporter-0.3.0/cargo-crates/hyper-0.12.35/src/common/io/ |
| H A D | rewind.rs | 113 self.inner.read_buf(buf) in read_buf()
156 stream.rewind(read_buf); in async_partial_rewind()
161 stream.read_buf(&mut o2_cursor).unwrap(); in async_partial_rewind()
162 stream.read_buf(&mut o2_cursor).unwrap(); in async_partial_rewind()
183 stream.rewind(read_buf); in async_full_rewind()
186 stream.read_buf(&mut o2_cursor).unwrap(); in async_full_rewind()
187 stream.read_buf(&mut o2_cursor).unwrap(); in async_full_rewind()
201 let read_buf = Bytes::from(&o1[..]); in partial_rewind() localVariable
202 stream.rewind(read_buf); in partial_rewind()
216 let read_buf = Bytes::from(&o1[..]); in full_rewind() localVariable
[all …]
|
| /dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/hyper-0.12.19/src/common/io/ |
| H A D | rewind.rs | 113 self.inner.read_buf(buf) in read_buf()
156 stream.rewind(read_buf); in async_partial_rewind()
161 stream.read_buf(&mut o2_cursor).unwrap(); in async_partial_rewind()
162 stream.read_buf(&mut o2_cursor).unwrap(); in async_partial_rewind()
183 stream.rewind(read_buf); in async_full_rewind()
186 stream.read_buf(&mut o2_cursor).unwrap(); in async_full_rewind()
187 stream.read_buf(&mut o2_cursor).unwrap(); in async_full_rewind()
201 let read_buf = Bytes::from(&o1[..]); in partial_rewind() localVariable
202 stream.rewind(read_buf); in partial_rewind()
216 let read_buf = Bytes::from(&o1[..]); in full_rewind() localVariable
[all …]
|
| /dports/security/sequoia/sequoia-383133f6be990237044900a4df676488bf8dd71e/cargo-crates/hyper-0.12.35/src/common/io/ |
| H A D | rewind.rs | 113 self.inner.read_buf(buf) in read_buf()
156 stream.rewind(read_buf); in async_partial_rewind()
161 stream.read_buf(&mut o2_cursor).unwrap(); in async_partial_rewind()
162 stream.read_buf(&mut o2_cursor).unwrap(); in async_partial_rewind()
183 stream.rewind(read_buf); in async_full_rewind()
186 stream.read_buf(&mut o2_cursor).unwrap(); in async_full_rewind()
187 stream.read_buf(&mut o2_cursor).unwrap(); in async_full_rewind()
201 let read_buf = Bytes::from(&o1[..]); in partial_rewind() localVariable
202 stream.rewind(read_buf); in partial_rewind()
216 let read_buf = Bytes::from(&o1[..]); in full_rewind() localVariable
[all …]
|
| /dports/sysutils/rsfetch/rsfetch-2.0.0/cargo-crates/hyper-0.12.35/src/common/io/ |
| H A D | rewind.rs | 113 self.inner.read_buf(buf) in read_buf()
156 stream.rewind(read_buf); in async_partial_rewind()
161 stream.read_buf(&mut o2_cursor).unwrap(); in async_partial_rewind()
162 stream.read_buf(&mut o2_cursor).unwrap(); in async_partial_rewind()
183 stream.rewind(read_buf); in async_full_rewind()
186 stream.read_buf(&mut o2_cursor).unwrap(); in async_full_rewind()
187 stream.read_buf(&mut o2_cursor).unwrap(); in async_full_rewind()
201 let read_buf = Bytes::from(&o1[..]); in partial_rewind() localVariable
202 stream.rewind(read_buf); in partial_rewind()
216 let read_buf = Bytes::from(&o1[..]); in full_rewind() localVariable
[all …]
|