Searched refs:local_epoch (Results 1 – 4 of 4) sorted by relevance
| /webrtc/dtls/src/ |
| H A D | state.rs | 21 pub(crate) local_epoch: Arc<AtomicU16>, field
54 local_epoch: u16, field
70 local_epoch: Arc::new(AtomicU16::new(0)), in default()
132 let local_epoch = self.local_epoch.load(Ordering::SeqCst); in serialize() localVariable
136 lsn[local_epoch as usize] in serialize()
147 local_epoch, in serialize()
163 self.local_epoch in deserialize()
164 .store(serialized.local_epoch, Ordering::SeqCst); in deserialize()
169 while lsn.len() <= serialized.local_epoch as usize { in deserialize()
172 lsn[serialized.local_epoch as usize] = serialized.sequence_number; in deserialize()
[all …]
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 321 let local_epoch = Arc::clone(&c.state.local_epoch); in new() localVariable
357 &local_epoch, in new()
751 local_epoch: &Arc<AtomicU16>, in read_and_buffer()
766 local_epoch.load(Ordering::SeqCst), in read_and_buffer()
818 … DTLSConn::handle_queued_packets(ctx, local_epoch, handshake_completed_successfully, pkts).await?; in read_and_buffer()
834 local_epoch: &Arc<AtomicU16>, in handle_queued_packets()
847 local_epoch.load(Ordering::SeqCst), in handle_queued_packets()
1134 self.state.local_epoch.store(epoch, Ordering::SeqCst); in set_local_epoch()
1138 self.state.local_epoch.load(Ordering::SeqCst) in get_local_epoch()
|
| /webrtc/dtls/src/flight/ |
| H A D | flight1.rs | 125 state.local_epoch.store(zero_epoch, Ordering::SeqCst); in generate()
|
| H A D | flight0.rs | 194 state.local_epoch.store(zero_epoch, Ordering::SeqCst); in generate()
|