• Home
  • Raw
  • Download

Lines Matching refs:prr

104         let mut prr = PRR::default();  in congestion_event()  localVariable
107 prr.congestion_event(bytes_in_flight); in congestion_event()
109 assert_eq!(prr.recoverfs, bytes_in_flight); in congestion_event()
110 assert_eq!(prr.snd_cnt, 0); in congestion_event()
115 let mut prr = PRR::default(); in on_packet_sent() localVariable
119 prr.congestion_event(bytes_in_flight); in on_packet_sent()
121 prr.on_packet_sent(bytes_sent); in on_packet_sent()
123 assert_eq!(prr.prr_out, bytes_sent); in on_packet_sent()
124 assert_eq!(prr.snd_cnt, 0); in on_packet_sent()
129 let mut prr = PRR::default(); in on_packet_acked_prr() localVariable
135 prr.congestion_event(bytes_in_flight); in on_packet_acked_prr()
140 prr.on_packet_acked(acked, pipe, ssthresh, max_datagram_size); in on_packet_acked_prr()
142 assert_eq!(prr.snd_cnt, 500); in on_packet_acked_prr()
144 let snd_cnt = prr.snd_cnt; in on_packet_acked_prr()
147 prr.on_packet_sent(snd_cnt); in on_packet_acked_prr()
149 prr.on_packet_acked(acked, pipe, ssthresh, max_datagram_size); in on_packet_acked_prr()
151 assert_eq!(prr.snd_cnt, 500); in on_packet_acked_prr()
156 let mut prr = PRR::default(); in on_packet_acked_prr_overflow() localVariable
162 prr.congestion_event(bytes_in_flight); in on_packet_acked_prr_overflow()
164 prr.on_packet_sent(max_datagram_size); in on_packet_acked_prr_overflow()
169 prr.on_packet_acked(acked, pipe, ssthresh, max_datagram_size); in on_packet_acked_prr_overflow()
171 assert_eq!(prr.snd_cnt, 0); in on_packet_acked_prr_overflow()
176 let mut prr = PRR::default(); in on_packet_acked_prr_zero_in_flight() localVariable
182 prr.congestion_event(bytes_in_flight); in on_packet_acked_prr_zero_in_flight()
187 prr.on_packet_acked(acked, pipe, ssthresh, max_datagram_size); in on_packet_acked_prr_zero_in_flight()
189 assert_eq!(prr.snd_cnt, 0); in on_packet_acked_prr_zero_in_flight()
194 let mut prr = PRR::default(); in on_packet_acked_prr_ssrb() localVariable
200 prr.congestion_event(bytes_in_flight); in on_packet_acked_prr_ssrb()
205 prr.on_packet_acked(acked, pipe, ssthresh, max_datagram_size); in on_packet_acked_prr_ssrb()
207 assert_eq!(prr.snd_cnt, 2000); in on_packet_acked_prr_ssrb()
209 let snd_cnt = prr.snd_cnt; in on_packet_acked_prr_ssrb()
212 prr.on_packet_sent(snd_cnt); in on_packet_acked_prr_ssrb()
214 prr.on_packet_acked(acked, pipe, ssthresh, max_datagram_size); in on_packet_acked_prr_ssrb()
216 assert_eq!(prr.snd_cnt, 2000); in on_packet_acked_prr_ssrb()
221 let mut prr = PRR::default(); in on_packet_acked_prr_ssrb_overflow() localVariable
227 prr.congestion_event(bytes_in_flight); in on_packet_acked_prr_ssrb_overflow()
232 prr.on_packet_sent(max_datagram_size); in on_packet_acked_prr_ssrb_overflow()
234 prr.on_packet_acked(acked, pipe, ssthresh, max_datagram_size); in on_packet_acked_prr_ssrb_overflow()
236 assert_eq!(prr.snd_cnt, 1500); in on_packet_acked_prr_ssrb_overflow()