| /webrtc/dtls/examples/hub/src/ |
| H A D | lib.rs | 10 use util::Conn;
19 conns: Arc<Mutex<HashMap<String, Arc<dyn Conn + Send + Sync>>>>,
31 pub async fn register(&self, conn: Arc<dyn Conn + Send + Sync>) { in register()
46 conns: Arc<Mutex<HashMap<String, Arc<dyn Conn + Send + Sync>>>>, in read_loop()
47 conn: Arc<dyn Conn + Send + Sync>, in read_loop()
60 conns: Arc<Mutex<HashMap<String, Arc<dyn Conn + Send + Sync>>>>, in unregister()
61 conn: Arc<dyn Conn + Send + Sync>, in unregister()
|
| /webrtc/turn/src/relay/ |
| H A D | mod.rs | 7 use util::Conn;
25 ) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)>; in allocate_conn()
|
| H A D | relay_none.rs | 30 ) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)> { in allocate_conn()
|
| H A D | relay_static.rs | 36 ) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)> { in allocate_conn()
|
| /webrtc/util/src/conn/ |
| H A D | conn_disconnected_packet.rs | 13 pconn: Arc<dyn Conn + Send + Sync>,
17 pub fn new(conn: Arc<dyn Conn + Send + Sync>) -> Self { in new()
26 impl Conn for DisconnectedPacketConn {
|
| H A D | conn_udp_listener.rs | 25 pconn: Arc<dyn Conn + Send + Sync>,
36 async fn accept(&self) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)> { in accept()
142 pconn: Arc<dyn Conn + Send + Sync>, in read_loop()
188 pconn: &Arc<dyn Conn + Send + Sync>, in get_udp_conn()
236 pconn: Arc<dyn Conn + Send + Sync>,
244 pconn: Arc<dyn Conn + Send + Sync>, in new()
258 impl Conn for UdpConn {
|
| H A D | conn_pipe.rs | 12 pub fn pipe() -> (impl Conn, impl Conn) { in pipe()
30 impl Conn for Pipe {
|
| H A D | mod.rs | 27 pub trait Conn { interface
43 async fn accept(&self) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)>; in accept()
|
| H A D | conn_udp.rs | 6 impl Conn for UdpSocket {
|
| H A D | conn_bridge.rs | 23 impl Conn for BridgeConn {
89 ) -> (Arc<Bridge>, impl Conn, impl Conn) { in new() argument
|
| /webrtc/turn/src/server/ |
| H A D | config.rs | 6 use util::Conn;
14 pub conn: Arc<dyn Conn + Send + Sync>,
|
| /webrtc/webrtc/src/mux/ |
| H A D | endpoint.rs | 2 use util::{Buffer, Conn};
16 pub(crate) next_conn: Arc<dyn Conn + Send + Sync>,
35 impl Conn for Endpoint {
|
| H A D | mod.rs | 15 use util::{Buffer, Conn};
25 pub conn: Arc<dyn Conn + Send + Sync>,
33 next_conn: Arc<dyn Conn + Send + Sync>,
97 next_conn: Arc<dyn Conn + Send + Sync>, in read_loop()
|
| /webrtc/ice/src/udp_mux/ |
| H A D | mod.rs | 3 use util::{sync::RwLock, Conn, Error};
45 async fn get_conn(self: Arc<Self>, ufrag: &str) -> Result<Arc<dyn Conn + Send + Sync>, Error>; in get_conn()
52 conn: Box<dyn Conn + Send + Sync>,
58 C: Conn + Send + Sync + 'static, in new()
257 async fn get_conn(self: Arc<Self>, ufrag: &str) -> Result<Arc<dyn Conn + Send + Sync>, Error> { in get_conn()
267 return Ok(Arc::new(conn.clone()) as Arc<dyn Conn + Send + Sync>); in get_conn()
283 Ok(Arc::new(muxed_conn) as Arc<dyn Conn + Send + Sync>) in get_conn()
|
| /webrtc/ice/src/util/ |
| H A D | mod.rs | 13 use util::{vnet::net::*, Conn};
49 conn: &Arc<dyn Conn + Send + Sync>, in get_xormapped_addr()
62 conn: &Arc<dyn Conn + Send + Sync>, in stun_request()
139 ) -> Result<Arc<dyn Conn + Send + Sync>> { in listen_udp_in_port_range()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_transport_test.rs | 5 use util::{vnet::*, Conn};
11 ) -> Result<(Arc<impl Conn>, Arc<impl Conn>, Arc<Agent>, Arc<Agent>)> { in pipe() argument
|
| H A D | agent_transport.rs | 8 use util::Conn;
21 ) -> Result<Arc<impl Conn>> { in dial() argument
56 ) -> Result<Arc<impl Conn>> { in accept() argument
165 impl Conn for AgentConn {
|
| /webrtc/dtls/examples/dial/selfsign/ |
| H A D | dial_selfsign.rs | 5 use util::Conn;
70 let dtls_conn: Arc<dyn Conn + Send + Sync> = in main()
|
| /webrtc/dtls/examples/dial/verify/ |
| H A D | dial_verify.rs | 6 use util::Conn;
81 let dtls_conn: Arc<dyn Conn + Send + Sync> = in main()
|
| /webrtc/dtls/examples/dial/psk/ |
| H A D | dial_psk.rs | 5 use util::Conn;
72 let dtls_conn: Arc<dyn Conn + Send + Sync> = in main()
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 13 use util::{conn::Conn, marshal::*};
37 pub(crate) udp_tx: Arc<dyn Conn + Send + Sync>,
43 conn: Arc<dyn Conn + Send + Sync>, in new()
130 udp_rx: &Arc<dyn Conn + Send + Sync>, in incoming()
|
| /webrtc/turn/src/allocation/ |
| H A D | mod.rs | 17 use util::Conn;
73 turn_socket: Arc<dyn Conn + Send + Sync>,
75 pub(crate) relay_socket: Arc<dyn Conn + Send + Sync>,
96 turn_socket: Arc<dyn Conn + Send + Sync>, in new()
97 relay_socket: Arc<dyn Conn + Send + Sync>, in new()
|
| /webrtc/stun/src/ |
| H A D | client.rs | 8 use util::Conn;
115 c: Option<Arc<dyn Conn + Send + Sync>>,
173 pub fn with_conn(mut self, conn: Arc<dyn Conn + Send + Sync>) -> Self { in with_conn()
223 c: Arc<dyn Conn + Send + Sync>, in read_until_closed()
280 conn: Option<Arc<dyn Conn + Send + Sync>>, in start()
|
| /webrtc/turn/src/client/ |
| H A D | transaction.rs | 12 use util::Conn;
18 conn: &Arc<dyn Conn + Send + Sync>, in on_rtx_timeout()
166 conn: Arc<dyn Conn + Send + Sync>, in start_rtx_timer()
|
| /webrtc/util/ |
| H A D | CHANGELOG.md | 11 - `Conn`:
|