| /webrtc/stun/src/xoraddr/ |
| H A D | xoraddr_test.rs | 39 let transaction_id = base64::decode("jxhBARZwX+rsC6er").unwrap(); in test_xormapped_address_get_from() localVariable
40 m.transaction_id.0.copy_from_slice(&transaction_id); in test_xormapped_address_get_from()
107 let transaction_id = base64::decode("jxhBARZwX+rsC6er").unwrap(); in test_xormapped_address_get_from_invalid() localVariable
108 m.transaction_id.0.copy_from_slice(&transaction_id); in test_xormapped_address_get_from_invalid()
137 let transaction_id = base64::decode("jxhBARZwX+rsC6er").unwrap(); in test_xormapped_address_add_to() localVariable
138 m.transaction_id.0.copy_from_slice(&transaction_id); in test_xormapped_address_add_to()
169 let transaction_id = base64::decode("jxhBARZwX+rsC6er").unwrap(); in test_xormapped_address_add_to_ipv6() localVariable
170 m.transaction_id.0.copy_from_slice(&transaction_id); in test_xormapped_address_add_to_ipv6()
|
| /webrtc/stun/src/agent/ |
| H A D | agent_test.rs | 12 m.transaction_id = TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12]); in test_agent_process_in_transaction()
13 a.start(m.transaction_id, Instant::now())?; in test_agent_process_in_transaction()
22 e.event_body.as_ref().unwrap().transaction_id, in test_agent_process_in_transaction()
25 e.event_body.as_ref().unwrap().transaction_id, in test_agent_process_in_transaction()
38 m.transaction_id = TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12]); in test_agent_process()
47 e.event_body.as_ref().unwrap().transaction_id, in test_agent_process()
50 e.event_body.as_ref().unwrap().transaction_id, in test_agent_process()
|
| /webrtc/stun/src/ |
| H A D | message.rs | 60 pub transaction_id: TransactionId, field
67 let t_id = base64::encode(self.transaction_id.0); in fmt()
86 if self.transaction_id != other.transaction_id { in eq()
106 b.transaction_id = self.transaction_id; in add_to()
143 rand::thread_rng().fill(&mut self.transaction_id.0); in new_transaction_id()
232 self.raw[8..MESSAGE_HEADER_SIZE].copy_from_slice(&self.transaction_id.0); in write_header()
238 self.raw[8..MESSAGE_HEADER_SIZE].copy_from_slice(&self.transaction_id.0); in write_transaction_id()
300 self.transaction_id in decode()
|
| H A D | agent.rs | 98 m.transaction_id = *self; in add_to()
152 self.transactions.remove(&message.transaction_id); in process()
155 event_type: EventType::Callback(message.transaction_id), in process()
|
| H A D | xoraddr.rs | 126 xor_value[4..].copy_from_slice(&m.transaction_id.0); in add_to_as()
160 xor_value[4..].copy_from_slice(&m.transaction_id.0); in get_from_as()
|
| H A D | client.rs | 438 id: m.transaction_id, in send()
451 .send(ClientAgent::Start(m.transaction_id, d)) in send()
459 self.remove(m.transaction_id)?; in send()
463 .send(ClientAgent::Stop(m.transaction_id)) in send()
|
| /webrtc/turn/src/server/ |
| H A D | request.rs | 156 m.transaction_id, in authenticate_request()
248 m.transaction_id, in respond_with_nonce()
269 m.transaction_id, in handle_binding_request()
315 m.transaction_id, in handle_allocate_request()
340 m.transaction_id, in handle_allocate_request()
351 m.transaction_id, in handle_allocate_request()
374 m.transaction_id, in handle_allocate_request()
545 m.transaction_id, in handle_allocate_request()
584 m.transaction_id, in handle_refresh_request()
651 m.transaction_id, in handle_create_permission_request()
[all …]
|
| /webrtc/stun/benches/ |
| H A D | bench.rs | 270 m.transaction_id = TransactionId::new(); in benchmark_message()
301 transaction_id: TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12]), in benchmark_message()
325 transaction_id: TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12]), in benchmark_message()
347 transaction_id: TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12]), in benchmark_message()
367 transaction_id: TransactionId::new(), in benchmark_message()
434 transaction_id: TransactionId::new(), in benchmark_message()
492 transaction_id: TransactionId::new(), in benchmark_message()
626 let transaction_id = base64::decode("jxhBARZwX+rsC6er").unwrap(); in benchmark_xoraddr() localVariable
628 m.transaction_id.0.copy_from_slice(&transaction_id); in benchmark_xoraddr()
|
| /webrtc/stun/src/message/ |
| H A D | message_test.rs | 16 m.transaction_id = TransactionId::new(); in test_message_buffer()
143 m.transaction_id = TransactionId::new(); in test_message_write_to()
191 transaction_id: TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12]), in test_message_bad_length()
219 transaction_id: TransactionId::new(), in test_message_attr_length_less_than_header()
249 transaction_id: TransactionId::new(), in test_message_attr_size_less_than_length()
430 transaction_id: t_id, in test_message_equal()
685 m.transaction_id = TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 2, 0]); in test_message_add_to()
701 m.transaction_id = TransactionId::new(); in test_decode()
|
| /webrtc/stun/src/integrity/ |
| H A D | integrity_test.rs | 49 m.transaction_id = TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 0]); in test_message_integrity_with_fingerprint()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_selector.rs | 308 if let Some(pending_request) = self.handle_inbound_binding_success(m.transaction_id).await { in handle_success_response()
346 m.transaction_id in handle_success_response()
466 if let Some(pending_request) = self.handle_inbound_binding_success(m.transaction_id).await { in handle_success_response()
494 m.transaction_id in handle_success_response()
|
| H A D | mod.rs | 50 pub(crate) transaction_id: TransactionId, field
59 transaction_id: TransactionId::default(), in default()
|
| H A D | agent_internal.rs | 726 transaction_id: m.transaction_id, in send_binding_request()
814 if pending_binding_requests[i].transaction_id == id { in handle_inbound_binding_success()
|
| H A D | agent_test.rs | 336 transaction_id: tid, in test_handle_peer_reflexive_unknown_remote()
|
| /webrtc/turn/src/client/ |
| H A D | mod.rs | 106 let tr_key = base64::encode(msg.transaction_id.0); in perform_transaction()
344 let tr_key = base64::encode(msg.transaction_id.0); in handle_stun_message()
|