| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_conn.rs | 16 async fn register_conn_for_address(&self, conn: &UDPMuxConn, addr: SocketAddr); in register_conn_for_address() 115 pub fn get_addresses(&self) -> Vec<SocketAddr> { in get_addresses() 120 pub async fn add_address(&self, addr: SocketAddr) { in add_address() 128 pub fn remove_address(&self, addr: &SocketAddr) { in remove_address() 152 async fn recv_from(&self, buf: &mut [u8]) -> ConnResult<(usize, SocketAddr)> { in recv_from() argument 232 fn local_addr(&self) -> SocketAddr { in local_addr() 237 pub(super) fn get_addresses(&self) -> Vec<SocketAddr> { in get_addresses() 243 pub(super) fn add_address(self: &Arc<Self>, addr: SocketAddr) { in add_address() 250 pub(super) fn remove_address(&self, addr: &SocketAddr) { in remove_address() 292 fn local_addr(&self) -> ConnResult<SocketAddr> { in local_addr() [all …]
|
| H A D | socket_addr_ext.rs | 16 fn decode(buffer: &[u8]) -> Result<SocketAddr, Error>; in decode() 26 impl SocketAddrExt for SocketAddr { implementation 64 fn decode(buffer: &[u8]) -> Result<SocketAddr, Error> { in decode()
|
| H A D | mod.rs | 27 fn normalize_socket_addr(target: &SocketAddr, socket_addr: &SocketAddr) -> SocketAddr { in normalize_socket_addr() 308 async fn register_conn_for_address(&self, conn: &UDPMuxConn, addr: SocketAddr) { in register_conn_for_address()
|
| /webrtc/util/src/conn/ |
| H A D | mod.rs | 30 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)>; in recv_from() argument 33 fn local_addr(&self) -> Result<SocketAddr>; in local_addr() 34 fn remote_addr(&self) -> Option<SocketAddr>; in remote_addr() 43 async fn accept(&self) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)>; in accept() argument 50 async fn addr(&self) -> Result<SocketAddr>; in addr()
|
| H A D | conn_udp.rs | 15 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument 27 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() 31 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr()
|
| H A D | conn_disconnected_packet.rs | 37 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument 50 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() 54 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr()
|
| H A D | conn_pipe.rs | 46 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument 64 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() 68 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr()
|
| H A D | conn_udp_listener.rs | 36 async fn accept(&self) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)> { in accept() argument 71 async fn addr(&self) -> Result<SocketAddr> { in addr() 193 raddr: SocketAddr, in get_udp_conn() 246 raddr: SocketAddr, in new() 267 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument 280 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() 284 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr()
|
| H A D | conn_bridge.rs | 39 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument 56 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() 60 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr()
|
| /webrtc/mdns/src/conn/ |
| H A D | mod.rs | 51 pub fn server(addr: SocketAddr, config: Config) -> Result<Self> { in server() 167 ) -> Result<(ResourceHeader, SocketAddr)> { in query() argument 248 dst_addr: SocketAddr, in start() 296 src: SocketAddr, in run() 297 dst_addr: SocketAddr, in run() 384 interface_addr: &SocketAddr, in send_answer() 387 dst_addr: SocketAddr, in send_answer() 426 async fn get_interface_addr_for_ip(addr: impl ToSocketAddrs) -> std::io::Result<SocketAddr> { in get_interface_addr_for_ip()
|
| /webrtc/util/src/vnet/ |
| H A D | conn.rs | 22 async fn on_closed(&self, addr: SocketAddr); in on_closed() 41 loc_addr: SocketAddr, in new() 42 rem_addr: Option<SocketAddr>, in new() 81 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument 135 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() 139 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr()
|
| H A D | chunk.rs | 101 fn source_addr(&self) -> SocketAddr; in source_addr() 102 fn destination_addr(&self) -> SocketAddr; in destination_addr() 182 fn source_addr(&self) -> SocketAddr { in source_addr() 186 fn destination_addr(&self) -> SocketAddr { in destination_addr() 228 pub(crate) fn new(src_addr: SocketAddr, dst_addr: SocketAddr) -> Self { in new() 289 fn source_addr(&self) -> SocketAddr { in source_addr() 293 fn destination_addr(&self) -> SocketAddr { in destination_addr() 336 pub(crate) fn new(src_addr: SocketAddr, dst_addr: SocketAddr, flags: TcpFlag) -> Self { in new()
|
| /webrtc/ice/src/util/ |
| H A D | mod.rs | 15 pub fn create_addr(_network: NetworkType, ip: IpAddr, port: u16) -> SocketAddr { in create_addr() 50 server_addr: SocketAddr, in get_xormapped_addr() 63 server_addr: SocketAddr, in stun_request() 138 laddr: SocketAddr, in listen_udp_in_port_range()
|
| /webrtc/turn/src/client/ |
| H A D | permission.rs | 50 pub(crate) fn insert(&mut self, addr: &SocketAddr, p: Arc<Permission>) { in insert() 58 pub(crate) fn delete(&mut self, addr: &SocketAddr) { in delete() 62 pub(crate) fn addrs(&self) -> Vec<SocketAddr> { in addrs()
|
| H A D | mod.rs | 267 from: SocketAddr, in handle_inbound() 308 mut from: SocketAddr, in handle_stun_message() 403 from: SocketAddr, in handle_inbound_relay_conn() 437 async fn send_binding_request_to(&mut self, to: &str) -> Result<SocketAddr> { in send_binding_request_to() 464 async fn send_binding_request(&mut self) -> Result<SocketAddr> { in send_binding_request() 478 ) -> Option<SocketAddr> { in find_addr_by_channel_number() 611 pub async fn send_binding_request_to(&self, to: &str) -> Result<SocketAddr> { in send_binding_request_to() 617 pub async fn send_binding_request(&self) -> Result<SocketAddr> { in send_binding_request()
|
| /webrtc/webrtc/src/mux/ |
| H A D | endpoint.rs | 48 async fn recv_from(&self, _buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument 61 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() 65 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr()
|
| H A D | mux_test.rs | 71 async fn recv_from(&self, _buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument 83 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() 87 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr()
|
| /webrtc/dtls/src/ |
| H A D | listener.rs | 74 async fn accept(&self) -> UtilResult<(Arc<dyn Conn + Send + Sync>, SocketAddr)> { in accept() argument 90 async fn addr(&self) -> UtilResult<SocketAddr> { in addr()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_transport.rs | 187 ) -> std::result::Result<(usize, SocketAddr), util::Error> { in recv_from() argument 225 _target: SocketAddr, in send_to() 230 fn local_addr(&self) -> std::result::Result<SocketAddr, util::Error> { in local_addr() 238 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr()
|
| H A D | agent_selector.rs | 29 remote_addr: SocketAddr, in handle_success_response() 53 remote_addr: SocketAddr, in handle_success_response() 190 remote_addr: SocketAddr, in handle_success_response() 306 remote_addr: SocketAddr, in handle_success_response() 458 remote_addr: SocketAddr, in handle_success_response()
|
| /webrtc/turn/src/relay/ |
| H A D | mod.rs | 25 ) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)>; in allocate_conn() argument
|
| H A D | relay_none.rs | 30 ) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)> { in allocate_conn() argument
|
| H A D | relay_static.rs | 36 ) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)> { in allocate_conn() argument
|
| /webrtc/sctp/src/association/association_internal/ |
| H A D | association_internal_test.rs | 25 async fn recv_from(&self, _buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument 37 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() 41 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr()
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_relay_test.rs | 21 _src_addr: SocketAddr, in auth_handle()
|