Lines Matching refs:oper
25 let oper = sel.select(); in smoke1() localVariable
26 match oper.index() { in smoke1()
27 i if i == oper1 => assert_eq!(oper.recv(&r1), Ok(1)), in smoke1()
37 let oper = sel.select(); in smoke1() localVariable
38 match oper.index() { in smoke1()
40 i if i == oper2 => assert_eq!(oper.recv(&r2), Ok(2)), in smoke1()
61 let oper = sel.select(); in smoke2() localVariable
62 match oper.index() { in smoke2()
67 i if i == oper5 => assert_eq!(oper.recv(&r5), Ok(5)), in smoke2()
87 let oper = sel.select_timeout(ms(1000)); in disconnected() localVariable
88 match oper { in disconnected()
90 Ok(oper) => match oper.index() { in disconnected()
91 i if i == oper1 => assert!(oper.recv(&r1).is_err()), in disconnected()
104 let oper = sel.select_timeout(ms(1000)); in disconnected() localVariable
105 match oper { in disconnected()
107 Ok(oper) => match oper.index() { in disconnected()
108 i if i == oper1 => assert!(oper.recv(&r1).is_err()), in disconnected()
122 let oper = sel.select_timeout(ms(1000)); in disconnected() localVariable
123 match oper { in disconnected()
125 Ok(oper) => match oper.index() { in disconnected()
126 i if i == oper1 => assert!(oper.recv(&r2).is_err()), in disconnected()
142 let oper = sel.try_select(); in default() localVariable
143 match oper { in default()
153 let oper = sel.try_select(); in default() localVariable
154 match oper { in default()
156 Ok(oper) => match oper.index() { in default()
157 i if i == oper1 => assert!(oper.recv(&r1).is_err()), in default()
167 let oper = sel.try_select(); in default() localVariable
168 match oper { in default()
170 Ok(oper) => match oper.index() { in default()
171 i if i == oper1 => assert_eq!(oper.recv(&r2), Ok(2)), in default()
178 let oper = sel.try_select(); in default() localVariable
179 match oper { in default()
185 let oper = sel.try_select(); in default() localVariable
186 match oper { in default()
206 let oper = sel.select_timeout(ms(1000)); in timeout() localVariable
207 match oper { in timeout()
209 Ok(oper) => match oper.index() { in timeout()
219 let oper = sel.select_timeout(ms(1000)); in timeout() localVariable
220 match oper { in timeout()
222 Ok(oper) => match oper.index() { in timeout()
224 i if i == oper2 => assert_eq!(oper.recv(&r2), Ok(2)), in timeout()
240 let oper = sel.select_timeout(ms(1000)); in timeout() localVariable
241 match oper { in timeout()
245 let oper = sel.try_select(); in timeout() localVariable
246 match oper { in timeout()
248 Ok(oper) => match oper.index() { in timeout()
249 i if i == oper1 => assert!(oper.recv(&r).is_err()), in timeout()
266 let oper = sel.try_select(); in default_when_disconnected() localVariable
267 match oper { in default_when_disconnected()
269 Ok(oper) => match oper.index() { in default_when_disconnected()
270 i if i == oper1 => assert!(oper.recv(&r).is_err()), in default_when_disconnected()
279 let oper = sel.select_timeout(ms(1000)); in default_when_disconnected() localVariable
280 match oper { in default_when_disconnected()
282 Ok(oper) => match oper.index() { in default_when_disconnected()
283 i if i == oper1 => assert!(oper.recv(&r).is_err()), in default_when_disconnected()
292 let oper = sel.try_select(); in default_when_disconnected() localVariable
293 match oper { in default_when_disconnected()
295 Ok(oper) => match oper.index() { in default_when_disconnected()
296 i if i == oper1 => assert!(oper.send(&s, 0).is_err()), in default_when_disconnected()
305 let oper = sel.select_timeout(ms(1000)); in default_when_disconnected() localVariable
306 match oper { in default_when_disconnected()
308 Ok(oper) => match oper.index() { in default_when_disconnected()
309 i if i == oper1 => assert!(oper.send(&s, 0).is_err()), in default_when_disconnected()
320 let oper = sel.try_select(); in default_only() localVariable
321 assert!(oper.is_err()); in default_only()
327 let oper = sel.select_timeout(ms(500)); in default_only() localVariable
328 assert!(oper.is_err()); in default_only()
348 let oper = sel.select_timeout(ms(1000)); in unblocks() localVariable
349 match oper { in unblocks()
351 Ok(oper) => match oper.index() { in unblocks()
353 i if i == oper2 => assert_eq!(oper.recv(&r2), Ok(2)), in unblocks()
369 let oper = sel.select_timeout(ms(1000)); in unblocks() localVariable
370 match oper { in unblocks()
372 Ok(oper) => match oper.index() { in unblocks()
373 i if i == oper1 => oper.send(&s1, 1).unwrap(), in unblocks()
398 let oper = sel.select(); in both_ready() localVariable
399 match oper.index() { in both_ready()
400 i if i == oper1 => assert_eq!(oper.recv(&r1), Ok(1)), in both_ready()
401 i if i == oper2 => oper.send(&s2, 2).unwrap(), in both_ready()
424 let oper = sel.try_select(); in loop_try() localVariable
425 match oper { in loop_try()
427 Ok(oper) => match oper.index() { in loop_try()
429 let _ = oper.send(&s1, 1); in loop_try()
441 let oper = sel.try_select(); in loop_try() localVariable
442 match oper { in loop_try()
444 Ok(oper) => match oper.index() { in loop_try()
446 let _ = oper.recv(&r_end); in loop_try()
466 let oper = sel.try_select(); in loop_try() localVariable
467 match oper { in loop_try()
469 Ok(oper) => match oper.index() { in loop_try()
471 let _ = oper.recv(&r_end); in loop_try()
488 let oper = sel.select_timeout(ms(1000)); in loop_try() localVariable
489 match oper { in loop_try()
491 Ok(oper) => match oper.index() { in loop_try()
492 i if i == oper1 => assert_eq!(oper.recv(&r1), Ok(1)), in loop_try()
493 i if i == oper2 => assert!(oper.send(&s2, 2).is_ok()), in loop_try()
525 let oper = sel.select(); in cloning1() localVariable
526 match oper.index() { in cloning1()
527 i if i == oper1 => drop(oper.recv(&r1)), in cloning1()
528 i if i == oper2 => drop(oper.recv(&r2)), in cloning1()
548 let oper = sel.select(); in cloning2() localVariable
549 match oper.index() { in cloning2()
551 i if i == oper2 => drop(oper.recv(&r2)), in cloning2()
570 let oper = sel.select(); in preflight1() localVariable
571 match oper.index() { in preflight1()
572 i if i == oper1 => drop(oper.recv(&r)), in preflight1()
586 let oper = sel.select(); in preflight2() localVariable
587 match oper.index() { in preflight2()
588 i if i == oper1 => assert_eq!(oper.recv(&r), Ok(())), in preflight2()
605 let oper = sel.select(); in preflight3() localVariable
606 match oper.index() { in preflight3()
607 i if i == oper1 => assert!(oper.recv(&r).is_err()), in preflight3()
623 let oper = sel.select(); in duplicate_operations() localVariable
624 match oper.index() { in duplicate_operations()
626 assert!(oper.recv(&r).is_ok()); in duplicate_operations()
630 assert!(oper.recv(&r).is_ok()); in duplicate_operations()
634 assert!(oper.send(&s, 0).is_ok()); in duplicate_operations()
638 assert!(oper.send(&s, 0).is_ok()); in duplicate_operations()
652 let oper = sel.select(); in nesting() localVariable
653 match oper.index() { in nesting()
655 assert!(oper.send(&s, 0).is_ok()); in nesting()
659 let oper = sel.select(); in nesting() localVariable
660 match oper.index() { in nesting()
662 assert_eq!(oper.recv(&r), Ok(0)); in nesting()
666 let oper = sel.select(); in nesting() localVariable
667 match oper.index() { in nesting()
669 assert!(oper.send(&s, 1).is_ok()); in nesting()
673 let oper = sel.select(); in nesting() localVariable
674 match oper.index() { in nesting()
676 assert_eq!(oper.recv(&r), Ok(1)); in nesting()
715 let oper = sel.select(); in stress_recv() localVariable
716 match oper.index() { in stress_recv()
717 ix if ix == oper1 => assert_eq!(oper.recv(&r1), Ok(i)), in stress_recv()
718 ix if ix == oper2 => assert_eq!(oper.recv(&r2), Ok(i)), in stress_recv()
751 let oper = sel.select(); in stress_send() localVariable
752 match oper.index() { in stress_send()
753 ix if ix == oper1 => assert!(oper.send(&s1, i).is_ok()), in stress_send()
754 ix if ix == oper2 => assert!(oper.send(&s2, i).is_ok()), in stress_send()
786 let oper = sel.select(); in stress_mixed() localVariable
787 match oper.index() { in stress_mixed()
788 ix if ix == oper1 => assert_eq!(oper.recv(&r1), Ok(i)), in stress_mixed()
789 ix if ix == oper2 => assert!(oper.send(&s2, i).is_ok()), in stress_mixed()
816 let oper = sel.select_timeout(ms(100)); in stress_timeout_two_threads() localVariable
817 match oper { in stress_timeout_two_threads()
819 Ok(oper) => match oper.index() { in stress_timeout_two_threads()
821 assert!(oper.send(&s, i).is_ok()); in stress_timeout_two_threads()
841 let oper = sel.select_timeout(ms(100)); in stress_timeout_two_threads() localVariable
842 match oper { in stress_timeout_two_threads()
844 Ok(oper) => match oper.index() { in stress_timeout_two_threads()
846 assert_eq!(oper.recv(&r), Ok(i)); in stress_timeout_two_threads()
865 let oper = sel.select_timeout(ms(100)); in send_recv_same_channel() localVariable
866 match oper { in send_recv_same_channel()
868 Ok(oper) => match oper.index() { in send_recv_same_channel()
879 let oper = sel.select_timeout(ms(100)); in send_recv_same_channel() localVariable
880 match oper { in send_recv_same_channel()
882 Ok(oper) => match oper.index() { in send_recv_same_channel()
883 ix if ix == oper1 => assert!(oper.send(&s, 0).is_ok()), in send_recv_same_channel()
902 let oper = sel.select(); in matching() localVariable
903 match oper.index() { in matching()
904 ix if ix == oper1 => assert_ne!(oper.recv(&r), Ok(i)), in matching()
905 ix if ix == oper2 => assert!(oper.send(&s, i).is_ok()), in matching()
928 let oper = sel.select(); in matching_with_leftover() localVariable
929 match oper.index() { in matching_with_leftover()
930 ix if ix == oper1 => assert_ne!(oper.recv(&r), Ok(i)), in matching_with_leftover()
931 ix if ix == oper2 => assert!(oper.send(&s, i).is_ok()), in matching_with_leftover()
963 let oper = sel.select(); in channel_through_channel() localVariable
964 match oper.index() { in channel_through_channel()
965 ix if ix == oper1 => assert!(oper.send(&s, new_r).is_ok()), in channel_through_channel()
981 let oper = sel.select(); in channel_through_channel() localVariable
982 match oper.index() { in channel_through_channel()
983 ix if ix == oper1 => oper in channel_through_channel()
1025 let oper = sel.try_select(); in linearizable_try() localVariable
1026 match oper { in linearizable_try()
1028 Ok(oper) => match oper.index() { in linearizable_try()
1029 ix if ix == oper1 => assert!(oper.recv(&r1).is_ok()), in linearizable_try()
1030 ix if ix == oper2 => assert!(oper.recv(&r2).is_ok()), in linearizable_try()
1077 let oper = sel.select_timeout(ms(0)); in linearizable_timeout() localVariable
1078 match oper { in linearizable_timeout()
1080 Ok(oper) => match oper.index() { in linearizable_timeout()
1081 ix if ix == oper1 => assert!(oper.recv(&r1).is_ok()), in linearizable_timeout()
1082 ix if ix == oper2 => assert!(oper.recv(&r2).is_ok()), in linearizable_timeout()
1127 let oper = sel.select(); in fairness1() localVariable
1128 match oper.index() { in fairness1()
1130 oper.recv(&r1).unwrap(); in fairness1()
1134 oper.recv(&r2).unwrap(); in fairness1()
1138 oper.recv(&after).unwrap(); in fairness1()
1142 oper.recv(&tick).unwrap(); in fairness1()
1172 let oper = sel.select(); in fairness2() localVariable
1173 match oper.index() { in fairness2()
1174 i if Some(i) == oper1 => assert!(oper.send(&s1, ()).is_ok()), in fairness2()
1175 i if Some(i) == oper2 => assert!(oper.send(&s2, ()).is_ok()), in fairness2()
1176 i if i == oper3 => assert!(oper.send(&s3, ()).is_ok()), in fairness2()
1188 let oper = sel.select(); in fairness2() localVariable
1189 match oper.index() { in fairness2()
1191 oper.recv(&r1).unwrap(); in fairness2()
1195 oper.recv(&r2).unwrap(); in fairness2()
1199 oper.recv(&r3).unwrap(); in fairness2()
1225 let oper = sel.select(); in sync_and_clone() localVariable
1226 match oper.index() { in sync_and_clone()
1227 ix if ix == oper1 => assert_ne!(oper.recv(&r), Ok(i)), in sync_and_clone()
1228 ix if ix == oper2 => assert!(oper.send(&s, i).is_ok()), in sync_and_clone()
1253 let oper = sel.select(); in send_and_clone() localVariable
1254 match oper.index() { in send_and_clone()
1255 ix if ix == oper1 => assert_ne!(oper.recv(&r), Ok(i)), in send_and_clone()
1256 ix if ix == oper2 => assert!(oper.send(&s, i).is_ok()), in send_and_clone()
1290 let oper = sel.select(); in reuse() localVariable
1291 match oper.index() { in reuse()
1292 ix if ix == oper1 => assert_eq!(oper.recv(&r1), Ok(i)), in reuse()
1293 ix if ix == oper2 => assert!(oper.send(&s2, i).is_ok()), in reuse()