| /webrtc/ice/src/ |
| H A D | udp_network.rs | 86 let e = EphemeralUDP::default(); in test_ephemeral_udp_constructor() localVariable
87 assert_eq!(e.port_min(), 0, "EphemeralUDP should default port_min to 0"); in test_ephemeral_udp_constructor()
88 assert_eq!(e.port_max(), 0, "EphemeralUDP should default port_max to 0"); in test_ephemeral_udp_constructor()
93 let mut e = EphemeralUDP::default(); in test_ephemeral_udp_set_ports() localVariable
96 e.set_ports(3000, 2999).is_err(), in test_ephemeral_udp_set_ports()
101 e.set_ports(6000, 6001).is_ok(), in test_ephemeral_udp_set_ports()
106 e.port_min(), in test_ephemeral_udp_set_ports()
111 e.port_max(), in test_ephemeral_udp_set_ports()
|
| H A D | error.rs | 230 fn from(e: io::Error) -> Self { in from()
231 Error::Io(IoError(e)) in from()
236 fn from(e: SystemTimeError) -> Self { in from()
237 Error::Other(e.to_string()) in from()
|
| /webrtc/data/src/ |
| H A D | error.rs | 36 fn from(e: Error) -> Self { in from()
37 util::Error::from_std(e) in from()
44 e @ Error::Sctp(sctp::Error::ErrEof) => { in from()
45 io::Error::new(io::ErrorKind::UnexpectedEof, e.to_string()) in from()
47 e @ Error::ErrStreamClosed => { in from()
48 io::Error::new(io::ErrorKind::ConnectionAborted, e.to_string()) in from()
50 e => io::Error::new(io::ErrorKind::Other, e.to_string()), in from()
|
| /webrtc/dtls/src/ |
| H A D | error.rs | 190 fn from(e: io::Error) -> Self { in from()
191 Error::Io(IoError(e)) in from()
196 fn from(e: sec1::Error) -> Self { in from()
197 Error::Sec1(e) in from()
212 fn from(e: p256::elliptic_curve::Error) -> Self { in from()
213 Error::P256(P256Error(e)) in from()
219 Error::Other(e.to_string()) in from()
223 fn from(e: block_modes::BlockModeError) -> Self { in from()
224 Error::Other(e.to_string()) in from()
230 fn from(e: MpscSendError<T>) -> Self { in from()
[all …]
|
| /webrtc/dtls/src/crypto/ |
| H A D | mod.rs | 213 .map_err(|e| Error::Other(e.to_string()))?, in try_from()
224 .map_err(|e| Error::Other(e.to_string()))?, in try_from()
232 .map_err(|e| Error::Other(e.to_string()))?, in try_from()
249 .map_err(|e| Error::Other(e.to_string()))?, in from_key_pair()
260 .map_err(|e| Error::Other(e.to_string()))?, in from_key_pair()
296 .map_err(|e| Error::Other(e.to_string()))? in generate_key_signature()
309 .map_err(|e| Error::Other(e.to_string()))?; in generate_key_signature()
334 .map_err(|e| Error::Other(e.to_string()))?; in verify_signature()
380 .map_err(|e| Error::Other(e.to_string()))?; in verify_signature()
418 .map_err(|e| Error::Other(e.to_string()))? in generate_certificate_verify()
[all …]
|
| H A D | crypto_ccm.rs | 124 .map_err(|e| Error::Other(e.to_string()))?; in encrypt()
128 .map_err(|e| Error::Other(e.to_string()))?; in encrypt()
173 .map_err(|e| Error::Other(e.to_string()))?; in decrypt()
179 .map_err(|e| Error::Other(e.to_string()))?; in decrypt()
|
| /webrtc/stun/src/agent/ |
| H A D | agent_test.rs | 17 while let Some(e) = handler_rx.recv().await { in test_agent_process_in_transaction()
18 assert!(e.event_body.is_ok(), "got error: {:?}", e.event_body); in test_agent_process_in_transaction()
22 e.event_body.as_ref().unwrap().transaction_id, in test_agent_process_in_transaction()
25 e.event_body.as_ref().unwrap().transaction_id, in test_agent_process_in_transaction()
42 while let Some(e) = handler_rx.recv().await { in test_agent_process()
43 assert!(e.event_body.is_ok(), "got error: {:?}", e.event_body); in test_agent_process()
47 e.event_body.as_ref().unwrap().transaction_id, in test_agent_process()
50 e.event_body.as_ref().unwrap().transaction_id, in test_agent_process()
|
| /webrtc/mdns/src/conn/ |
| H A D | mod.rs | 70 Ok(e) => e, in server()
71 Err(e) => { in server()
72 log::error!("Error getting interfaces: {:?}", e); in server()
73 return Err(Error::Other(e.to_string())); in server()
78 if let Some(SocketAddr::V4(e)) = interface.addr { in server()
79 if let Err(e) = socket.join_multicast_v4(&Ipv4Addr::new(224, 0, 0, 251), e.ip()) in server()
86 log::trace!("Connected to interface address {:?}", e); in server()
154 Err(e) => { in close()
324 Err(e) => { in run()
328 e in run()
[all …]
|
| /webrtc/webrtc/src/mux/ |
| H A D | mux_test.rs | 20 let e = m.new_endpoint(Box::new(match_all)).await; in pipe_memory() localVariable
21 m.remove_endpoint(&e).await; in pipe_memory()
22 let e = m.new_endpoint(Box::new(match_all)).await; in pipe_memory() localVariable
24 (e, cb) in pipe_memory()
114 let e = m.new_endpoint(Box::new(match_all)).await; in test_non_fatal_read() localVariable
117 let n = e.recv(&mut buff).await?; in test_non_fatal_read()
120 let n = e.recv(&mut buff).await?; in test_non_fatal_read()
123 let n = e.recv(&mut buff).await?; in test_non_fatal_read()
|
| H A D | mod.rs | 68 let e = Arc::new(Endpoint { in new_endpoint() localVariable
76 endpoints.insert(e.id, Arc::clone(&e)); in new_endpoint()
78 e in new_endpoint()
82 pub async fn remove_endpoint(&mut self, e: &Endpoint) { in remove_endpoint()
84 endpoints.remove(&e.id); in remove_endpoint()
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 134 if let Err(e) = self in fetch_inbound_stats()
141 e in fetch_inbound_stats()
163 e in fetch_outbound_stats()
311 let e = lock in bind_remote_stream() localVariable
315 e.clone() in bind_remote_stream()
334 let e = lock in bind_local_stream() localVariable
338 e.clone() in bind_local_stream()
488 .map(|e| e.sr_packets_sent.is_some()) in read()
518 .map(|e| e.dlrr_last_rr.is_some()) in read()
638 e.fir_count = e.fir_count.map(|v| v + 1).or(Some(1)); in write()
[all …]
|
| /webrtc/.github/ |
| H A D | FUNDING.yml | 3 github: webrtc-rs # Replace with up to 4 GitHub Sponsors-enabled usernames e.g., [user1, user2]
7 tidelift: # Replace with a single Tidelift platform-name/package-name e.g., npm/babel
8 community_bridge: # Replace with a single Community Bridge project-name e.g., cloud-foundry
12 custom: # Replace with up to 4 custom sponsorship URLs e.g., ['link1', 'link2']
|
| /webrtc/constraints/src/algorithms/fitness_distance/value_range_constraint/ |
| H A D | tests.rs | 12 expected: $e:expr $(,)?
22 expected: $e
33 expected: $e:expr $(,)?
44 assert_eq!(result, $e);
75 expected: $e:expr $(,)?
81 assert_eq!(result, $e);
|
| /webrtc/constraints/src/algorithms/fitness_distance/value_sequence_constraint/ |
| H A D | tests.rs | 12 expected: $e:expr $(,)?
22 expected: $e
33 expected: $e:expr $(,)?
44 assert_eq!(result, $e);
75 expected: $e:expr $(,)?
81 assert_eq!(result, $e);
|
| /webrtc/constraints/src/algorithms/fitness_distance/value_constraint/ |
| H A D | tests.rs | 12 expected: $e:expr $(,)?
22 expected: $e
33 expected: $e:expr $(,)?
44 assert_eq!(result, $e);
75 expected: $e:expr $(,)?
81 assert_eq!(result, $e);
|
| /webrtc/sctp/src/ |
| H A D | error.rs | 230 e @ Error::ErrEof => io::Error::new(io::ErrorKind::UnexpectedEof, e.to_string()), in from()
231 e @ Error::ErrStreamClosed => { in from()
232 io::Error::new(io::ErrorKind::ConnectionAborted, e.to_string()) in from()
234 e => io::Error::new(io::ErrorKind::Other, e.to_string()), in from()
|
| /webrtc/dtls/src/flight/ |
| H A D | flight0.rs | 103 Extension::SupportedEllipticCurves(e) => { in parse()
104 if e.elliptic_curves.is_empty() { in parse()
113 state.named_curve = e.elliptic_curves[0]; in parse()
115 Extension::UseSrtp(e) => { in parse()
117 &e.protection_profiles, in parse()
136 Extension::ServerName(e) => { in parse()
137 state.server_name = e.server_name.clone(); // remote server name in parse()
|
| /webrtc/stun/src/ |
| H A D | error.rs | 88 fn from(e: io::Error) -> Self { in from()
89 Error::Io(IoError(e)) in from()
95 fn from(e: MpscSendError<T>) -> Self { in from()
96 Error::MpscSend(e.to_string()) in from()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | certificate.rs | 51 .map_err(|e| Error::new(e.to_string()))?, in from_params()
62 .map_err(|e| Error::new(e.to_string()))?, in from_params()
70 .map_err(|e| Error::new(e.to_string()))?, in from_params()
124 pem::parse(first_block).map_err(|e| Error::new(format!("can't parse PEM: {e}")))?; in from_pem()
133 let expires = if let Some(e) = in from_pem()
136 e in from_pem()
|
| /webrtc/webrtc/src/ |
| H A D | error.rs | 433 fn from(e: MpscSendError<T>) -> Self { in from()
434 Error::MpscSend(e.to_string()) in from()
439 fn from(e: Error) -> Self { in from()
441 interceptor::Error::Util(util::Error::from_std(e)) in from()
447 if let Error::Ice(e) = self { in eq()
448 return e == other; in eq()
459 let errs_strs: Vec<String> = errs.into_iter().map(|e| e.into().to_string()).collect(); in flatten_errs()
|
| /webrtc/srtp/src/ |
| H A D | error.rs | 109 fn from(e: io::Error) -> Self { in from()
110 Error::Io(IoError(e)) in from()
116 fn from(e: MpscSendError<T>) -> Self { in from()
117 Error::MpscSend(e.to_string()) in from()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_error.rs | 65 let e = ErrorCause::unmarshal( in unmarshal() localVariable
68 offset += e.length(); in unmarshal()
69 error_causes.push(e); in unmarshal()
|
| H A D | chunk_abort.rs | 63 let e = ErrorCause::unmarshal( in unmarshal() localVariable
66 offset += e.length(); in unmarshal()
67 error_causes.push(e); in unmarshal()
|
| /webrtc/dtls/examples/hub/src/ |
| H A D | utilities.rs | 29 fn from(e: Error) -> Self { in from()
30 dtls::Error::Other(e.to_string()) in from()
35 fn from(e: io::Error) -> Self { in from()
36 Error::Other(e.to_string()) in from()
|
| /webrtc/turn/src/ |
| H A D | error.rs | 181 fn from(e: io::Error) -> Self { in from()
182 Error::Io(IoError(e)) in from()
187 fn from(e: SystemTimeError) -> Self { in from()
188 Error::Other(e.to_string()) in from()
|