• Home
  • Raw
  • Download

Lines Matching refs:recv

24     sel.recv(&r1);  in smoke1()
25 sel.recv(&r2); in smoke1()
32 sel.recv(&r1); in smoke1()
33 sel.recv(&r2); in smoke1()
49 sel.recv(&r1); in smoke2()
50 sel.recv(&r2); in smoke2()
51 sel.recv(&r3); in smoke2()
52 sel.recv(&r4); in smoke2()
53 sel.recv(&r5); in smoke2()
71 sel.recv(&r1); in disconnected()
72 sel.recv(&r2); in disconnected()
78 r2.recv().unwrap(); in disconnected()
83 sel.recv(&r1); in disconnected()
84 sel.recv(&r2); in disconnected()
97 sel.recv(&r2); in disconnected()
112 sel.recv(&r1); in default()
113 sel.recv(&r2); in default()
119 sel.recv(&r1); in default()
120 sel.recv(&r2); in default()
129 sel.recv(&r2); in default()
136 sel.recv(&r2); in default()
155 sel.recv(&r1); in timeout()
156 sel.recv(&r2); in timeout()
160 sel.recv(&r1); in timeout()
161 sel.recv(&r2); in timeout()
181 sel.recv(&r); in timeout()
195 sel.recv(&r); in default_when_disconnected()
204 sel.recv(&r); in default_when_disconnected()
258 sel.recv(&r1); in unblocks()
259 sel.recv(&r2); in unblocks()
270 assert_eq!(r1.recv().unwrap(), 1); in unblocks()
298 assert_eq!(r2.recv().unwrap(), 2); in both_ready()
303 sel.recv(&r1); in both_ready()
323 r3.recv().unwrap(); in cloning1()
327 r3.recv().unwrap(); in cloning1()
333 sel.recv(&r1); in cloning1()
334 sel.recv(&r2); in cloning1()
355 sel.recv(&r1); in cloning2()
356 sel.recv(&r2); in cloning2()
377 sel.recv(&r); in preflight1()
392 sel.recv(&r); in preflight2()
407 r.recv().unwrap(); in preflight3()
410 sel.recv(&r); in preflight3()
424 sel.recv(&r); in duplicate_operations()
425 sel.recv(&r); in duplicate_operations()
461 sel.recv(&r); in nesting()
473 sel.recv(&r); in nesting()
503 r3.recv().unwrap(); in stress_recv()
506 r3.recv().unwrap(); in stress_recv()
513 sel.recv(&r1); in stress_recv()
514 sel.recv(&r2); in stress_recv()
539 assert_eq!(r1.recv().unwrap(), i); in stress_send()
540 assert_eq!(r2.recv().unwrap(), i); in stress_send()
541 r3.recv().unwrap(); in stress_send()
574 assert_eq!(r2.recv().unwrap(), i); in stress_mixed()
575 r3.recv().unwrap(); in stress_mixed()
582 sel.recv(&r1); in stress_mixed()
634 sel.recv(&r); in stress_timeout_two_threads()
655 sel.recv(&r); in send_recv_same_channel()
661 sel.recv(&r); in send_recv_same_channel()
705 sel.recv(&r); in channel_through_channel()
743 sel.recv(&r1); in fairness1()
744 sel.recv(&r2); in fairness1()
745 sel.recv(&after); in fairness1()
746 sel.recv(&tick); in fairness1()
804 sel.recv(&r1); in fairness2()
805 sel.recv(&r2); in fairness2()
806 sel.recv(&r3); in fairness2()