| /webrtc/dtls/src/alert/ |
| H A D | mod.rs | 19 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 21 AlertLevel::Warning => write!(f, "LevelWarning"), in fmt() 22 AlertLevel::Fatal => write!(f, "LevelFatal"), in fmt() 23 _ => write!(f, "Invalid alert level"), in fmt() 69 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 71 AlertDescription::CloseNotify => write!(f, "CloseNotify"), in fmt() 73 AlertDescription::BadRecordMac => write!(f, "BadRecordMac"), in fmt() 85 AlertDescription::UnknownCa => write!(f, "UnknownCA"), in fmt() 87 AlertDescription::DecodeError => write!(f, "DecodeError"), in fmt() 96 _ => write!(f, "Invalid alert description"), in fmt() [all …]
|
| /webrtc/util/src/vnet/chunk/ |
| H A D | chunk_test.rs | 7 let f = TCP_FLAG_FIN; in test_tcp_frag_string() localVariable 8 assert_eq!(f.to_string(), "FIN", "should match"); in test_tcp_frag_string() 9 let f = TCP_FLAG_SYN; in test_tcp_frag_string() localVariable 10 assert_eq!(f.to_string(), "SYN", "should match"); in test_tcp_frag_string() 11 let f = TCP_FLAG_RST; in test_tcp_frag_string() localVariable 12 assert_eq!(f.to_string(), "RST", "should match"); in test_tcp_frag_string() 13 let f = TCP_FLAG_PSH; in test_tcp_frag_string() localVariable 14 assert_eq!(f.to_string(), "PSH", "should match"); in test_tcp_frag_string() 15 let f = TCP_FLAG_ACK; in test_tcp_frag_string() localVariable 16 assert_eq!(f.to_string(), "ACK", "should match"); in test_tcp_frag_string() [all …]
|
| /webrtc/sdp/src/description/ |
| H A D | common.rs | 17 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 19 write!(f, "{} {} {}", self.network_type, self.address_type, address,) in fmt() 21 write!(f, "{} {}", self.network_type, self.address_type,) in fmt() 35 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 43 write!(f, "{}", parts.join("/")) in fmt() 57 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 59 write!(f, "{}{}:{}", output, self.bandwidth_type, self.bandwidth) in fmt() 75 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 77 write!(f, "{}:{}", self.key, value) in fmt() 79 write!(f, "{}", self.key) in fmt()
|
| H A D | session.rs | 59 f, in fmt() 597 f: unmarshal_origin, in s2() 921 Ok(Some(StateFn { f: s2 })) in unmarshal_protocol_version() 962 Ok(Some(StateFn { f: s3 })) in unmarshal_origin() 970 Ok(Some(StateFn { f: s4 })) in unmarshal_session_name() 978 Ok(Some(StateFn { f: s7 })) in unmarshal_session_information() 994 Ok(Some(StateFn { f: s6 })) in unmarshal_email() 1002 Ok(Some(StateFn { f: s8 })) in unmarshal_phone() 1010 Ok(Some(StateFn { f: s5 })) in unmarshal_session_connection_information() 1055 Ok(Some(StateFn { f: s5 })) in unmarshal_session_bandwidth() [all …]
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_interceptor.rs | 66 if let Some(f) = &self.bind_rtcp_reader_fn { in bind_rtcp_reader() 67 f(reader).await in bind_rtcp_reader() 79 if let Some(f) = &self.bind_rtcp_writer_fn { in bind_rtcp_writer() 80 f(writer).await in bind_rtcp_writer() 93 if let Some(f) = &self.bind_local_stream_fn { in bind_local_stream() 94 f(info, writer).await in bind_local_stream() 103 f(info).await in unbind_local_stream() 115 f(info, reader).await in bind_remote_stream() 124 f(info).await in unbind_remote_stream() 130 if let Some(f) = &self.close_fn { in close() [all …]
|
| /webrtc/constraints/src/ |
| H A D | enumerations.rs | 43 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt() 45 Self::User => f.write_str("user"), in fmt() 46 Self::Environment => f.write_str("environment"), in fmt() 47 Self::Left => f.write_str("left"), in fmt() 48 Self::Right => f.write_str("right"), in fmt() 90 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt() 92 Self::None => f.write_str("none"), in fmt() 93 Self::CropAndScale => f.write_str("crop-and-scale"), in fmt()
|
| /webrtc/rtp/src/extension/abs_send_time_extension/ |
| H A D | mod.rs | 90 let mut f = u % 1_000_000_000; in unix2ntp() localVariable 91 f <<= 32; in unix2ntp() 92 f /= 1_000_000_000; in unix2ntp() 95 s | f in unix2ntp() 100 let mut f = t & 0xFFFFFFFF; in ntp2unix() localVariable 101 f *= 1_000_000_000; in ntp2unix() 102 f >>= 32; in ntp2unix() 104 let u = s * 1_000_000_000 + f; in ntp2unix()
|
| /webrtc/interceptor/src/twcc/ |
| H A D | twcc_test.rs | 184 let mut f = Feedback::default(); in test_feedback() localVariable 185 let got = f.add_received(0, 10); in test_feedback() 191 let mut f = Feedback::default(); in test_feedback() localVariable 198 let mut f = Feedback::default(); in test_feedback() localVariable 199 f.set_base(1, 1000 * 1000); in test_feedback() 214 assert!(!f in test_feedback() 223 f.set_base(5, 320 * 1000); in test_feedback() 234 let pkt = f.get_rtcp(); in test_feedback() 288 f.set_base(65535, 320 * 1000); in test_feedback() 299 let pkt = f.get_rtcp(); in test_feedback() [all …]
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | ice_gatherer_state.rs | 55 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 57 RTCIceGathererState::New => write!(f, "{ICE_GATHERED_STATE_NEW_STR}"), in fmt() 58 RTCIceGathererState::Gathering => write!(f, "{ICE_GATHERED_STATE_GATHERING_STR}"), in fmt() 60 write!(f, "{ICE_GATHERED_STATE_COMPLETE_STR}") in fmt() 63 write!(f, "{ICE_GATHERED_STATE_CLOSED_STR}") in fmt() 65 _ => write!(f, "{}", crate::UNSPECIFIED_STR), in fmt()
|
| H A D | ice_transport_state.rs | 86 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 88 RTCIceTransportState::New => write!(f, "{ICE_TRANSPORT_STATE_NEW_STR}"), in fmt() 89 RTCIceTransportState::Checking => write!(f, "{ICE_TRANSPORT_STATE_CHECKING_STR}"), in fmt() 91 write!(f, "{ICE_TRANSPORT_STATE_CONNECTED_STR}") in fmt() 93 RTCIceTransportState::Completed => write!(f, "{ICE_TRANSPORT_STATE_COMPLETED_STR}"), in fmt() 95 write!(f, "{ICE_TRANSPORT_STATE_FAILED_STR}") in fmt() 98 write!(f, "{ICE_TRANSPORT_STATE_DISCONNECTED_STR}") in fmt() 101 write!(f, "{ICE_TRANSPORT_STATE_CLOSED_STR}") in fmt() 103 _ => write!(f, "{}", crate::UNSPECIFIED_STR), in fmt()
|
| H A D | ice_gathering_state.rs | 40 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 42 RTCIceGatheringState::New => write!(f, "{ICE_GATHERING_STATE_NEW_STR}"), in fmt() 43 RTCIceGatheringState::Gathering => write!(f, "{ICE_GATHERING_STATE_GATHERING_STR}"), in fmt() 45 write!(f, "{ICE_GATHERING_STATE_COMPLETE_STR}") in fmt() 47 _ => write!(f, "{}", crate::UNSPECIFIED_STR), in fmt()
|
| H A D | ice_candidate_type.rs | 73 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 75 RTCIceCandidateType::Host => write!(f, "{ICE_CANDIDATE_TYPE_HOST_STR}"), in fmt() 76 RTCIceCandidateType::Srflx => write!(f, "{ICE_CANDIDATE_TYPE_SRFLX_STR}"), in fmt() 77 RTCIceCandidateType::Prflx => write!(f, "{ICE_CANDIDATE_TYPE_PRFLX_STR}"), in fmt() 78 RTCIceCandidateType::Relay => write!(f, "{ICE_CANDIDATE_TYPE_RELAY_STR}"), in fmt() 79 _ => write!(f, "{}", crate::UNSPECIFIED_STR), in fmt()
|
| H A D | ice_role.rs | 35 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 37 RTCIceRole::Controlling => write!(f, "{ICE_ROLE_CONTROLLING_STR}"), in fmt() 38 RTCIceRole::Controlled => write!(f, "{ICE_ROLE_CONTROLLED_STR}"), in fmt() 39 _ => write!(f, "{}", crate::UNSPECIFIED_STR), in fmt()
|
| H A D | ice_credential_type.rs | 34 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 36 RTCIceCredentialType::Password => write!(f, "{ICE_CREDENTIAL_TYPE_PASSWORD_STR}"), in fmt() 37 RTCIceCredentialType::Oauth => write!(f, "{ICE_CREDENTIAL_TYPE_OAUTH_STR}"), in fmt() 38 _ => write!(f, "{}", crate::UNSPECIFIED_STR), in fmt()
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | mod.rs | 209 pub fn on_open(&self, f: OnOpenHdlrFn) { in on_open() 226 if let Some(f) = on_open_handler { in do_open() 227 f().await; in do_open() 243 pub fn on_close(&self, f: OnCloseHdlrFn) { in on_close() 259 let mut f = handler.lock().await; in do_message() localVariable 260 f(msg).await; in do_message() 295 pub fn on_error(&self, f: OnErrorHdlrFn) { in on_error() 323 f().await; in read_loop() 345 f().await; in read_loop() 357 f(DataChannelMessage { in read_loop() [all …]
|
| /webrtc/dtls/src/signature_hash_algorithm/ |
| H A D | mod.rs | 42 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 44 HashAlgorithm::Md2 => write!(f, "md2"), in fmt() 45 HashAlgorithm::Md5 => write!(f, "md5"), // [RFC3279] in fmt() 46 HashAlgorithm::Sha1 => write!(f, "sha-1"), // [RFC3279] in fmt() 47 HashAlgorithm::Sha224 => write!(f, "sha-224"), // [RFC4055] in fmt() 48 HashAlgorithm::Sha256 => write!(f, "sha-256"), // [RFC4055] in fmt() 49 HashAlgorithm::Sha384 => write!(f, "sha-384"), // [RFC4055] in fmt() 50 HashAlgorithm::Sha512 => write!(f, "sha-512"), // [RFC4055] in fmt() 51 HashAlgorithm::Ed25519 => write!(f, "null"), // [RFC4055] in fmt() 52 _ => write!(f, "unknown or unsupported hash algorithm"), in fmt()
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | sdp_type.rs | 56 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 58 RTCSdpType::Offer => write!(f, "{SDP_TYPE_OFFER_STR}"), in fmt() 59 RTCSdpType::Pranswer => write!(f, "{SDP_TYPE_PRANSWER_STR}"), in fmt() 60 RTCSdpType::Answer => write!(f, "{SDP_TYPE_ANSWER_STR}"), in fmt() 61 RTCSdpType::Rollback => write!(f, "{SDP_TYPE_ROLLBACK_STR}"), in fmt() 62 _ => write!(f, "{}", crate::UNSPECIFIED_STR), in fmt()
|
| /webrtc/dtls/src/fragment_buffer/ |
| H A D | mod.rs | 131 .map(|fragment| fragment.iter().map(|f| f.data.len()).sum::<usize>()) in size() 137 for f in frags { in append_message() 138 if f.handshake_header.fragment_offset == target_offset { in append_message() 140 f.handshake_header.fragment_offset + f.handshake_header.fragment_length; in append_message() 144 if fragment_end != f.handshake_header.length in append_message() 145 && f.handshake_header.fragment_length != 0 in append_message() 152 message.extend_from_slice(&f.data); in append_message()
|
| /webrtc/dtls/src/cipher_suite/ |
| H A D | mod.rs | 50 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 53 write!(f, "TLS_ECDHE_ECDSA_WITH_AES_128_CCM") in fmt() 56 write!(f, "TLS_ECDHE_ECDSA_WITH_AES_128_CCM_8") in fmt() 59 write!(f, "TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256") in fmt() 62 write!(f, "TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256") in fmt() 65 write!(f, "TLS_ECDHE_ECDSA_WITH_AES_256_CBC_SHA") in fmt() 68 write!(f, "TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA") in fmt() 70 CipherSuiteId::Tls_Psk_With_Aes_128_Ccm => write!(f, "TLS_PSK_WITH_AES_128_CCM"), in fmt() 71 CipherSuiteId::Tls_Psk_With_Aes_128_Ccm_8 => write!(f, "TLS_PSK_WITH_AES_128_CCM_8"), in fmt() 73 write!(f, "TLS_PSK_WITH_AES_128_GCM_SHA256") in fmt() [all …]
|
| /webrtc/webrtc/src/peer_connection/policy/ |
| H A D | bundle_policy.rs | 52 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 54 RTCBundlePolicy::Balanced => write!(f, "{BUNDLE_POLICY_BALANCED_STR}"), in fmt() 55 RTCBundlePolicy::MaxCompat => write!(f, "{BUNDLE_POLICY_MAX_COMPAT_STR}"), in fmt() 56 RTCBundlePolicy::MaxBundle => write!(f, "{BUNDLE_POLICY_MAX_BUNDLE_STR}"), in fmt() 57 _ => write!(f, "{}", crate::UNSPECIFIED_STR), in fmt()
|
| /webrtc/dtls/src/handshake/ |
| H A D | mod.rs | 55 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 57 HandshakeType::HelloRequest => write!(f, "HelloRequest"), in fmt() 58 HandshakeType::ClientHello => write!(f, "ClientHello"), in fmt() 59 HandshakeType::ServerHello => write!(f, "ServerHello"), in fmt() 61 HandshakeType::Certificate => write!(f, "Certificate"), in fmt() 62 HandshakeType::ServerKeyExchange => write!(f, "ServerKeyExchange"), in fmt() 64 HandshakeType::ServerHelloDone => write!(f, "ServerHelloDone"), in fmt() 65 HandshakeType::CertificateVerify => write!(f, "CertificateVerify"), in fmt() 66 HandshakeType::ClientKeyExchange => write!(f, "ClientKeyExchange"), in fmt() 67 HandshakeType::Finished => write!(f, "Finished"), in fmt() [all …]
|
| /webrtc/turn/src/allocation/ |
| H A D | five_tuple.rs | 33 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 34 write!(f, "{}_{}_{}", self.protocol, self.src_addr, self.dst_addr) in fmt() 39 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 40 f.debug_struct("FiveTuple") in fmt()
|
| /webrtc/rtp/src/extension/ |
| H A D | mod.rs | 80 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt() 84 AbsSendTime(ext) => f.debug_tuple("AbsSendTime").field(ext).finish(), in fmt() 85 AudioLevel(ext) => f.debug_tuple("AudioLevel").field(ext).finish(), in fmt() 86 TransportCc(ext) => f.debug_tuple("TransportCc").field(ext).finish(), in fmt() 87 VideoOrientation(ext) => f.debug_tuple("VideoOrientation").field(ext).finish(), in fmt() 88 Custom { uri, extension: _ } => f.debug_struct("Custom").field("uri", uri).finish(), in fmt()
|
| /webrtc/turn/src/proto/ |
| H A D | addr.rs | 25 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 26 write!(f, "{}:{}", self.ip, self.port) in fmt() 59 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 60 write!(f, "{}->{} ({})", self.client, self.server, self.proto) in fmt()
|
| /webrtc/ice/src/state/ |
| H A D | mod.rs | 40 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 51 write!(f, "{s}") in fmt() 103 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() 110 write!(f, "{s}") in fmt()
|