Searched refs:recv_count (Results 1 – 2 of 2) sorted by relevance
| /external/rust/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 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
[all …]
|
| /external/rust/crates/quiche/src/ |
| D | lib.rs | 807 recv_count: usize, field
1159 recv_count: 0, in with_tls()
1456 self.recv_count, in recv_single()
1475 if self.recv_count > 0 { in recv_single()
1616 self.recv_count, in recv_single()
1656 self.recv_count, in recv_single()
1665 drop_pkt_on_err(e, self.recv_count, self.is_server, &self.trace_id) in recv_single()
1716 drop_pkt_on_err(e, self.recv_count, self.is_server, &self.trace_id) in recv_single()
1867 self.recv_count += 1; in recv_single()
3361 if self.recv_count == 0 { in close()
[all …]
|