Lines Matching refs:dgram_send_queue
924 dgram_send_queue: dgram::DatagramQueue, field
1236 dgram_send_queue: dgram::DatagramQueue::new( in with_tls()
2325 while let Some(len) = self.dgram_send_queue.peek_front_len() { in send()
2328 match self.dgram_send_queue.pop() { in send()
2347 self.dgram_send_queue.pop(); in send()
2580 if self.dgram_send_queue.byte_size() > self.recovery.cwnd_available() { in send()
3156 self.dgram_send_queue.push(buf)?; in dgram_send()
3158 if self.dgram_send_queue.byte_size() > self.recovery.cwnd_available() { in dgram_send()
3180 self.dgram_send_queue.purge(f); in dgram_purge_outgoing()
3521 self.dgram_send_queue.has_pending() || in write_epoch()
7505 assert_eq!(pipe.client.dgram_send_queue.byte_size(), 1_000_000); in dgram_send_app_limited()
7509 assert_ne!(pipe.client.dgram_send_queue.byte_size(), 0); in dgram_send_app_limited()
7510 assert_ne!(pipe.client.dgram_send_queue.byte_size(), 1_000_000); in dgram_send_app_limited()
7516 assert_ne!(pipe.client.dgram_send_queue.byte_size(), 0); in dgram_send_app_limited()
7517 assert_ne!(pipe.client.dgram_send_queue.byte_size(), 1_000_000); in dgram_send_app_limited()