Home
last modified time | relevance | path

Searched refs:pipe (Results 1 – 9 of 9) sorted by relevance

/webrtc/webrtc/src/mux/
H A Dmux_test.rs7 use util::conn::conn_pipe::pipe;
13 let (ca, cb) = pipe(); in pipe_memory()
30 let (ca, _) = pipe(); in test_no_endpoints()
/webrtc/ice/src/agent/
H A Dagent_transport_test.rs8 pub(crate) async fn pipe( in pipe() function
111 let (ca, cb, _, _) = pipe(None, None).await?; in test_conn_stats()
H A Dagent_test.rs12 use crate::agent::agent_transport_test::pipe;
168 let (conn_a, conn_b, agent_a, agent_b) = pipe(None, None).await?; in test_agent_get_stats()
1809 let (_, _, agent_a, agent_b) = pipe( in test_agent_restart_one_side()
1867 let (_, _, agent_a, agent_b) = pipe( in test_agent_restart_both_side()
/webrtc/util/src/conn/
H A Dconn_pipe_test.rs6 let (c1, c2) = pipe(); in test_pipe()
H A Dconn_udp_listener_test.rs11 async fn pipe() -> Result<( in pipe() function
54 let (listener, ca, _) = pipe().await?; in test_listener_close_timeout()
H A Dconn_pipe.rs12 pub fn pipe() -> (impl Conn, impl Conn) { in pipe() function
/webrtc/dtls/src/conn/
H A Dconn_test.rs34 let (ua, ub) = pipe(); in build_pipe()
355 let (ca, cb) = pipe(); in test_handshake_with_alert()
399 let (ca, _cb) = pipe(); in test_export_keying_material()
532 let (ca, cb) = pipe(); in test_psk()
593 let (ca, cb) = pipe(); in test_psk_hint_fail()
659 let (ca, _cb) = pipe(); in test_client_timeout()
773 let (ca, cb) = pipe(); in test_srtp_configuration()
1025 let (ca, cb) = pipe(); in test_client_certificate()
1249 let (ca, cb) = pipe(); in test_extended_master_secret()
1869 let (ca, cb) = pipe(); in test_server_timeout()
[all …]
/webrtc/srtp/src/session/
H A Dsession_rtcp_test.rs13 let (ua, ub) = pipe(); in build_session_srtcp_pair()
/webrtc/sctp/src/association/
H A Dassociation_test.rs16 use util::conn::conn_pipe::pipe;
2600 let (a_conn, charlie_conn) = pipe(); in test_association_handle_packet_before_init()