Searched refs:resp (Results 1 – 8 of 8) sorted by relevance
| /webrtc/turn/src/client/ |
| H A D | client_test.rs | 60 let resp = c.send_binding_request().await?; in test_client_with_stun_send_binding_request() localVariable
61 log::debug!("mapped-addr: {}", resp); in test_client_with_stun_send_binding_request()
87 if let Ok(resp) = c2.send_binding_request_to(&to.to_string()).await { in test_client_with_stun_send_binding_request_to_parallel()
88 log::debug!("mapped-addr: {}", resp); in test_client_with_stun_send_binding_request_to_parallel()
95 let resp = c1.send_binding_request_to(&to.to_string()).await?; in test_client_with_stun_send_binding_request_to_parallel() localVariable
96 log::debug!("mapped-addr: {}", resp); in test_client_with_stun_send_binding_request_to_parallel()
|
| /webrtc/ice/examples/ |
| H A D | ping_pong.rs | 224 let resp = match client3.request(req).await { in main() localVariable
225 Ok(resp) => resp, in main()
231 println!("Response from remoteCandidate: {}", resp.status()); in main()
259 let resp = match client.request(req).await { in main() localVariable
260 Ok(resp) => resp, in main()
263 println!("Response from remoteAuth: {}", resp.status()); in main()
|
| /webrtc/examples/examples/data-channels-flow-control/ |
| H A D | data-channels-flow-control.rs | 231 let resp = responder.create_answer(None).await?; in main() localVariable
233 responder.set_local_description(resp.clone()).await?; in main()
234 requester.set_remote_description(resp).await?; in main()
|
| /webrtc/examples/examples/offer-answer/ |
| H A D | offer.rs | 54 Ok(resp) => resp, in signal_candidate()
356 Ok(resp) => resp, in main()
|
| H A D | answer.rs | 55 Ok(resp) => resp, in signal_candidate()
149 Ok(resp) => resp, in remote_handler()
|
| /webrtc/ice/src/util/ |
| H A D | mod.rs | 53 let resp = stun_request(conn, server_addr, deadline).await?; in get_xormapped_addr() localVariable
55 addr.get_from(&resp)?; in get_xormapped_addr()
|
| /webrtc/dtls/src/conn/ |
| H A D | conn_test.rs | 2074 let mut resp = vec![0; 1024]; in test_protocol_version_validation() localVariable
2084 n = ca.recv(&mut resp).await?; in test_protocol_version_validation()
2214 let mut resp = vec![0; 1024]; in test_protocol_version_validation() localVariable
2216 let _ = ca.recv(&mut resp).await?; in test_protocol_version_validation()
2226 let n = ca.recv(&mut resp).await?; in test_protocol_version_validation()
2306 let mut resp = vec![0; 1024]; in test_multiple_hello_verify_request() localVariable
2307 let n = cb.recv(&mut resp).await?; in test_multiple_hello_verify_request()
2308 let mut reader = BufReader::new(&resp[..n]); in test_multiple_hello_verify_request()
2377 let mut resp = vec![0u8; 1024]; in test_renegotation_info() localVariable
2401 let n = ca.recv(&mut resp).await?; in test_renegotation_info()
[all …]
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 970 let resp = self.reset_streams_if_any(&rst_req); in handle_peer_last_tsn_and_acknowledgement() localVariable
971 log::debug!("[{}] RESET RESPONSE: {}", self.name, resp); in handle_peer_last_tsn_and_acknowledgement()
972 reply.push(resp); in handle_peer_last_tsn_and_acknowledgement()
|