Lines Matching refs:pkt_num_spaces
1219 pkt_num_spaces: [packet::PktNumSpace; packet::Epoch::count()], field
1715 pkt_num_spaces: [ in with_tls()
1876 conn.pkt_num_spaces[packet::Epoch::Initial].crypto_open = in with_tls()
1878 conn.pkt_num_spaces[packet::Epoch::Initial].crypto_seal = in with_tls()
2143 if self.pkt_num_spaces[packet::Epoch::Application] in process_undecrypted_0rtt_packets()
2307 self.pkt_num_spaces[packet::Epoch::Initial].crypto_open = in recv_single()
2309 self.pkt_num_spaces[packet::Epoch::Initial].crypto_seal = in recv_single()
2372 self.pkt_num_spaces[packet::Epoch::Initial].crypto_open = in recv_single()
2374 self.pkt_num_spaces[packet::Epoch::Initial].crypto_seal = in recv_single()
2436 self.pkt_num_spaces[packet::Epoch::Initial].crypto_open = in recv_single()
2438 self.pkt_num_spaces[packet::Epoch::Initial].crypto_seal = in recv_single()
2450 self.pkt_num_spaces[epoch].crypto_0rtt_open.as_ref() in recv_single()
2453 self.pkt_num_spaces[epoch].crypto_open.as_ref() in recv_single()
2495 self.pkt_num_spaces[epoch].largest_rx_pkt_num, in recv_single()
2522 if let Some(key_update) = self.pkt_num_spaces[epoch] in recv_single()
2534 self.pkt_num_spaces[epoch] in recv_single()
2539 self.pkt_num_spaces[epoch] in recv_single()
2563 if self.pkt_num_spaces[epoch].recv_pkt_num.contains(pn) { in recv_single()
2586 if !self.pkt_num_spaces[epoch] in recv_single()
2597 let _ = self.pkt_num_spaces[epoch].crypto_seal.replace(seal_next); in recv_single()
2599 let open_prev = self.pkt_num_spaces[epoch] in recv_single()
2606 self.pkt_num_spaces[epoch].key_update = Some(packet::KeyUpdate { in recv_single()
2787 self.pkt_num_spaces[epoch] in recv_single()
2794 self.pkt_num_spaces[epoch] in recv_single()
2895 if self.pkt_num_spaces[epoch].recv_pkt_need_ack.last() < Some(pn) { in recv_single()
2896 self.pkt_num_spaces[epoch].largest_rx_pkt_time = now; in recv_single()
2899 self.pkt_num_spaces[epoch].recv_pkt_num.insert(pn); in recv_single()
2901 self.pkt_num_spaces[epoch].recv_pkt_need_ack.push_item(pn); in recv_single()
2903 self.pkt_num_spaces[epoch].ack_elicited = in recv_single()
2904 cmp::max(self.pkt_num_spaces[epoch].ack_elicited, ack_elicited); in recv_single()
2906 self.pkt_num_spaces[epoch].largest_rx_pkt_num = in recv_single()
2907 cmp::max(self.pkt_num_spaces[epoch].largest_rx_pkt_num, pn); in recv_single()
2910 self.pkt_num_spaces[epoch].largest_rx_non_probing_pkt_num = cmp::max( in recv_single()
2911 self.pkt_num_spaces[epoch].largest_rx_non_probing_pkt_num, in recv_single()
2920 self.pkt_num_spaces[epoch].largest_rx_non_probing_pkt_num == pn in recv_single()
3256 let pkt_space = &mut self.pkt_num_spaces[epoch]; in send_single()
3363 let pkt_space = &mut self.pkt_num_spaces[epoch]; in send_single()
4267 has_handshake_keys: self.pkt_num_spaces[packet::Epoch::Handshake] in send_single()
5423 self.pkt_num_spaces[packet::Epoch::Application] in dgram_max_writable_len()
5469 let key_update_timer = self.pkt_num_spaces in timeout_instant()
5536 if let Some(timer) = self.pkt_num_spaces[packet::Epoch::Application] in on_timeout()
5543 let _ = self.pkt_num_spaces[packet::Epoch::Application] in on_timeout()
6374 pkt_num_spaces: &mut self.pkt_num_spaces, in do_handshake()
6482 if self.pkt_num_spaces[packet::Epoch::Initial] in write_pkt_type()
6497 if self.pkt_num_spaces[epoch].crypto_seal.is_none() { in write_pkt_type()
6502 if self.pkt_num_spaces[epoch].ready() { in write_pkt_type()
6721 self.pkt_num_spaces[epoch].crypto_stream.recv.write(data)?; in process_frame()
6729 let stream = &mut self.pkt_num_spaces[epoch].crypto_stream; in process_frame()
7024 if self.pkt_num_spaces[epoch].crypto_open.is_none() { in drop_epoch_state()
7028 self.pkt_num_spaces[epoch].crypto_open = None; in drop_epoch_state()
7029 self.pkt_num_spaces[epoch].crypto_seal = None; in drop_epoch_state()
7030 self.pkt_num_spaces[epoch].clear(); in drop_epoch_state()
7099 has_handshake_keys: self.pkt_num_spaces[packet::Epoch::Handshake] in handshake_status()
8196 &mut self.client.pkt_num_spaces[packet::Epoch::Application]; in client_update_key()
8309 let space = &mut conn.pkt_num_spaces[epoch]; in encode_pkt()
8388 let aead = conn.pkt_num_spaces[epoch].crypto_open.as_ref().unwrap(); in decode_pkt()
8395 conn.pkt_num_spaces[epoch].largest_rx_pkt_num, in decode_pkt()
9224 pipe.server.pkt_num_spaces[packet::Epoch::Application] in update_key_request()
10176 pipe.server.pkt_num_spaces[packet::Epoch::Application] in early_1rtt_packet()
10187 pipe.server.pkt_num_spaces[packet::Epoch::Application] in early_1rtt_packet()
11210 let space = &mut pipe.client.pkt_num_spaces[epoch]; in invalid_initial_payload()
12419 assert_eq!(pipe.server.pkt_num_spaces[epoch].recv_pkt_need_ack.len(), 0); in limit_ack_ranges()
12430 last_packet_sent = pipe.client.pkt_num_spaces[epoch].next_pkt_num; in limit_ack_ranges()
12438 pipe.client.pkt_num_spaces[epoch].next_pkt_num += 1; in limit_ack_ranges()
12442 pipe.server.pkt_num_spaces[epoch].recv_pkt_need_ack.len(), in limit_ack_ranges()
12447 pipe.server.pkt_num_spaces[epoch].recv_pkt_need_ack.first(), in limit_ack_ranges()
12452 pipe.server.pkt_num_spaces[epoch].recv_pkt_need_ack.last(), in limit_ack_ranges()