Lines Matching refs:pkt_num_spaces
789 pkt_num_spaces: [packet::PktNumSpace; packet::EPOCH_COUNT], field
1143 pkt_num_spaces: [ in with_tls()
1272 conn.pkt_num_spaces[packet::EPOCH_INITIAL].crypto_open = in with_tls()
1274 conn.pkt_num_spaces[packet::EPOCH_INITIAL].crypto_seal = in with_tls()
1526 self.pkt_num_spaces[packet::EPOCH_INITIAL].crypto_open = in recv_single()
1528 self.pkt_num_spaces[packet::EPOCH_INITIAL].crypto_seal = in recv_single()
1581 self.pkt_num_spaces[packet::EPOCH_INITIAL].crypto_open = in recv_single()
1583 self.pkt_num_spaces[packet::EPOCH_INITIAL].crypto_seal = in recv_single()
1631 self.pkt_num_spaces[packet::EPOCH_INITIAL].crypto_open = in recv_single()
1633 self.pkt_num_spaces[packet::EPOCH_INITIAL].crypto_seal = in recv_single()
1644 let aead = (self.pkt_num_spaces[epoch].crypto_0rtt_open.as_ref()) in recv_single()
1648 .or(self.pkt_num_spaces[epoch].crypto_open.as_ref()) in recv_single()
1669 self.pkt_num_spaces[epoch].largest_rx_pkt_num, in recv_single()
1719 if self.pkt_num_spaces[epoch].recv_pkt_num.contains(pn) { in recv_single()
1815 self.pkt_num_spaces[epoch] in recv_single()
1822 self.pkt_num_spaces[epoch] in recv_single()
1849 if self.pkt_num_spaces[epoch].recv_pkt_need_ack.last() < Some(pn) { in recv_single()
1850 self.pkt_num_spaces[epoch].largest_rx_pkt_time = now; in recv_single()
1853 self.pkt_num_spaces[epoch].recv_pkt_num.insert(pn); in recv_single()
1855 self.pkt_num_spaces[epoch].recv_pkt_need_ack.push_item(pn); in recv_single()
1857 self.pkt_num_spaces[epoch].ack_elicited = in recv_single()
1858 cmp::max(self.pkt_num_spaces[epoch].ack_elicited, ack_elicited); in recv_single()
1860 self.pkt_num_spaces[epoch].largest_rx_pkt_num = in recv_single()
1861 cmp::max(self.pkt_num_spaces[epoch].largest_rx_pkt_num, pn); in recv_single()
1969 self.pkt_num_spaces[epoch].crypto_stream.send.push(data)?; in send()
2002 self.pkt_num_spaces[epoch].ack_elicited = true; in send()
2037 let pn = self.pkt_num_spaces[epoch].next_pkt_num; in send()
2041 let crypto_overhead = self.pkt_num_spaces[epoch] in send()
2111 if self.pkt_num_spaces[epoch].recv_pkt_need_ack.len() > 0 && in send()
2112 (self.pkt_num_spaces[epoch].ack_elicited || in send()
2117 self.pkt_num_spaces[epoch].largest_rx_pkt_time.elapsed(); in send()
2125 ranges: self.pkt_num_spaces[epoch].recv_pkt_need_ack.clone(), in send()
2129 self.pkt_num_spaces[epoch].ack_elicited = false; in send()
2300 if self.pkt_num_spaces[epoch].crypto_stream.is_flushable() && in send()
2305 let crypto_buf = self.pkt_num_spaces[epoch] in send()
2533 let aead = match self.pkt_num_spaces[epoch].crypto_seal { in send()
2576 self.pkt_num_spaces[epoch].next_pkt_num += 1; in send()
3216 self.pkt_num_spaces[packet::EPOCH_APPLICATION] in dgram_max_writable_len()
3496 if self.pkt_num_spaces[epoch].crypto_seal.is_none() { in write_epoch()
3501 if self.pkt_num_spaces[epoch].ready() { in write_epoch()
3641 self.pkt_num_spaces[epoch].crypto_stream.recv.push(data)?; in process_frame()
3649 let stream = &mut self.pkt_num_spaces[epoch].crypto_stream; in process_frame()
3920 if self.pkt_num_spaces[epoch].crypto_open.is_none() { in drop_epoch_state()
3924 self.pkt_num_spaces[epoch].crypto_open = None; in drop_epoch_state()
3925 self.pkt_num_spaces[epoch].crypto_seal = None; in drop_epoch_state()
3926 self.pkt_num_spaces[epoch].clear(); in drop_epoch_state()
3987 has_handshake_keys: self.pkt_num_spaces[packet::EPOCH_HANDSHAKE] in handshake_status()
4667 let space = &mut conn.pkt_num_spaces[epoch]; in encode_pkt()
4730 let aead = conn.pkt_num_spaces[epoch].crypto_open.as_ref().unwrap(); in decode_pkt()
4737 conn.pkt_num_spaces[epoch].largest_rx_pkt_num, in decode_pkt()
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()
6144 let space = &mut pipe.client.pkt_num_spaces[epoch]; in invalid_initial_payload()
6942 assert_eq!(pipe.server.pkt_num_spaces[epoch].recv_pkt_need_ack.len(), 0); in limit_ack_ranges()
6953 last_packet_sent = pipe.client.pkt_num_spaces[epoch].next_pkt_num; in limit_ack_ranges()
6961 pipe.client.pkt_num_spaces[epoch].next_pkt_num += 1; in limit_ack_ranges()
6965 pipe.server.pkt_num_spaces[epoch].recv_pkt_need_ack.len(), in limit_ack_ranges()
6970 pipe.server.pkt_num_spaces[epoch].recv_pkt_need_ack.first(), in limit_ack_ranges()
6975 pipe.server.pkt_num_spaces[epoch].recv_pkt_need_ack.last(), in limit_ack_ranges()