| /webrtc/dtls/src/handshake/handshake_cache/ |
| H A D | handshake_cache_test.rs | 11 epoch: 0, in test_handshake_cache_single_push()
17 epoch: 0, in test_handshake_cache_single_push()
29 epoch: 0, in test_handshake_cache_single_push()
36 epoch: 0, in test_handshake_cache_single_push()
43 epoch: 0, in test_handshake_cache_single_push()
51 epoch: 0, in test_handshake_cache_single_push()
57 epoch: 0, in test_handshake_cache_single_push()
63 epoch: 0, in test_handshake_cache_single_push()
76 epoch: 0, in test_handshake_cache_single_push()
83 epoch: 0, in test_handshake_cache_single_push()
[all …]
|
| /webrtc/dtls/src/handshake/ |
| H A D | handshake_cache.rs | 18 epoch: u16, field
26 pub(crate) epoch: u16, field
46 epoch: u16, in push()
62 epoch, in push()
168 epoch: u16, in session_hash()
178 epoch, in session_hash()
184 epoch, in session_hash()
190 epoch, in session_hash()
196 epoch, in session_hash()
202 epoch, in session_hash()
[all …]
|
| /webrtc/dtls/src/flight/ |
| H A D | flight6.rs | 39 epoch: cfg.initial_epoch + 1, in parse()
91 epoch: cfg.initial_epoch, in generate()
97 epoch: cfg.initial_epoch, in generate()
103 epoch: cfg.initial_epoch, in generate()
109 epoch: cfg.initial_epoch, in generate()
115 epoch: cfg.initial_epoch, in generate()
121 epoch: cfg.initial_epoch, in generate()
127 epoch: cfg.initial_epoch, in generate()
133 epoch: cfg.initial_epoch, in generate()
139 epoch: cfg.initial_epoch, in generate()
[all …]
|
| H A D | flight5.rs | 51 epoch: cfg.initial_epoch + 1, in parse()
79 epoch: cfg.initial_epoch, in parse()
85 epoch: cfg.initial_epoch, in parse()
91 epoch: cfg.initial_epoch, in parse()
97 epoch: cfg.initial_epoch, in parse()
103 epoch: cfg.initial_epoch, in parse()
109 epoch: cfg.initial_epoch, in parse()
115 epoch: cfg.initial_epoch, in parse()
121 epoch: cfg.initial_epoch, in parse()
127 epoch: cfg.initial_epoch, in parse()
[all …]
|
| H A D | flight3.rs | 56 epoch: cfg.initial_epoch, in parse()
104 epoch: cfg.initial_epoch, in parse()
110 epoch: cfg.initial_epoch, in parse()
116 epoch: cfg.initial_epoch, in parse()
130 epoch: cfg.initial_epoch, in parse()
136 epoch: cfg.initial_epoch, in parse()
142 epoch: cfg.initial_epoch, in parse()
148 epoch: cfg.initial_epoch, in parse()
154 epoch: cfg.initial_epoch, in parse()
|
| H A D | flight4.rs | 58 epoch: cfg.initial_epoch, in parse()
64 epoch: cfg.initial_epoch, in parse()
70 epoch: cfg.initial_epoch, in parse()
145 epoch: cfg.initial_epoch, in parse()
151 epoch: cfg.initial_epoch, in parse()
157 epoch: cfg.initial_epoch, in parse()
163 epoch: cfg.initial_epoch, in parse()
169 epoch: cfg.initial_epoch, in parse()
175 epoch: cfg.initial_epoch, in parse()
181 epoch: cfg.initial_epoch, in parse()
[all …]
|
| H A D | flight1.rs | 52 epoch: cfg.initial_epoch, in parse()
58 epoch: cfg.initial_epoch, in parse()
|
| H A D | flight2.rs | 40 epoch: cfg.initial_epoch, in parse()
|
| H A D | flight0.rs | 39 epoch: cfg.initial_epoch, in parse()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 596 let epoch = p.record.record_layer_header.epoch as usize; in process_packet() localVariable
603 lsn[epoch] += 1; in process_packet()
604 lsn[epoch] - 1 in process_packet()
643 let epoch = p.record.record_layer_header.epoch as usize; in process_handshake_packet() localVariable
653 lsn[epoch] - 1 in process_handshake_packet()
664 epoch: p.record.record_layer_header.epoch, in process_handshake_packet()
902 if h.epoch > epoch { in handle_incoming_packet()
903 if h.epoch > epoch + 1 { in handle_incoming_packet()
907 h.epoch, in handle_incoming_packet()
936 h.epoch, in handle_incoming_packet()
[all …]
|
| /webrtc/dtls/src/record_layer/ |
| H A D | record_layer_header.rs | 41 pub epoch: u16, field
55 writer.write_u16::<BigEndian>(self.epoch)?; in marshal()
69 let epoch = reader.read_u16::<BigEndian>()?; in unmarshal() localVariable
85 epoch, in unmarshal()
|
| H A D | mod.rs | 39 pub fn new(protocol_version: ProtocolVersion, epoch: u16, content: Content) -> Self { in new()
44 epoch, in new()
|
| H A D | record_layer_test.rs | 89 epoch: 0, in test_record_layer_round_trip()
|
| /webrtc/webrtc/src/stats/ |
| H A D | serialize.rs | 19 let epoch = approx in serialize() localVariable
23 let epoch_ms = epoch.as_millis() as f64 / 1000.0; in serialize()
|
| /webrtc/dtls/src/ |
| H A D | handshaker.rs | 269 let epoch = self.cfg.initial_epoch; in prepare() localVariable
270 let mut next_epoch = epoch; in prepare()
273 p.record.record_layer_header.epoch += epoch; in prepare()
274 if p.record.record_layer_header.epoch > next_epoch { in prepare()
275 next_epoch = p.record.record_layer_header.epoch; in prepare()
283 if epoch != next_epoch { in prepare()
|
| /webrtc/dtls/src/fragment_buffer/ |
| H A D | fragment_buffer_test.rs | 134 let (out, epoch) = fragment_buffer.pop()?; in test_fragment_buffer()
141 epoch, expected_epoch, in test_fragment_buffer()
|
| H A D | mod.rs | 94 let (content, epoch) = if let Some(frags) = self.cache.get_mut(&seq_num) { in pop()
113 let message_epoch = frags[0].record_layer_header.epoch; in pop()
125 Ok((content, epoch)) in pop()
|
| /webrtc/dtls/src/crypto/ |
| H A D | crypto_cbc.rs | 64 h.epoch, in encrypt()
112 h.epoch, in decrypt()
|
| H A D | crypto_test.rs | 123 epoch: 0, in test_ccm_encryption_and_decryption()
|
| H A D | mod.rs | 509 additional_data[..2].copy_from_slice(&h.epoch.to_be_bytes()); in generate_aead_additional_data()
|
| /webrtc/dtls/src/prf/ |
| H A D | mod.rs | 294 epoch: u16, in prf_mac()
304 msg[..2].copy_from_slice(&epoch.to_be_bytes()); in prf_mac()
|
| /webrtc/ |
| H A D | Cargo.lock | 655 "crossbeam-epoch",
660 name = "crossbeam-epoch"
|