| /webrtc/mdns/src/message/ |
| H A D | parser.rs | 41 Ok(self.header.header()) in start()
57 Ok(()) in check_advance()
67 Ok(Resource { in resource()
84 Ok(hdr) in resource_header()
96 return Ok(()); in skip_resource()
102 Ok(()) in skip_resource()
150 Ok(()) in skip_question()
158 return Ok(()); in skip_all_questions()
212 return Ok(()); in skip_all_answers()
266 return Ok(()); in skip_all_authorities()
[all …]
|
| H A D | builder.rs | 92 Ok(()) in start_check()
99 Ok(()) in start_questions()
106 Ok(()) in start_answers()
113 Ok(()) in start_authorities()
120 Ok(()) in start_additionals()
139 Ok(()) in increment_section_count()
158 Ok(()) in add_question()
168 Ok(()) in check_resource_section()
192 Ok(()) in add_resource()
207 Ok(msg) in finish()
|
| /webrtc/data/src/message/ |
| H A D | message_channel_open.rs | 83 Ok(1) in marshal_to()
182 Ok(self.marshal_size()) in marshal_to()
221 Ok(Self { in unmarshal()
242 Ok(()) in test_channel_type_unmarshal_success()
252 return Ok(()); in test_channel_type_unmarshal_invalid()
274 return Ok(()); in test_channel_type_unmarshal_unexpected_end_of_buffer()
291 Ok(()) in test_channel_type_marshal_size()
304 Ok(()) in test_channel_type_marshal()
328 Ok(()) in test_channel_open_unmarshal_success()
418 Ok(()) in test_channel_open_marshal_size()
[all …]
|
| H A D | message_type.rs | 33 Ok(1) in marshal_to()
54 MESSAGE_TYPE_ACK => Ok(Self::DataChannelAck), in unmarshal()
55 MESSAGE_TYPE_OPEN => Ok(Self::DataChannelOpen), in unmarshal()
73 Ok(()) in test_message_type_unmarshal_open_success()
82 Ok(()) in test_message_type_unmarshal_ack_success()
89 Ok(_) => panic!("expected Error, but got Ok"), in test_message_type_unmarshal_invalid()
92 return Ok(()); in test_message_type_unmarshal_invalid()
109 Ok(()) in test_message_type_marshal_size()
122 Ok(()) in test_message_type_marshal()
|
| H A D | message_channel_ack.rs | 27 Ok(0) in marshal_to()
37 Ok(Self) in unmarshal()
53 Ok(()) in test_channel_ack_unmarshal()
62 Ok(()) in test_channel_ack_marshal_size()
74 Ok(()) in test_channel_ack_marshal()
|
| /webrtc/util/src/conn/ |
| H A D | conn_udp.rs | 8 Ok(self.connect(addr).await?) in connect()
12 Ok(self.recv(buf).await?) in recv()
16 Ok(self.recv_from(buf).await?) in recv_from()
20 Ok(self.send(buf).await?) in send()
24 Ok(self.send_to(buf, target).await?) in send_to()
28 Ok(self.local_addr()?) in local_addr()
36 Ok(()) in close()
|
| H A D | conn_bridge_test.rs | 25 Result::<()>::Ok(()) in test_bridge_normal()
33 Ok(()) in test_bridge_normal()
51 Result::<()>::Ok(()) in test_bridge_drop_1st_packet_from_conn0()
60 Ok(()) in test_bridge_drop_1st_packet_from_conn0()
87 Ok(()) in test_bridge_drop_2nd_packet_from_conn0()
114 Ok(()) in test_bridge_drop_1st_packet_from_conn1()
141 Ok(()) in test_bridge_drop_2nd_packet_from_conn1()
172 Ok(()) in test_bridge_reorder_packets_from_conn0()
203 Ok(()) in test_bridge_reorder_packets_from_conn1()
211 Ok(()) in test_bridge_inverse_error()
[all …]
|
| /webrtc/sdp/src/description/ |
| H A D | session.rs | 338 Ok(codec.clone()) in get_codec_for_payload_type()
563 Ok(lexer.desc) in unmarshal()
578 Ok(session_description) in try_from()
705 return Ok(None); in s9()
752 return Ok(None); in s11()
769 return Ok(None); in s12()
798 return Ok(None); in s13()
818 return Ok(None); in s14()
851 return Ok(None); in s15()
881 return Ok(None); in s16()
[all …]
|
| /webrtc/sctp/src/param/ |
| H A D | mod.rs | 48 Ok(buf.freeze()) in marshal()
65 ParamType::ForwardTsnSupp => Ok(Box::new(ParamForwardTsnSupported::unmarshal(raw_param)?)), in build_param()
66 ParamType::SupportedExt => Ok(Box::new(ParamSupportedExtensions::unmarshal(raw_param)?)), in build_param()
67 ParamType::Random => Ok(Box::new(ParamRandom::unmarshal(raw_param)?)), in build_param()
68 ParamType::ReqHmacAlgo => Ok(Box::new(ParamRequestedHmacAlgorithm::unmarshal(raw_param)?)), in build_param()
69 ParamType::ChunkList => Ok(Box::new(ParamChunkList::unmarshal(raw_param)?)), in build_param()
70 ParamType::StateCookie => Ok(Box::new(ParamStateCookie::unmarshal(raw_param)?)), in build_param()
71 ParamType::HeartbeatInfo => Ok(Box::new(ParamHeartbeatInfo::unmarshal(raw_param)?)), in build_param()
72 ParamType::OutSsnResetReq => Ok(Box::new(ParamOutgoingResetRequest::unmarshal(raw_param)?)), in build_param()
73 ParamType::ReconfigResp => Ok(Box::new(ParamReconfigResponse::unmarshal(raw_param)?)), in build_param()
[all …]
|
| H A D | param_test.rs | 20 Ok(()) in test_parse_param_type_success()
47 Ok(()) in test_param_header_success()
67 Ok(()) in test_param_header_unmarshal_failure()
91 Ok(()) in test_param_forward_tsn_supported_success()
103 Ok(()) in test_param_forward_tsn_supported_failure()
149 Ok(()) in test_param_outgoing_reset_request_success()
164 Ok(()) in test_param_outgoing_reset_request_failure()
193 Ok(()) in test_param_reconfig_response_success()
211 Ok(()) in test_param_reconfig_response_failure()
237 Ok(()) in test_reconfig_result_stringer()
[all …]
|
| /webrtc/dtls/examples/hub/src/ |
| H A D | utilities.rs | 46 while let Ok(n) = conn_rx.recv(&mut b).await { in chat()
51 Result::<(), Error>::Ok(()) in chat()
59 Ok(0) => return Ok(()), in chat()
62 return Ok(()); in chat()
67 return Ok(()); in chat()
83 Ok(Certificate { in load_key_and_certificate()
100 Ok(CryptoPrivateKey::from_key_pair(&key_pair).expect("crypto key pair")) in load_key()
109 Ok(ders) => Ok(ders), in load_certificate()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | srtp_writer_future.rs | 128 return Ok(()); in init()
160 Ok(()) in init()
165 return Ok(()); in close()
174 Ok(rtcp_read_stream.close().await?) in close()
176 Ok(()) in close()
187 return Ok(rtcp_read_stream.read(b).await?); in read()
203 Ok(0) in read()
229 Ok(0) in write_rtp()
255 Ok(0) in write()
264 Ok((self.read(buf).await?, a.clone())) in read()
[all …]
|
| /webrtc/rtp/src/extension/video_orientation_extension/ |
| H A D | mod.rs | 83 Ok(VideoOrientationExtension { in unmarshal()
99 Ok(VIDEO_ORIENTATION_EXTENSION_SIZE) in marshal_to()
108 0 => Ok(CameraDirection::Front), in try_from()
109 1 => Ok(CameraDirection::Back), in try_from()
122 0 => Ok(VideoRotation::Degree0), in try_from()
123 1 => Ok(VideoRotation::Degree90), in try_from()
124 2 => Ok(VideoRotation::Degree180), in try_from()
125 3 => Ok(VideoRotation::Degree270), in try_from()
|
| /webrtc/ice/src/udp_mux/ |
| H A D | socket_addr_ext.rs | 44 Ok(7) in encode()
59 Ok(MAX_ADDR_SIZE) in encode()
76 Ok(input) => u16::from_le_bytes(*input), in decode()
95 Ok(input) => Ipv6Addr::from(*input), in decode()
99 Ok(input) => u16::from_le_bytes(*input), in decode()
104 Ok(input) => u32::from_le_bytes(*input), in decode()
112 Ok(SocketAddr::V6(SocketAddrV6::new( in decode()
133 assert_eq!(encoded_len, Ok(7)); in test_ipv4()
141 assert_eq!(decoded, Ok(ip)); in test_ipv4()
158 assert_eq!(encoded_len, Ok(27)); in test_ipv6()
[all …]
|
| /webrtc/dtls/src/ |
| H A D | handshaker.rs | 173 return Ok(cert.clone()); in get_certificate()
183 return Ok(cert.clone()); in get_certificate()
188 Ok(self.local_certificates[0].clone()) in get_certificate()
212 return Ok(()); in handshake()
251 Ok(pkts) => { in prepare()
292 Ok(HandshakeState::Sending) in prepare()
301 Ok(HandshakeState::Finished) in send()
303 Ok(HandshakeState::Waiting) in send()
342 Ok(next_flight) => { in wait()
393 Ok(_) => { in finish()
[all …]
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_test.rs | 39 Ok(()) in test_chunk_type_string()
67 Ok(()) in test_abort_chunk_one_error_cause()
100 Ok(()) in test_abort_chunk_many_error_causes()
142 Ok(()) in test_chunk_error_unrecognized_chunk_type_unmarshal()
159 Ok(()) in test_chunk_error_unrecognized_chunk_type_marshal()
178 Ok(()) in test_chunk_error_unrecognized_chunk_type_marshal_with_cause_value_being_nil()
205 Ok(()) in test_chunk_forward_tsn_success()
229 Ok(()) in test_chunk_forward_tsn_unmarshal_failure()
298 Ok(()) in test_chunk_reconfig_success()
325 Ok(()) in test_chunk_reconfig_unmarshal_failure()
[all …]
|
| /webrtc/constraints/src/algorithms/fitness_distance/ |
| H A D | value_constraint.rs | 57 Ok(0.0)
65 Ok(1.0)
75 Ok(0.0)
135 Ok(super::relative_fitness_distance(actual, ideal))
143 Ok(1.0)
153 Ok(0.0)
199 Ok(0.0)
201 Ok(1.0)
210 None => Ok(0.0),
|
| H A D | empty_constraint.rs | 15 Ok(0.0) in fitness_distance()
44 expected: Ok(0.0) in bool()
52 expected: Ok(0.0) in string()
60 expected: Ok(0.0) in i64()
68 expected: Ok(0.0) in f64()
|
| /webrtc/examples/examples/ice-restart/ |
| H A D | ice-restart.rs | 50 Ok(not_found()) in simple_file_send()
64 Ok(not_found) in remote_handler()
81 Ok(_) => {} in do_signaling()
93 Ok(r) => r, in do_signaling()
105 Ok(p) => p, in do_signaling()
147 Ok(s) => s, in do_signaling()
160 Ok(answer) => answer, in do_signaling()
176 Ok(p) => p, in do_signaling()
187 Ok(res) => res, in do_signaling()
192 Ok(response) in do_signaling()
[all …]
|
| /webrtc/constraints/src/algorithms/fitness_distance/value_constraint/tests/ |
| H A D | f64.rs | 30 expected: Ok(0.0)
47 expected: Ok(0.75), in i64_setting()
55 expected: Ok(0.5), in i64_setting()
63 expected: Ok(0.25), in i64_setting()
82 expected: Ok(0.75), in f64_setting()
90 expected: Ok(0.5), in f64_setting()
98 expected: Ok(0.25), in f64_setting()
126 expected: Ok(1.0)
152 expected: Ok(0.0)
|
| /webrtc/ice/src/external_ip_mapper/ |
| H A D | mod.rs | 12 Ok(ip) => Ok(ip), in validate_ip_string()
32 Ok(()) in set_sole_ip()
49 Ok(()) in add_ip_mapping()
54 return Ok(*ip_sole); in find_external_ip()
59 |ext_ip| Ok(*ext_ip), in find_external_ip()
74 return Ok(None); in new()
121 Ok(Some(m)) in new()
|
| /webrtc/constraints/src/algorithms/fitness_distance/value_range_constraint/tests/ |
| H A D | u64.rs | 28 expected: Ok(0.0)
50 expected: Ok(0.0)
69 expected: Ok(0.75), in i64_setting()
79 expected: Ok(0.5), in i64_setting()
89 expected: Ok(0.25), in i64_setting()
110 expected: Ok(0.75), in f64_setting()
120 expected: Ok(0.5), in f64_setting()
130 expected: Ok(0.25), in f64_setting()
160 expected: Ok(1.0)
188 expected: Ok(0.0)
[all …]
|
| H A D | f64.rs | 28 expected: Ok(0.0)
50 expected: Ok(0.0)
69 expected: Ok(0.75), in i64_setting()
79 expected: Ok(0.5), in i64_setting()
89 expected: Ok(0.25), in i64_setting()
110 expected: Ok(0.75), in f64_setting()
120 expected: Ok(0.5), in f64_setting()
130 expected: Ok(0.25), in f64_setting()
160 expected: Ok(1.0)
188 expected: Ok(0.0)
[all …]
|
| /webrtc/dtls/src/cipher_suite/ |
| H A D | mod.rs | 144 Ok(Box::new(new_cipher_suite_tls_ecdhe_ecdsa_with_aes_128_ccm())) in cipher_suite_for_id()
146 CipherSuiteId::Tls_Ecdhe_Ecdsa_With_Aes_128_Ccm_8 => Ok(Box::new( in cipher_suite_for_id()
150 Ok(Box::new(CipherSuiteAes128GcmSha256::new(false))) in cipher_suite_for_id()
153 Ok(Box::new(CipherSuiteAes128GcmSha256::new(true))) in cipher_suite_for_id()
156 Ok(Box::new(CipherSuiteAes256CbcSha::new(true))) in cipher_suite_for_id()
159 Ok(Box::new(CipherSuiteAes256CbcSha::new(false))) in cipher_suite_for_id()
162 Ok(Box::new(new_cipher_suite_tls_psk_with_aes_128_ccm())) in cipher_suite_for_id()
165 Ok(Box::new(new_cipher_suite_tls_psk_with_aes_128_ccm8())) in cipher_suite_for_id()
168 Ok(Box::<CipherSuiteTlsPskWithAes128GcmSha256>::default()) in cipher_suite_for_id()
203 Ok(cipher_suites) in cipher_suites_for_ids()
[all …]
|
| /webrtc/data/src/data_channel/ |
| H A D | mod.rs | 93 return Ok(ch); in accept()
149 Ok(data_channel) in server()
184 Ok(()) => {} in read_data_channel()
207 return Ok((n, is_string)); in read_data_channel()
255 Ok(()) in handle_dcep()
294 Ok(n) in write_data_channel()
299 Ok(self in write_data_channel_ack()
559 return Poll::Ready(Ok(0)); in poll_write()
606 Poll::Ready(Ok(n)) in poll_write()
655 Poll::Ready(Ok(_)) => { in poll_shutdown()
[all …]
|