Lines Matching refs:recv_count
674 let mut recv_count = 0; in stress_recv_timeout_two_threads() localVariable
679 recv_count += 1; in stress_recv_timeout_two_threads()
686 assert_eq!(recv_count, stress); in stress_recv_timeout_two_threads()
718 let mut recv_count = 0; in stress_recv_timeout_shared() localVariable
723 recv_count += 1; in stress_recv_timeout_shared()
730 assert_eq!(recv_count, stress); in stress_recv_timeout_shared()
1104 let mut recv_count = 0; in stress_recv_timeout_two_threads() localVariable
1109 recv_count += 1; in stress_recv_timeout_two_threads()
1116 assert_eq!(recv_count, 10000); in stress_recv_timeout_two_threads()
1128 let mut recv_count = 0; in stress_recv_timeout_shared() localVariable
1133 recv_count += 1; in stress_recv_timeout_shared()
1140 assert_eq!(recv_count, AMT * NTHREADS); in stress_recv_timeout_shared()