| /webrtc/ice/src/agent/ |
| H A D | agent_stats.rs | 218 let mut res = Vec::with_capacity(checklist.len()); in get_candidate_pairs_stats() localVariable
228 res.push(stat); in get_candidate_pairs_stats()
230 res in get_candidate_pairs_stats()
236 let mut res = Vec::with_capacity(local_candidates.len()); in get_local_candidates_stats() localVariable
252 res.push(stat); in get_local_candidates_stats()
255 res in get_local_candidates_stats()
261 let mut res = Vec::with_capacity(remote_candidates.len()); in get_remote_candidates_stats() localVariable
277 res.push(stat); in get_remote_candidates_stats()
280 res in get_remote_candidates_stats()
|
| H A D | mod.rs | 306 let mut res = vec![]; in get_local_candidates() localVariable
312 res.push(Arc::clone(candidate)); in get_local_candidates()
317 Ok(res) in get_local_candidates()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_error.rs | 36 let mut res = vec![self.header().to_string()]; in fmt() localVariable
39 res.push(format!(" - {cause}")); in fmt()
42 write!(f, "{}", res.join("\n")) in fmt()
|
| H A D | chunk_abort.rs | 34 let mut res = vec![self.header().to_string()]; in fmt() localVariable
37 res.push(format!(" - {cause}")); in fmt()
40 write!(f, "{}", res.join("\n")) in fmt()
|
| H A D | chunk_forward_tsn.rs | 40 let mut res = vec![self.header().to_string()]; in fmt() localVariable
41 res.push(format!("New Cumulative TSN: {}", self.new_cumulative_tsn)); in fmt()
43 res.push(format!(" - si={}, ssn={}", s.identifier, s.sequence)); in fmt()
46 write!(f, "{}", res.join("\n")) in fmt()
|
| H A D | chunk_reconfig.rs | 42 let mut res = String::new(); in fmt() localVariable
44 res += format!("Param A:\n {param_a}").as_str(); in fmt()
47 res += format!("Param B:\n {param_b}").as_str() in fmt()
|
| H A D | chunk_init.rs | 97 let mut res = format!( in fmt() localVariable
113 res += format!("Param {i}:\n {param}").as_str(); in fmt()
115 write!(f, "{} {}", self.header(), res) in fmt()
|
| H A D | chunk_selective_ack.rs | 62 let mut res = format!( in fmt() localVariable
68 res += format!("\n gap ack: {gap}").as_str(); in fmt()
|
| /webrtc/rtcp/src/ |
| H A D | util.rs | 106 let res = set_nbits_of_uint16(source, size, index, value); in test_set_nbits_of_uint16() localVariable
108 assert!(res.is_err(), "setNBitsOfUint16 {name} : should be error"); in test_set_nbits_of_uint16()
109 } else if let Ok(got) = res { in test_set_nbits_of_uint16()
|
| /webrtc/turn/src/client/ |
| H A D | relay_conn.rs | 391 let res = { in create_permissions() localVariable
425 if res.typ.class == CLASS_ERROR_RESPONSE { in create_permissions()
427 let result = code.get_from(&res); in create_permissions()
429 return Err(Error::Other(format!("{}", res.typ))); in create_permissions()
431 self.set_nonce_from_msg(&res); in create_permissions()
464 let res = { in refresh_allocation() localVariable
495 if res.typ.class == CLASS_ERROR_RESPONSE { in refresh_allocation()
497 let result = code.get_from(&res); in refresh_allocation()
501 self.set_nonce_from_msg(&res); in refresh_allocation()
510 updated_lifetime.get_from(&res)?; in refresh_allocation()
[all …]
|
| H A D | mod.rs | 507 let res = tr_res.msg; in allocate() localVariable
510 let nonce = Nonce::get_from_as(&res, ATTR_NONCE)?; in allocate()
511 self.realm = Realm::get_from_as(&res, ATTR_REALM)?; in allocate()
537 let res = tr_res.msg; in allocate() localVariable
539 if res.typ.class == CLASS_ERROR_RESPONSE { in allocate()
541 let result = code.get_from(&res); in allocate()
543 return Err(Error::Other(format!("{}", res.typ))); in allocate()
545 return Err(Error::Other(format!("{} (error {})", res.typ, code))); in allocate()
551 relayed.get_from(&res)?; in allocate()
556 lifetime.get_from(&res)?; in allocate()
|
| H A D | transaction.rs | 208 pub async fn write_result(&self, res: TransactionResult) -> bool { in write_result()
210 result_ch.send(res).await.is_ok() in write_result()
|
| /webrtc/mdns/src/conn/ |
| H A D | conn_test.rs | 38 let res = server_a.query("invalid-host", b).await; in test_query_respect_timeout() localVariable
39 assert!(res.is_err(), "server_a.query expects timeout!"); in test_query_respect_timeout()
|
| H A D | mod.rs | 200 if let Some(res) = res_opt{ in query()
201 return Ok((res.answer, res.addr)); in query()
|
| /webrtc/ice/src/util/ |
| H A D | mod.rs | 83 let mut res = Message::new(); in stun_request() localVariable
84 res.raw = bs[..n].to_vec(); in stun_request()
85 res.decode()?; in stun_request()
87 Ok(res) in stun_request()
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_test.rs | 141 let res = udp_mux.close().await; in test_udp_mux() localVariable
142 assert!(res.is_ok()); in test_udp_mux()
143 let res = udp_mux.get_conn("failurefrag").await; in test_udp_mux() localVariable
146 res.is_err(), in test_udp_mux()
274 let res = conn.close().await; in test_mux_connection() localVariable
275 assert!(res.is_ok(), "Failed to close Conn: {res:?}"); in test_mux_connection()
|
| H A D | mod.rs | 172 res = conn.recv_from(&mut buffer) => { in start_conn_worker()
173 match res { in start_conn_worker()
|
| /webrtc/rtp/src/codecs/h264/ |
| H A D | h264_test.rs | 253 let res = pck.payload(1500, &Bytes::from_static(&[0x07, 0x00, 0x01]))?; in test_h264_payloader_payload_sps_and_pps_handling() localVariable
254 assert!(res.is_empty(), "Generated payload should be empty"); in test_h264_payloader_payload_sps_and_pps_handling()
256 let res = pck.payload(1500, &Bytes::from_static(&[0x08, 0x02, 0x03]))?; in test_h264_payloader_payload_sps_and_pps_handling() localVariable
257 assert!(res.is_empty(), "Generated payload should be empty"); in test_h264_payloader_payload_sps_and_pps_handling()
|
| /webrtc/rtp/src/packet/ |
| H A D | packet_test.rs | 585 let res = p.header.get_extension(1); in test_rfc8285_get_extension_returns_nil_when_extension_disabled() localVariable
587 res.is_none(), in test_rfc8285_get_extension_returns_nil_when_extension_disabled()
791 let res = p.header.set_extension(1, extension); in test_rfc8285_set_extension_should_set_correct_extension_profile_for_16_byte_extension() localVariable
792 assert!(res.is_ok(), "Error setting extension"); in test_rfc8285_set_extension_should_set_correct_extension_profile_for_16_byte_extension()
922 let res = p.header.set_extension( in test_rfc8285_one_byte_set_extension_should_error_when_payload_too_large() localVariable
931 res.is_err(), in test_rfc8285_one_byte_set_extension_should_error_when_payload_too_large()
1045 let res = p.header.set_extension( in test_rfc8285_two_byte_set_extension_should_error_when_payload_too_large() localVariable
1071 res.is_err(), in test_rfc8285_two_byte_set_extension_should_error_when_payload_too_large()
1100 let res = p.header.get_extension(0); in test_rfc3550_set_extension_should_error_when_non_zero() localVariable
1102 res, in test_rfc3550_set_extension_should_error_when_non_zero()
[all …]
|
| /webrtc/rtp/src/codecs/vp9/ |
| H A D | vp9_test.rs | 317 let res = pck.payload(4, &Bytes::from_static(&[0x01]))?; in test_vp9_payloader_payload() localVariable
319 p.depacketize(&res[0])?; in test_vp9_payloader_payload()
|
| /webrtc/sctp/src/ |
| H A D | packet.rs | 66 let mut res = format!( in fmt() localVariable
75 res += format!("Chunk: {chunk}").as_str(); in fmt()
|
| /webrtc/examples/examples/ice-restart/ |
| H A D | ice-restart.rs | 187 Ok(res) => res, in do_signaling()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 176 res = State::error_on_close(&mut state_watch_rx) => { in read()
177 res? in read()
208 res = State::error_on_close(&mut state_watch_rx) => { in read_simulcast()
209 res? in read_simulcast()
|
| /webrtc/stun/src/ |
| H A D | client.rs | 232 res = c.recv(&mut buf) => { in read_until_closed()
233 if let Ok(n) = res { in read_until_closed()
|
| /webrtc/examples/examples/play-from-disk-renegotiation/ |
| H A D | play-from-disk-renegotiation.rs | 139 Ok(res) => res, in do_signaling()
|