| /webrtc/stun/src/ |
| H A D | agent.rs | 34 transactions: HashMap<TransactionId, AgentTransaction>,
43 Callback(TransactionId),
45 Remove(TransactionId),
51 EventType::Callback(TransactionId::default()) in default()
75 id: TransactionId,
84 pub struct TransactionId(pub [u8; TRANSACTION_ID_SIZE]); struct
86 impl TransactionId { implementation
90 let mut b = TransactionId([0u8; TRANSACTION_ID_SIZE]); in new()
96 impl Setter for TransactionId { implementation
110 Start(TransactionId, Instant),
[all …]
|
| H A D | client.rs | 82 id: TransactionId,
264 fn remove(&mut self, id: TransactionId) -> Result<()> { in remove()
283 mut t: HashMap<TransactionId, ClientTransaction>, in start() argument
389 let t: HashMap<TransactionId, ClientTransaction> = HashMap::new(); in run()
|
| H A D | message.rs | 60 pub transaction_id: TransactionId,
|
| /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()
20 let tid = TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12]); 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()
45 let tid = TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12]); in test_agent_process()
74 let id = TransactionId::new(); in test_agent_start()
92 let id = TransactionId::new(); in test_agent_start()
127 let result = a.stop(TransactionId::default()); in test_agent_stop()
140 let id = TransactionId::new(); in test_agent_stop()
180 let result = a.stop(TransactionId::default()); in test_agent_stop()
|
| /webrtc/stun/benches/ |
| H A D | bench.rs | 9 use stun::agent::{noop_handler, Agent, TransactionId};
63 a.start(TransactionId::new(), deadline).unwrap(); in benchmark_agent()
78 a.start(TransactionId::new(), deadline).unwrap(); in benchmark_agent()
82 m.build(&[Box::<TransactionId>::default()]).unwrap(); in benchmark_agent()
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()
367 transaction_id: TransactionId::new(), in benchmark_message()
434 transaction_id: TransactionId::new(), in benchmark_message()
449 Box::new(TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 1, 2])), in benchmark_message()
472 Box::new(TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 1, 2])), in benchmark_message()
[all …]
|
| /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()
425 let t_id = TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12]); in test_message_equal()
621 Box::new(TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 1, 0])), in test_message_full_size()
647 Box::new(TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 1, 0])), in test_message_clone_to()
677 Box::new(TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 1, 0])), in test_message_add_to()
685 m.transaction_id = TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 2, 0]); in test_message_add_to()
[all …]
|
| /webrtc/stun/src/integrity/ |
| H A D | integrity_test.rs | 2 use crate::agent::TransactionId;
49 m.transaction_id = TransactionId([1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 0]); in test_message_integrity_with_fingerprint()
|
| /webrtc/stun/examples/ |
| H A D | stun_client.rs | 51 msg.build(&[Box::<TransactionId>::default(), Box::new(BINDING_REQUEST)])?; in main()
|
| /webrtc/turn/src/client/ |
| H A D | mod.rs | 441 Box::new(TransactionId::new()), in send_binding_request_to()
446 vec![Box::new(TransactionId::new()), Box::new(BINDING_REQUEST)] in send_binding_request_to()
495 Box::new(TransactionId::new()), in allocate()
521 Box::new(TransactionId::new()), in allocate()
|
| H A D | relay_conn.rs | 296 Box::new(TransactionId::new()), in send_to()
395 Box::new(TransactionId::new()), in create_permissions()
469 Box::new(TransactionId::new()), in refresh_allocation()
546 Box::new(TransactionId::new()), in bind()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_selector.rs | 121 Box::new(TransactionId::new()), in nominate_pair()
282 Box::new(TransactionId::new()), in ping_candidate()
434 Box::new(TransactionId::new()), in ping_candidate()
|
| H A D | mod.rs | 50 pub(crate) transaction_id: TransactionId,
59 transaction_id: TransactionId::default(), in default()
|
| H A D | agent_test.rs | 273 Box::new(TransactionId::new()), in test_handle_peer_reflexive_udp_pflx_candidate()
328 let mut tid = TransactionId::default(); in test_handle_peer_reflexive_unknown_remote()
621 Box::new(TransactionId::new()), in build_msg()
813 Box::new(TransactionId::new()), in test_inbound_validity()
837 let mut t_id = TransactionId::default(); in test_inbound_validity()
|
| H A D | agent_internal.rs | 807 id: TransactionId, in handle_inbound_binding_success() argument
|
| /webrtc/ice/src/util/ |
| H A D | mod.rs | 67 request.build(&[Box::new(BINDING_REQUEST), Box::new(TransactionId::new())])?; in stun_request()
|
| /webrtc/turn/src/allocation/ |
| H A D | mod.rs | 425 Box::new(TransactionId::new()), in packet_handler()
|
| /webrtc/turn/src/server/ |
| H A D | request.rs | 859 transaction_id: TransactionId, in build_msg() argument
|