Lines Matching refs:rl
177 let mut rl = GeneratorStreamInternal::new(1); in test_generator_stream() localVariable
198 let add = |rl: &mut GeneratorStreamInternal, nums: &[u16]| { in test_generator_stream()
201 rl.add(seq); in test_generator_stream()
205 let assert_get = |rl: &GeneratorStreamInternal, nums: &[u16]| { in test_generator_stream()
208 assert!(rl.get(seq), "not found: {seq}"); in test_generator_stream()
212 let assert_not_get = |rl: &GeneratorStreamInternal, nums: &[u16]| { in test_generator_stream()
216 !rl.get(seq), in test_generator_stream()
225 let assert_missing = |rl: &GeneratorStreamInternal, skip_last_n: u16, nums: &[u16]| { in test_generator_stream()
226 let missing = rl.missing_seq_numbers(skip_last_n); in test_generator_stream()
235 let assert_last_consecutive = |rl: &GeneratorStreamInternal, last_consecutive: u16| { in test_generator_stream()
237 assert_eq!(rl.last_consecutive, want, "invalid last_consecutive want"); in test_generator_stream()
240 add(&mut rl, &[0]); in test_generator_stream()
241 assert_get(&rl, &[0]); in test_generator_stream()
242 assert_missing(&rl, 0, &[]); in test_generator_stream()
243 assert_last_consecutive(&rl, 0); // first element added in test_generator_stream()
245 add(&mut rl, &all(1, 127)); in test_generator_stream()
246 assert_get(&rl, &all(1, 127)); in test_generator_stream()
247 assert_missing(&rl, 0, &[]); in test_generator_stream()
248 assert_last_consecutive(&rl, 127); in test_generator_stream()
250 add(&mut rl, &[128]); in test_generator_stream()
251 assert_get(&rl, &[128]); in test_generator_stream()
252 assert_not_get(&rl, &[0]); in test_generator_stream()
253 assert_missing(&rl, 0, &[]); in test_generator_stream()
254 assert_last_consecutive(&rl, 128); in test_generator_stream()
256 add(&mut rl, &[130]); in test_generator_stream()
257 assert_get(&rl, &[130]); in test_generator_stream()
258 assert_not_get(&rl, &[1, 2, 129]); in test_generator_stream()
259 assert_missing(&rl, 0, &[129]); in test_generator_stream()
260 assert_last_consecutive(&rl, 128); in test_generator_stream()
262 add(&mut rl, &[333]); in test_generator_stream()
263 assert_get(&rl, &[333]); in test_generator_stream()
264 assert_not_get(&rl, &all(0, 332)); in test_generator_stream()
265 assert_missing(&rl, 0, &all(206, 332)); // all 127 elements missing before 333 in test_generator_stream()
266 assert_missing(&rl, 10, &all(206, 323)); // skip last 10 packets (324-333) from check in test_generator_stream()
267 assert_last_consecutive(&rl, 205); // lastConsecutive is still out of the buffer in test_generator_stream()
269 add(&mut rl, &[329]); in test_generator_stream()
270 assert_get(&rl, &[329]); in test_generator_stream()
271 assert_missing(&rl, 0, &join(&[&all(206, 328), &all(330, 332)])); in test_generator_stream()
272 … assert_missing(&rl, 5, &join(&[&all(206, 328)])); // skip last 5 packets (329-333) from check in test_generator_stream()
273 assert_last_consecutive(&rl, 205); in test_generator_stream()
275 add(&mut rl, &all(207, 320)); in test_generator_stream()
276 assert_get(&rl, &all(207, 320)); in test_generator_stream()
277 assert_missing(&rl, 0, &join(&[&[206], &all(321, 328), &all(330, 332)])); in test_generator_stream()
278 assert_last_consecutive(&rl, 205); in test_generator_stream()
280 add(&mut rl, &[334]); in test_generator_stream()
281 assert_get(&rl, &[334]); in test_generator_stream()
282 assert_not_get(&rl, &[206]); in test_generator_stream()
283 assert_missing(&rl, 0, &join(&[&all(321, 328), &all(330, 332)])); in test_generator_stream()
284 assert_last_consecutive(&rl, 320); // head of buffer is full of consecutive packages in test_generator_stream()
286 add(&mut rl, &all(322, 328)); in test_generator_stream()
287 assert_get(&rl, &all(322, 328)); in test_generator_stream()
288 assert_missing(&rl, 0, &join(&[&[321], &all(330, 332)])); in test_generator_stream()
289 assert_last_consecutive(&rl, 320); in test_generator_stream()
291 add(&mut rl, &[321]); in test_generator_stream()
292 assert_get(&rl, &[321]); in test_generator_stream()
293 assert_missing(&rl, 0, &all(330, 332)); in test_generator_stream()
294 …assert_last_consecutive(&rl, 329); // after adding a single missing packet, lastConsecutive should… in test_generator_stream()
302 let mut rl = GeneratorStreamInternal::new(1); in test_generator_stream_rollover() localVariable
304 rl.add(65533); in test_generator_stream_rollover()
305 rl.add(65535); in test_generator_stream_rollover()
306 rl.add(65534); in test_generator_stream_rollover()
308 let mut rl = GeneratorStreamInternal::new(1); in test_generator_stream_rollover() localVariable
310 rl.add(65534); in test_generator_stream_rollover()
311 rl.add(0); in test_generator_stream_rollover()
312 rl.add(65535); in test_generator_stream_rollover()