Lines Matching refs:recv
27 recv(r1) -> v => assert_eq!(v, Ok(1)), in smoke1()
28 recv(r2) -> _ => panic!(), in smoke1()
34 recv(r1) -> _ => panic!(), in smoke1()
35 recv(r2) -> v => assert_eq!(v, Ok(2)), in smoke1()
50 recv(r1) -> _ => panic!(), in smoke2()
51 recv(r2) -> _ => panic!(), in smoke2()
52 recv(r3) -> _ => panic!(), in smoke2()
53 recv(r4) -> _ => panic!(), in smoke2()
54 recv(r5) -> v => assert_eq!(v, Ok(5)), in smoke2()
71 recv(r1) -> v => assert!(v.is_err()), in disconnected()
72 recv(r2) -> _ => panic!(), in disconnected()
76 r2.recv().unwrap(); in disconnected()
81 recv(r1) -> v => assert!(v.is_err()), in disconnected()
82 recv(r2) -> _ => panic!(), in disconnected()
93 recv(r2) -> v => assert!(v.is_err()), in disconnected()
106 recv(r1) -> _ => panic!(), in default()
107 recv(r2) -> _ => panic!(), in default()
114 recv(r1) -> v => assert!(v.is_err()), in default()
115 recv(r2) -> _ => panic!(), in default()
122 recv(r2) -> v => assert_eq!(v, Ok(2)), in default()
127 recv(r2) -> _ => panic!(), in default()
148 recv(r1) -> _ => panic!(), in timeout()
149 recv(r2) -> _ => panic!(), in timeout()
154 recv(r1) -> _ => panic!(), in timeout()
155 recv(r2) -> v => assert_eq!(v, Ok(2)), in timeout()
172 recv(r) -> v => assert!(v.is_err()), in timeout()
186 recv(r) -> res => assert!(res.is_err()), in default_when_disconnected()
193 recv(r) -> res => assert!(res.is_err()), in default_when_disconnected()
242 recv(r1) -> _ => panic!(), in unblocks()
243 recv(r2) -> v => assert_eq!(v, Ok(2)), in unblocks()
252 assert_eq!(r1.recv().unwrap(), 1); in unblocks()
273 assert_eq!(r2.recv().unwrap(), 2); in both_ready()
278 recv(r1) -> v => assert_eq!(v, Ok(1)), in both_ready()
303 recv(r_end) -> _ => break, in loop_try()
315 recv(r_end) -> _ => break, in loop_try()
324 recv(r1) -> v => assert_eq!(v, Ok(1)), in loop_try()
344 r3.recv().unwrap(); in cloning1()
348 r3.recv().unwrap(); in cloning1()
354 recv(r1) -> _ => {}, in cloning1()
355 recv(r2) -> _ => {}, in cloning1()
372 recv(r1) -> _ => panic!(), in cloning2()
373 recv(r2) -> _ => {}, in cloning2()
390 recv(r) -> _ => {} in preflight1()
402 recv(r) -> v => assert!(v.is_ok()), in preflight2()
413 r.recv().unwrap(); in preflight3()
416 recv(r) -> v => assert!(v.is_err()) in preflight3()
427 recv(r) -> _ => hit[0] = true, in duplicate_operations()
428 recv(r) -> _ => hit[1] = true, in duplicate_operations()
442 recv(r) -> v => { in nesting()
447 recv(r) -> v => { in nesting()
482 recv(get()) -> _ => {} in panic_receiver()
498 r3.recv().unwrap(); in stress_recv()
501 r3.recv().unwrap(); in stress_recv()
508 recv(r1) -> v => assert_eq!(v, Ok(i)), in stress_recv()
509 recv(r2) -> v => assert_eq!(v, Ok(i)), in stress_recv()
530 assert_eq!(r1.recv().unwrap(), i); in stress_send()
531 assert_eq!(r2.recv().unwrap(), i); in stress_send()
532 r3.recv().unwrap(); in stress_send()
561 assert_eq!(r2.recv().unwrap(), i); in stress_mixed()
562 r3.recv().unwrap(); in stress_mixed()
569 recv(r1) -> v => assert_eq!(v, Ok(i)), in stress_mixed()
609 recv(r) -> v => { in stress_timeout_two_threads()
627 recv(r) -> _ => panic!(), in send_recv_same_channel()
634 recv(r) -> _ => panic!(), in send_recv_same_channel()
649 recv(r) -> v => assert_ne!(v.unwrap(), i), in matching()
670 recv(r) -> v => assert_ne!(v.unwrap(), i), in matching_with_leftover()
712 recv(r) -> msg => { in channel_through_channel()
748 recv(r1) -> _ => {} in linearizable_default()
749 recv(r2) -> _ => {} in linearizable_default()
759 start_r.recv().unwrap(); in linearizable_default()
764 end_r.recv().unwrap(); in linearizable_default()
792 recv(r1) -> _ => {} in linearizable_timeout()
793 recv(r2) -> _ => {} in linearizable_timeout()
803 start_r.recv().unwrap(); in linearizable_timeout()
808 end_r.recv().unwrap(); in linearizable_timeout()
830 recv(r1) -> _ => hits[0] += 1, in fairness1()
831 recv(r2) -> _ => hits[1] += 1, in fairness1()
832 recv(after(ms(0))) -> _ => hits[2] += 1, in fairness1()
833 recv(tick(ms(0))) -> _ => hits[3] += 1, in fairness1()
866 recv(r1) -> _ => hits[0].set(hits[0].get() + 1), in fairness2()
867 recv(r2) -> _ => hits[1].set(hits[1].get() + 1), in fairness2()
868 recv(r3) -> _ => hits[2].set(hits[2].get() + 1), in fairness2()
891 recv(r1) -> _ => hits[0] += 1, in fairness_recv()
892 recv(r2) -> _ => hits[1] += 1, in fairness_recv()
920 recv(r) -> _ => {} in references()
924 recv(&&&&r) -> _ => {} in references()
927 recv(Some(&r).unwrap_or(&never())) -> _ => {}, in references()
931 recv(Some(r).unwrap_or(never())) -> _ => {}, in references()
941 recv(r) -> _ => 3.0, in case_blocks()
942 recv(r) -> _ => loop { in case_blocks()
945 recv(r) -> _ => match 7 + 3 { in case_blocks()
952 recv(r) -> msg => if msg.is_ok() { in case_blocks()
965 recv((move || r)()) -> _ => {} in move_handles()
974 recv(r) -> _ => {} in infer_types()
983 r.recv().unwrap(); in infer_types()
991 recv(r) -> _ => panic!(), in default_syntax()
1010 recv(r) -> r => assert!(r.is_err()), in same_variable_name()
1021 recv(*r) -> _ => {} in handles_on_heap()
1040 recv(r) -> _ => drop(once), in once_blocks()
1053 recv(r) -> _ => drop(once1), in once_blocks()
1060 recv(r) -> _ => drop(once1), in once_blocks()
1076 recv(get()) -> _ => {} in once_receiver()
1100 recv(r) -> _ => {} in parse_nesting()
1101 recv(r) -> _ => { in parse_nesting()
1103 recv(r) -> _ => {} in parse_nesting()
1104 recv(r) -> _ => { in parse_nesting()
1106 recv(r) -> _ => {} in parse_nesting()
1107 recv(r) -> _ => { in parse_nesting()
1124 recv(r) -> _ => "foo".into(), in evaluate()
1131 recv(r) -> _ => "foo".into(), in evaluate()
1137 recv(r) -> _ => "foo".into(), in evaluate()
1171 recv(r) -> _ => panic!(), in deref()
1182 recv(r) -> res => drop::<Result<i32, RecvError>>(res), in result_types()
1185 recv(r) -> res => drop::<Result<i32, RecvError>>(res), in result_types()
1189 recv(r) -> res => drop::<Result<i32, RecvError>>(res), in result_types()
1207 recv(r) -> res => drop::<Result<i32, RecvError>>(res), in result_types()
1218 recv(r) -> _ => panic!(), in try_recv()
1223 recv(r) -> v => assert_eq!(v, Ok(7)), in try_recv()
1228 recv(r) -> v => assert_eq!(v, Err(RecvError)), in try_recv()
1243 fn recv() { in recv() function
1249 recv(r) -> v => assert_eq!(v, Ok(7)), in recv()
1253 recv(r) -> v => assert_eq!(v, Ok(8)), in recv()
1257 recv(r) -> v => assert_eq!(v, Ok(9)), in recv()
1260 recv(r) -> v => assert_eq!(v, Err(RecvError)), in recv()
1286 recv(r) -> _ => panic!(), in recv_timeout()
1290 recv(r) -> v => assert_eq!(v, Ok(7)), in recv_timeout()
1294 recv(r) -> v => assert_eq!(v, Err(RecvError)), in recv_timeout()
1332 recv(r) -> v => assert_eq!(v, Ok(8)), in try_send()
1360 recv(r) -> v => assert_eq!(v, Ok(7)), in send()
1363 recv(r) -> v => assert_eq!(v, Ok(8)), in send()
1366 recv(r) -> v => assert_eq!(v, Ok(9)), in send()
1395 recv(r) -> v => assert_eq!(v, Ok(8)), in send_timeout()
1427 recv(r) -> res => assert_eq!(res, Err(RecvError)), in disconnect_wakes_receiver()