Home
last modified time | relevance | path

Searched refs:EPOCH_APPLICATION (Results 1 – 7 of 7) sorted by relevance

/external/rust/crates/quiche/src/recovery/
Dmod.rs229 epoch == packet::EPOCH_APPLICATION && in on_packet_sent()
329 let ack_delay = if epoch == packet::EPOCH_APPLICATION { in on_ack_received()
551 if e == packet::EPOCH_APPLICATION { in pto_time_and_space()
1009 assert_eq!(r.sent[packet::EPOCH_APPLICATION].len(), 0); in loss_on_pto()
1030 packet::EPOCH_APPLICATION, in loss_on_pto()
1035 assert_eq!(r.sent[packet::EPOCH_APPLICATION].len(), 1); in loss_on_pto()
1056 packet::EPOCH_APPLICATION, in loss_on_pto()
1061 assert_eq!(r.sent[packet::EPOCH_APPLICATION].len(), 2); in loss_on_pto()
1082 packet::EPOCH_APPLICATION, in loss_on_pto()
1087 assert_eq!(r.sent[packet::EPOCH_APPLICATION].len(), 3); in loss_on_pto()
[all …]
Dreno.rs67 if r.hystart.enabled() && epoch == packet::EPOCH_APPLICATION { in on_packet_acked()
89 epoch == packet::EPOCH_APPLICATION && in on_packet_acked()
121 if r.hystart.enabled() && epoch == packet::EPOCH_APPLICATION { in congestion_event()
203 r.on_packets_acked(acked, packet::EPOCH_APPLICATION, now); in reno_slow_start()
220 r.congestion_event(now, packet::EPOCH_APPLICATION, now); in reno_congestion_event()
239 r.congestion_event(now, packet::EPOCH_APPLICATION, now); in reno_congestion_avoidance()
258 r.on_packets_acked(acked, packet::EPOCH_APPLICATION, now + rtt * 2); in reno_congestion_avoidance()
Dcubic.rs170 if r.hystart.enabled() && epoch == packet::EPOCH_APPLICATION { in on_packet_acked()
185 epoch == packet::EPOCH_APPLICATION && in on_packet_acked()
234 epoch == packet::EPOCH_APPLICATION && in on_packet_acked()
283 if r.hystart.enabled() && epoch == packet::EPOCH_APPLICATION { in congestion_event()
356 r.on_packets_acked(acked, packet::EPOCH_APPLICATION, now); in cubic_slow_start()
371 r.congestion_event(now, packet::EPOCH_APPLICATION, now); in cubic_congestion_event()
391 r.congestion_event(now, packet::EPOCH_APPLICATION, now); in cubic_congestion_avoidance()
408 r.on_packets_acked(acked, packet::EPOCH_APPLICATION, now + rtt * 3); in cubic_congestion_avoidance()
426 r.congestion_event(now, packet::EPOCH_APPLICATION, now); in cubic_collapse_cwnd_and_restart()
444 r.on_packets_acked(acked.clone(), packet::EPOCH_APPLICATION, now); in cubic_collapse_cwnd_and_restart()
[all …]
/external/rust/crates/quiche/src/
Dtls.rs572 &mut conn.pkt_num_spaces[packet::EPOCH_APPLICATION], in set_read_secret()
576 &mut conn.pkt_num_spaces[packet::EPOCH_APPLICATION], in set_read_secret()
622 &mut conn.pkt_num_spaces[packet::EPOCH_APPLICATION], in set_write_secret()
626 &mut conn.pkt_num_spaces[packet::EPOCH_APPLICATION], in set_write_secret()
676 &mut conn.pkt_num_spaces[packet::EPOCH_APPLICATION], in add_handshake_data()
Dpacket.rs55 pub const EPOCH_APPLICATION: usize = 2; constant
94 EPOCH_APPLICATION => Type::Short, in from_epoch()
104 Type::ZeroRTT => Ok(EPOCH_APPLICATION), in to_epoch()
108 Type::Short => Ok(EPOCH_APPLICATION), in to_epoch()
Dlib.rs3216 self.pkt_num_spaces[packet::EPOCH_APPLICATION] in dgram_max_writable_len()
3482 crypto::Level::OneRTT => packet::EPOCH_APPLICATION, in write_epoch()
3485 if epoch == packet::EPOCH_APPLICATION && !self.is_established() { in write_epoch()
3528 return Ok(packet::EPOCH_APPLICATION); in write_epoch()
3572 if epoch == packet::EPOCH_APPLICATION && self.is_established() { in process_frame()
5710 pipe.server.pkt_num_spaces[packet::EPOCH_APPLICATION] in early_1rtt_packet()
5721 pipe.server.pkt_num_spaces[packet::EPOCH_APPLICATION] in early_1rtt_packet()
6940 let epoch = packet::EPOCH_APPLICATION; in limit_ack_ranges()
7342 let epoch = packet::EPOCH_APPLICATION; in early_retransmit()
Dcrypto.rs51 packet::EPOCH_APPLICATION => Level::OneRTT, in from_epoch()