Lines Matching refs:packet
11 let mut packet: Vec<u8> = vec![0; 4]; in test_buffer() localVariable
18 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
20 assert_eq!(&packet[..n], &[0, 1]); in test_buffer()
23 let result = buffer.read(&mut packet, Some(Duration::new(0, 1))).await; in test_buffer()
35 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
37 assert_eq!(&packet[..n], &[2, 3, 4]); in test_buffer()
39 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
41 assert_eq!(&packet[..n], &[5, 6, 7]); in test_buffer()
55 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
57 assert_eq!(&packet[..n], &[3]); in test_buffer()
60 let result = buffer.read(&mut packet, None).await; in test_buffer()
134 let mut packet: Vec<u8> = vec![0; 4]; in test_buffer_async() localVariable
136 let n = assert_ok!(buffer2.read(&mut packet, None).await); in test_buffer_async()
138 assert_eq!(&packet[..n], &[0, 1]); in test_buffer_async()
140 let result = buffer2.read(&mut packet, None).await; in test_buffer_async()
187 let mut packet: Vec<u8> = vec![0; 4]; in test_buffer_limit_count() localVariable
188 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_count()
190 assert_eq!(&packet[..n], &[0, 1]); in test_buffer_limit_count()
207 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_count()
209 assert_eq!(&packet[..n], &[2, 3]); in test_buffer_limit_count()
212 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_count()
214 assert_eq!(&packet[..n], &[6, 7]); in test_buffer_limit_count()
250 let mut packet: Vec<u8> = vec![0; 4]; in test_buffer_limit_size() localVariable
251 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_size()
253 assert_eq!(&packet[..n], &[0, 1]); in test_buffer_limit_size()
270 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_size()
272 assert_eq!(&packet[..n], &[2, 3]); in test_buffer_limit_size()
275 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_size()
277 assert_eq!(&packet[..n], &[6]); in test_buffer_limit_size()
280 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_size()
282 assert_eq!(&packet[..n], &[7, 8]); in test_buffer_limit_size()
326 let mut packet = vec![0; size]; in test_buffer_limit_sizes() localVariable
328 let n = assert_ok!(buffer.read(&mut packet, Some(Duration::new(5, 0))).await); in test_buffer_limit_sizes()
343 let mut packet: Vec<u8> = vec![0; 3]; in test_buffer_misc() localVariable
344 let result = buffer.read(&mut packet, None).await; in test_buffer_misc()