Lines Matching refs:buffer
10 let buffer = Buffer::new(0, 0); in test_buffer() localVariable
14 let n = assert_ok!(buffer.write(&[0, 1]).await); in test_buffer()
18 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
23 let result = buffer.read(&mut packet, Some(Duration::new(0, 1))).await; in test_buffer()
28 let n = assert_ok!(buffer.write(&[2, 3, 4]).await); in test_buffer()
31 let n = assert_ok!(buffer.write(&[5, 6, 7]).await); in test_buffer()
35 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
39 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
44 let n = assert_ok!(buffer.write(&[3]).await); in test_buffer()
48 buffer.close().await; in test_buffer()
51 let result = buffer.write(&[4]).await; in test_buffer()
55 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
60 let result = buffer.read(&mut packet, None).await; in test_buffer()
66 let buffer = Buffer::new(0, 0); in test_wraparound() localVariable
68 let mut b = buffer.buffer.lock().await; in test_wraparound()
81 assert_ok!(buffer.write(&p1).await); in test_wraparound()
82 assert_ok!(buffer.write(&p2).await); in test_wraparound()
83 assert_ok!(buffer.write(&p3).await); in test_wraparound()
87 let n = assert_ok!(buffer.read(&mut p, None).await); in test_wraparound()
91 let mut b = buffer.buffer.lock().await; in test_wraparound()
96 let n = assert_ok!(buffer.read(&mut p, None).await); in test_wraparound()
99 assert_ok!(buffer.write(&p4).await); in test_wraparound()
101 let n = assert_ok!(buffer.read(&mut p, None).await); in test_wraparound()
103 let n = assert_ok!(buffer.read(&mut p, None).await); in test_wraparound()
107 let b = buffer.buffer.lock().await; in test_wraparound()
128 let buffer = Buffer::new(0, 0); in test_buffer_async() localVariable
132 let buffer2 = buffer.clone(); in test_buffer_async()
151 let n = assert_ok!(buffer.write(&[0, 1]).await); in test_buffer_async()
158 buffer.close().await; in test_buffer_async()
165 let buffer = Buffer::new(2, 0); in test_buffer_limit_count() localVariable
167 assert_eq!(buffer.count().await, 0); in test_buffer_limit_count()
170 let n = assert_ok!(buffer.write(&[0, 1]).await); in test_buffer_limit_count()
172 assert_eq!(buffer.count().await, 1); in test_buffer_limit_count()
174 let n = assert_ok!(buffer.write(&[2, 3]).await); in test_buffer_limit_count()
176 assert_eq!(buffer.count().await, 2); in test_buffer_limit_count()
179 let result = buffer.write(&[4, 5]).await; in test_buffer_limit_count()
184 assert_eq!(buffer.count().await, 2); in test_buffer_limit_count()
188 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_count()
191 assert_eq!(buffer.count().await, 1); in test_buffer_limit_count()
194 let n = assert_ok!(buffer.write(&[6, 7]).await); in test_buffer_limit_count()
196 assert_eq!(buffer.count().await, 2); in test_buffer_limit_count()
199 let result = buffer.write(&[8, 9]).await; in test_buffer_limit_count()
204 assert_eq!(buffer.count().await, 2); in test_buffer_limit_count()
207 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_count()
210 assert_eq!(buffer.count().await, 1); in test_buffer_limit_count()
212 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_count()
215 assert_eq!(buffer.count().await, 0); in test_buffer_limit_count()
218 buffer.close().await; in test_buffer_limit_count()
223 let buffer = Buffer::new(0, 11); in test_buffer_limit_size() localVariable
225 assert_eq!(buffer.size().await, 0); in test_buffer_limit_size()
228 let n = assert_ok!(buffer.write(&[0, 1]).await); in test_buffer_limit_size()
230 assert_eq!(buffer.size().await, 4); in test_buffer_limit_size()
232 let n = assert_ok!(buffer.write(&[2, 3]).await); in test_buffer_limit_size()
234 assert_eq!(buffer.size().await, 8); in test_buffer_limit_size()
237 let result = buffer.write(&[4, 5]).await; in test_buffer_limit_size()
242 assert_eq!(buffer.size().await, 8); in test_buffer_limit_size()
245 let n = assert_ok!(buffer.write(&[6]).await); in test_buffer_limit_size()
247 assert_eq!(buffer.size().await, 11); in test_buffer_limit_size()
251 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_size()
254 assert_eq!(buffer.size().await, 7); in test_buffer_limit_size()
257 let n = assert_ok!(buffer.write(&[7, 8]).await); in test_buffer_limit_size()
259 assert_eq!(buffer.size().await, 11); in test_buffer_limit_size()
262 let result = buffer.write(&[9, 10]).await; in test_buffer_limit_size()
267 assert_eq!(buffer.size().await, 11); in test_buffer_limit_size()
270 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_size()
273 assert_eq!(buffer.size().await, 7); in test_buffer_limit_size()
275 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_size()
278 assert_eq!(buffer.size().await, 4); in test_buffer_limit_size()
280 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer_limit_size()
283 assert_eq!(buffer.size().await, 0); in test_buffer_limit_size()
286 buffer.close().await; in test_buffer_limit_size()
306 let buffer = Buffer::new(0, 0); in test_buffer_limit_sizes() localVariable
310 buffer.set_limit_size(size + HEADER_SIZE).await; in test_buffer_limit_sizes()
318 assert_ok!(buffer.write(&pkt).await); in test_buffer_limit_sizes()
322 let result = buffer.write(&pkt).await; in test_buffer_limit_sizes()
328 let n = assert_ok!(buffer.read(&mut packet, Some(Duration::new(5, 0))).await); in test_buffer_limit_sizes()
336 let buffer = Buffer::new(0, 0); in test_buffer_misc() localVariable
339 let n = assert_ok!(buffer.write(&[0, 1, 2, 3]).await); in test_buffer_misc()
344 let result = buffer.read(&mut packet, None).await; in test_buffer_misc()
351 buffer.close().await; in test_buffer_misc()
354 assert!(buffer.is_closed().await); in test_buffer_misc()
357 buffer.close().await; in test_buffer_misc()