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()
815 let oper = sel.select_timeout(ms(100)); in stress_timeout_two_threads() localVariable
816 match oper { in stress_timeout_two_threads()
818 Ok(oper) => match oper.index() { in stress_timeout_two_threads()
820 assert!(oper.send(&s, i).is_ok()); in stress_timeout_two_threads()
839 let oper = sel.select_timeout(ms(100)); in stress_timeout_two_threads() localVariable
840 match oper { in stress_timeout_two_threads()
842 Ok(oper) => match oper.index() { in stress_timeout_two_threads()
844 assert_eq!(oper.recv(&r), Ok(i)); in stress_timeout_two_threads()
863 let oper = sel.select_timeout(ms(100)); in send_recv_same_channel() localVariable
864 match oper { in send_recv_same_channel()
866 Ok(oper) => match oper.index() { in send_recv_same_channel()
877 let oper = sel.select_timeout(ms(100)); in send_recv_same_channel() localVariable
878 match oper { in send_recv_same_channel()
880 Ok(oper) => match oper.index() { in send_recv_same_channel()
881 ix if ix == oper1 => assert!(oper.send(&s, 0).is_ok()), in send_recv_same_channel()
900 let oper = sel.select(); in matching() localVariable
901 match oper.index() { in matching()
902 ix if ix == oper1 => assert_ne!(oper.recv(&r), Ok(i)), in matching()
903 ix if ix == oper2 => assert!(oper.send(&s, i).is_ok()), in matching()
926 let oper = sel.select(); in matching_with_leftover() localVariable
927 match oper.index() { in matching_with_leftover()
928 ix if ix == oper1 => assert_ne!(oper.recv(&r), Ok(i)), in matching_with_leftover()
929 ix if ix == oper2 => assert!(oper.send(&s, i).is_ok()), in matching_with_leftover()
961 let oper = sel.select(); in channel_through_channel() localVariable
962 match oper.index() { in channel_through_channel()
963 ix if ix == oper1 => assert!(oper.send(&s, new_r).is_ok()), in channel_through_channel()
979 let oper = sel.select(); in channel_through_channel() localVariable
980 match oper.index() { in channel_through_channel()
981 ix if ix == oper1 => oper in channel_through_channel()
1023 let oper = sel.try_select(); in linearizable_try() localVariable
1024 match oper { in linearizable_try()
1026 Ok(oper) => match oper.index() { in linearizable_try()
1027 ix if ix == oper1 => assert!(oper.recv(&r1).is_ok()), in linearizable_try()
1028 ix if ix == oper2 => assert!(oper.recv(&r2).is_ok()), in linearizable_try()
1075 let oper = sel.select_timeout(ms(0)); in linearizable_timeout() localVariable
1076 match oper { in linearizable_timeout()
1078 Ok(oper) => match oper.index() { in linearizable_timeout()
1079 ix if ix == oper1 => assert!(oper.recv(&r1).is_ok()), in linearizable_timeout()
1080 ix if ix == oper2 => assert!(oper.recv(&r2).is_ok()), in linearizable_timeout()
1125 let oper = sel.select(); in fairness1() localVariable
1126 match oper.index() { in fairness1()
1128 oper.recv(&r1).unwrap(); in fairness1()
1132 oper.recv(&r2).unwrap(); in fairness1()
1136 oper.recv(&after).unwrap(); in fairness1()
1140 oper.recv(&tick).unwrap(); in fairness1()
1170 let oper = sel.select(); in fairness2() localVariable
1171 match oper.index() { in fairness2()
1172 i if Some(i) == oper1 => assert!(oper.send(&s1, ()).is_ok()), in fairness2()
1173 i if Some(i) == oper2 => assert!(oper.send(&s2, ()).is_ok()), in fairness2()
1174 i if i == oper3 => assert!(oper.send(&s3, ()).is_ok()), in fairness2()
1186 let oper = sel.select(); in fairness2() localVariable
1187 match oper.index() { in fairness2()
1189 oper.recv(&r1).unwrap(); in fairness2()
1193 oper.recv(&r2).unwrap(); in fairness2()
1197 oper.recv(&r3).unwrap(); in fairness2()
1223 let oper = sel.select(); in sync_and_clone() localVariable
1224 match oper.index() { in sync_and_clone()
1225 ix if ix == oper1 => assert_ne!(oper.recv(&r), Ok(i)), in sync_and_clone()
1226 ix if ix == oper2 => assert!(oper.send(&s, i).is_ok()), in sync_and_clone()
1251 let oper = sel.select(); in send_and_clone() localVariable
1252 match oper.index() { in send_and_clone()
1253 ix if ix == oper1 => assert_ne!(oper.recv(&r), Ok(i)), in send_and_clone()
1254 ix if ix == oper2 => assert!(oper.send(&s, i).is_ok()), in send_and_clone()
1288 let oper = sel.select(); in reuse() localVariable
1289 match oper.index() { in reuse()
1290 ix if ix == oper1 => assert_eq!(oper.recv(&r1), Ok(i)), in reuse()
1291 ix if ix == oper2 => assert!(oper.send(&s2, i).is_ok()), in reuse()