| /webrtc/stun/examples/ |
| H A D | stun_client.rs | 50 let mut msg = Message::new(); in main() localVariable
56 let msg = event.event_body?; in main() localVariable
|
| /webrtc/turn/src/server/ |
| H A D | request.rs | 247 let msg = build_msg( in respond_with_nonce() localVariable
268 let msg = build_msg( in handle_binding_request() localVariable
314 let msg = build_msg( in handle_allocate_request() localVariable
350 let msg = build_msg( in handle_allocate_request() localVariable
373 let msg = build_msg( in handle_allocate_request() localVariable
518 let msg = { in handle_allocate_request() localVariable
583 let msg = build_msg( in handle_refresh_request() localVariable
650 let msg = build_msg( in handle_create_permission_request() localVariable
761 let msg = build_msg( in handle_channel_bind_request() localVariable
873 let mut msg = Message::new(); in build_msg() localVariable
|
| /webrtc/data/src/message/ |
| H A D | message_test.rs | 56 let msg = Message::DataChannelAck(DataChannelAck {}); in test_message_marshal_size() localVariable
70 let msg = Message::DataChannelOpen(DataChannelOpen { in test_message_marshal() localVariable
|
| /webrtc/turn/examples/ |
| H A D | turn_client_udp.rs | 148 let msg = match String::from_utf8(buf[..n].to_vec()) { in do_ping_test() localVariable
187 let msg = "12345678910".to_owned(); //format!("{:?}", tokio::time::Instant::now()); in do_ping_test() localVariable
|
| /webrtc/dtls/examples/hub/src/ |
| H A D | lib.rs | 52 let msg = String::from_utf8(b[..n].to_vec())?; in read_loop() localVariable
97 let mut msg = String::new(); in chat() localVariable
|
| H A D | utilities.rs | 47 let msg = String::from_utf8(b[..n].to_vec()).expect("utf8"); in chat() localVariable
57 let mut msg = String::new(); in chat() localVariable
|
| /webrtc/mdns/src/message/ |
| H A D | builder.rs | 21 pub msg: Option<Vec<u8>>, field
151 let msg = self.msg.take(); in add_question() localVariable
|
| H A D | message_test.rs | 538 let mut msg = large_test_msg()?; in test_skip_all() localVariable
561 let mut msg = small_test_msg()?; in test_skip_each() localVariable
604 let mut msg = small_test_msg()?; in test_skip_after_read() localVariable
1042 let mut msg = large_test_msg()?; in test_builder() localVariable
|
| H A D | parser.rs | 22 pub msg: &'a [u8], field
|
| H A D | mod.rs | 321 let mut msg = h.pack(b); in append_pack() localVariable
|
| /webrtc/turn/src/client/ |
| H A D | relay_conn.rs | 294 let mut msg = Message::new(); in send_to() localVariable
392 let msg = { in create_permissions() localVariable
409 let mut msg = Message::new(); in create_permissions() localVariable
467 let mut msg = Message::new(); in refresh_allocation() localVariable
557 let mut msg = Message::new(); in bind() localVariable
|
| H A D | mod.rs | 310 let mut msg = Message::new(); in handle_stun_message() localVariable
438 let msg = { in send_binding_request_to() localVariable
449 let mut msg = Message::new(); in send_binding_request_to() localVariable
493 let mut msg = Message::new(); in allocate() localVariable
|
| H A D | transaction.rs | 86 pub msg: Message, field
|
| /webrtc/ice/src/agent/ |
| H A D | agent_selector.rs | 118 let mut msg = Message::new(); in nominate_pair() localVariable
279 let mut msg = Message::new(); in ping_candidate() localVariable
431 let mut msg = Message::new(); in ping_candidate() localVariable
|
| H A D | agent_test.rs | 270 let mut msg = Message::new(); in test_handle_peer_reflexive_udp_pflx_candidate() localVariable
360 let mut msg = Message::new(); in test_handle_peer_reflexive_unknown_remote() localVariable
618 let mut msg = Message::new(); in build_msg() localVariable
810 let mut msg = Message::new(); in test_inbound_validity() localVariable
845 let mut msg = Message::new(); in test_inbound_validity() localVariable
|
| /webrtc/mdns/src/conn/ |
| H A D | mod.rs | 218 let mut msg = Message { in send_question() localVariable
390 let mut msg = Message { in send_answer() localVariable
|
| /webrtc/data/src/data_channel/ |
| H A D | mod.rs | 105 let msg = Message::DataChannelOpen(DataChannelOpen { in client() localVariable
132 let msg = Message::unmarshal(&mut read_buf)?; in server() localVariable
240 let msg = Message::unmarshal(data)?; in handle_dcep() localVariable
|
| /webrtc/turn/src/allocation/ |
| H A D | mod.rs | 416 let msg = { in packet_handler() localVariable
423 let mut msg = Message::new(); in packet_handler() localVariable
|
| /webrtc/util/src/conn/ |
| H A D | conn_bridge_test.rs | 237 let msg = format!("msg{i}"); in test_bridge_drop_next_n_packets() localVariable
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 99 let msg = "PING!"; in test_net_native_loopback() localVariable
414 let msg = "PING!"; in test_net_virtual_loopback1() localVariable
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 118 let mut msg = Message::new(); in test_packet_handler() localVariable
|
| /webrtc/dtls/src/prf/ |
| H A D | mod.rs | 303 let mut msg = vec![0u8; 13]; in prf_mac() localVariable
|
| /webrtc/dtls/src/crypto/ |
| H A D | mod.rs | 290 let msg = value_key_message(client_random, server_random, public_key, named_curve); in generate_key_signature() localVariable
|
| /webrtc/stun/src/ |
| H A D | client.rs | 226 let mut msg = Message::new(); in read_until_closed() localVariable
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 180 let msg = match maybe_msg { in run_stats_reducer() localVariable
|