| /webrtc/util/src/conn/ |
| H A D | mod.rs | 24 use crate::error::Result;
28 async fn connect(&self, addr: SocketAddr) -> Result<()>; in connect() argument
29 async fn recv(&self, buf: &mut [u8]) -> Result<usize>; in recv()
30 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)>; in recv_from()
31 async fn send(&self, buf: &[u8]) -> Result<usize>; in send()
32 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize>; in send_to()
33 fn local_addr(&self) -> Result<SocketAddr>; in local_addr()
35 async fn close(&self) -> Result<()>; in close() argument
47 async fn close(&self) -> Result<()>; in close() argument
50 async fn addr(&self) -> Result<SocketAddr>; in addr()
[all …]
|
| H A D | conn_udp.rs | 7 async fn connect(&self, addr: SocketAddr) -> Result<()> { in connect() argument
11 async fn recv(&self, buf: &mut [u8]) -> Result<usize> { in recv()
15 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from()
19 async fn send(&self, buf: &[u8]) -> Result<usize> { in send()
23 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize> { in send_to()
27 fn local_addr(&self) -> Result<SocketAddr> { in local_addr()
35 async fn close(&self) -> Result<()> { in close() argument
|
| H A D | conn_disconnected_packet.rs | 27 async fn connect(&self, addr: SocketAddr) -> Result<()> { in connect() argument
31 async fn recv(&self, buf: &mut [u8]) -> Result<usize> { in recv()
37 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from()
41 async fn send(&self, buf: &[u8]) -> Result<usize> { in send()
46 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize> { in send_to()
50 fn local_addr(&self) -> Result<SocketAddr> { in local_addr()
59 async fn close(&self) -> Result<()> { in close() argument
|
| H A D | conn_bridge_test.rs | 13 async fn test_bridge_normal() -> Result<()> { in test_bridge_normal()
25 Result::<()>::Ok(()) in test_bridge_normal()
51 Result::<()>::Ok(()) in test_bridge_drop_1st_packet_from_conn0()
78 Result::<()>::Ok(()) in test_bridge_drop_2nd_packet_from_conn0()
105 Result::<()>::Ok(()) in test_bridge_drop_1st_packet_from_conn1()
132 Result::<()>::Ok(()) in test_bridge_drop_2nd_packet_from_conn1()
164 Result::<()>::Ok(()) in test_bridge_reorder_packets_from_conn0()
195 Result::<()>::Ok(()) in test_bridge_reorder_packets_from_conn1()
207 async fn test_bridge_inverse_error() -> Result<()> { in test_bridge_inverse_error()
215 async fn test_bridge_drop_next_n_packets() -> Result<()> { in test_bridge_drop_next_n_packets()
[all …]
|
| H A D | conn_pipe.rs | 31 async fn connect(&self, _addr: SocketAddr) -> Result<()> { in connect() argument
35 async fn recv(&self, b: &mut [u8]) -> Result<usize> { in recv()
46 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from()
51 async fn send(&self, b: &[u8]) -> Result<usize> { in send()
60 async fn send_to(&self, _buf: &[u8], _target: SocketAddr) -> Result<usize> { in send_to()
64 fn local_addr(&self) -> Result<SocketAddr> { in local_addr()
72 async fn close(&self) -> Result<()> { in close() argument
|
| /webrtc/mdns/src/message/ |
| H A D | parser.rs | 44 fn check_advance(&mut self, sec: Section) -> Result<()> { in check_advance() argument
106 pub fn question(&mut self) -> Result<Question> { in question()
143 pub fn skip_question(&mut self) -> Result<()> { in skip_question() argument
154 pub fn skip_all_questions(&mut self) -> Result<()> { in skip_all_questions() argument
172 pub fn answer(&mut self) -> Result<Resource> { in answer()
203 pub fn skip_answer(&mut self) -> Result<()> { in skip_answer() argument
208 pub fn skip_all_answers(&mut self) -> Result<()> { in skip_all_answers() argument
226 pub fn authority(&mut self) -> Result<Resource> { in authority()
257 pub fn skip_authority(&mut self) -> Result<()> { in skip_authority() argument
280 pub fn additional(&mut self) -> Result<Resource> { in additional()
[all …]
|
| H A D | message_test.rs | 17 fn small_test_msg() -> Result<Message> { in small_test_msg()
60 fn large_test_msg() -> Result<Message> { in large_test_msg()
239 fn test_name_string() -> Result<()> { in test_name_string()
283 fn test_name() -> Result<()> { in test_name()
405 fn test_parser_start() -> Result<()> { in test_parser_start()
537 fn test_skip_all() -> Result<()> { in test_skip_all()
560 fn test_skip_each() -> Result<()> { in test_skip_each()
796 fn test_too_long_txt() -> Result<()> { in test_too_long_txt()
812 fn test_start_error() -> Result<()> { in test_start_error()
1028 fn test_finish_error() -> Result<()> { in test_finish_error()
[all …]
|
| H A D | builder.rs | 84 fn start_check(&self, section: Section) -> Result<()> { in start_check() argument
96 pub fn start_questions(&mut self) -> Result<()> { in start_questions() argument
103 pub fn start_answers(&mut self) -> Result<()> { in start_answers() argument
110 pub fn start_authorities(&mut self) -> Result<()> { in start_authorities() argument
117 pub fn start_additionals(&mut self) -> Result<()> { in start_additionals() argument
123 fn increment_section_count(&mut self) -> Result<()> { in increment_section_count() argument
144 pub fn add_question(&mut self, q: &Question) -> Result<()> { in add_question() argument
161 fn check_resource_section(&self) -> Result<()> { in check_resource_section() argument
172 pub fn add_resource(&mut self, r: &mut Resource) -> Result<()> { in add_resource() argument
196 pub fn finish(&mut self) -> Result<Vec<u8>> { in finish()
|
| /webrtc/webrtc/src/mux/ |
| H A D | endpoint.rs | 22 pub async fn close(&self) -> Result<()> { in close() argument
32 type Result<T> = std::result::Result<T, util::Error>; typedef
36 async fn connect(&self, _addr: SocketAddr) -> Result<()> { in connect() argument
42 async fn recv(&self, buf: &mut [u8]) -> Result<usize> { in recv()
48 async fn recv_from(&self, _buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from()
53 async fn send(&self, buf: &[u8]) -> Result<usize> { in send()
57 async fn send_to(&self, _buf: &[u8], _target: SocketAddr) -> Result<usize> { in send_to()
61 fn local_addr(&self) -> Result<SocketAddr> { in local_addr()
69 async fn close(&self) -> Result<()> { in close() argument
|
| H A D | mux_test.rs | 28 async fn test_no_endpoints() -> crate::error::Result<()> { in test_no_endpoints()
48 type Result<T> = std::result::Result<T, util::Error>; typedef
52 async fn connect(&self, _addr: SocketAddr) -> Result<()> { in connect() argument
56 async fn recv(&self, buf: &mut [u8]) -> Result<usize> { in recv()
71 async fn recv_from(&self, _buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from()
75 async fn send(&self, _buf: &[u8]) -> Result<usize> { in send()
79 async fn send_to(&self, _buf: &[u8], _target: SocketAddr) -> Result<usize> { in send_to()
83 fn local_addr(&self) -> Result<SocketAddr> { in local_addr()
91 async fn close(&self) -> Result<()> { in close() argument
97 async fn test_non_fatal_read() -> Result<()> { in test_non_fatal_read()
|
| /webrtc/data/src/message/ |
| H A D | message_channel_ack.rs | 3 type Result<T> = std::result::Result<T, util::Error>; typedef
26 fn marshal_to(&self, _buf: &mut [u8]) -> Result<usize> { in marshal_to()
32 fn unmarshal<B>(_buf: &mut B) -> Result<Self> in unmarshal()
47 fn test_channel_ack_unmarshal() -> Result<()> { in test_channel_ack_unmarshal()
57 fn test_channel_ack_marshal_size() -> Result<()> { in test_channel_ack_marshal_size()
66 fn test_channel_ack_marshal() -> Result<()> { in test_channel_ack_marshal()
|
| H A D | message_type.rs | 9 type Result<T> = std::result::Result<T, util::Error>; typedef
25 fn marshal_to(&self, mut buf: &mut [u8]) -> Result<usize> { in marshal_to()
38 fn unmarshal<B>(buf: &mut B) -> Result<Self> in unmarshal()
67 fn test_message_type_unmarshal_open_success() -> Result<()> { in test_message_type_unmarshal_open_success()
77 fn test_message_type_unmarshal_ack_success() -> Result<()> { in test_message_type_unmarshal_ack_success()
86 fn test_message_type_unmarshal_invalid() -> Result<()> { in test_message_type_unmarshal_invalid()
104 fn test_message_type_marshal_size() -> Result<()> { in test_message_type_marshal_size()
113 fn test_message_type_marshal() -> Result<()> { in test_message_type_marshal()
|
| H A D | message_channel_open.rs | 4 type Result<T> = std::result::Result<T, util::Error>; typedef
62 fn marshal_to(&self, mut buf: &mut [u8]) -> Result<usize> { in marshal_to()
88 fn unmarshal<B>(buf: &mut B) -> Result<Self> in unmarshal()
187 fn unmarshal<B>(buf: &mut B) -> Result<Self> in unmarshal()
237 fn test_channel_type_unmarshal_success() -> Result<()> { in test_channel_type_unmarshal_success()
246 fn test_channel_type_unmarshal_invalid() -> Result<()> { in test_channel_type_unmarshal_invalid()
286 fn test_channel_type_marshal_size() -> Result<()> { in test_channel_type_marshal_size()
295 fn test_channel_type_marshal() -> Result<()> { in test_channel_type_marshal()
318 fn test_channel_open_unmarshal_success() -> Result<()> { in test_channel_open_unmarshal_success()
406 fn test_channel_open_marshal_size() -> Result<()> { in test_channel_open_marshal_size()
[all …]
|
| /webrtc/interceptor/src/ |
| H A D | lib.rs | 5 use error::Result;
32 fn build(&self, id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>>; in build()
75 async fn close(&self) -> Result<()>; in close() argument
82 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize>; in write()
89 ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + Sync>>)
98 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize> { in write()
114 ) -> Pin<Box<dyn Future<Output = Result<(usize, Attributes)>> + Send + Sync>>)
136 ) -> Result<usize>; in write()
143 ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + Sync>>)
157 ) -> Result<usize> { in write()
[all …]
|
| /webrtc/srtp/src/cipher/ |
| H A D | mod.rs | 6 use crate::error::Result;
46 ) -> Result<Bytes>; in encrypt_rtp()
54 ) -> Result<Bytes>; in decrypt_rtp()
57 fn encrypt_rtcp(&mut self, payload: &[u8], srtcp_index: usize, ssrc: u32) -> Result<Bytes>; in encrypt_rtcp()
60 fn decrypt_rtcp(&mut self, payload: &[u8], srtcp_index: usize, ssrc: u32) -> Result<Bytes>; in decrypt_rtcp()
|
| /webrtc/sctp/src/param/ |
| H A D | param_test.rs | 9 fn test_parse_param_type_success() -> Result<()> { in test_parse_param_type_success()
31 fn test_param_header_success() -> Result<()> { in test_param_header_success()
51 fn test_param_header_unmarshal_failure() -> Result<()> { in test_param_header_unmarshal_failure()
78 fn test_param_forward_tsn_supported_success() -> Result<()> { in test_param_forward_tsn_supported_success()
95 fn test_param_forward_tsn_supported_failure() -> Result<()> { in test_param_forward_tsn_supported_failure()
120 fn test_param_outgoing_reset_request_success() -> Result<()> { in test_param_outgoing_reset_request_success()
177 fn test_param_reconfig_response_success() -> Result<()> { in test_param_reconfig_response_success()
197 fn test_param_reconfig_response_failure() -> Result<()> { in test_param_reconfig_response_failure()
215 fn test_reconfig_result_stringer() -> Result<()> { in test_reconfig_result_stringer()
245 fn test_build_param_success() -> Result<()> { in test_build_param_success()
[all …]
|
| /webrtc/sctp/src/chunk/ |
| H A D | mod.rs | 22 use crate::error::{Error, Result};
31 fn unmarshal(raw: &Bytes) -> Result<Self> in unmarshal()
34 fn marshal_to(&self, buf: &mut BytesMut) -> Result<usize>; in marshal_to()
35 fn check(&self) -> Result<()>; in check() argument
39 fn marshal(&self) -> Result<Bytes> { in marshal()
|
| H A D | chunk_test.rs | 9 fn test_chunk_type_string() -> Result<()> { in test_chunk_type_string()
49 fn test_abort_chunk_one_error_cause() -> Result<()> { in test_abort_chunk_one_error_cause()
291 fn test_chunk_reconfig_success() -> Result<()> { in test_chunk_reconfig_success()
334 fn test_chunk_shutdown_success() -> Result<()> { in test_chunk_shutdown_success()
349 fn test_chunk_shutdown_failure() -> Result<()> { in test_chunk_shutdown_failure()
472 fn test_init_chunk() -> Result<()> { in test_init_chunk()
510 fn test_init_ack() -> Result<()> { in test_init_ack()
526 fn test_chrome_chunk1_init() -> Result<()> { in test_chrome_chunk1_init()
656 fn test_select_ack_chunk() -> Result<()> { in test_select_ack_chunk()
674 fn test_reconfig_chunk() -> Result<()> { in test_reconfig_chunk()
[all …]
|
| /webrtc/ice/src/control/ |
| H A D | mod.rs | 18 pub fn add_to_as(self, m: &mut Message, t: AttrType) -> Result<(), stun::Error> { in add_to_as() argument
26 pub fn get_from_as(&mut self, m: &Message, t: AttrType) -> Result<(), stun::Error> { in get_from_as() argument
39 fn add_to(&self, m: &mut Message) -> Result<(), stun::Error> { in add_to() argument
46 fn get_from(&mut self, m: &Message) -> Result<(), stun::Error> { in get_from() argument
60 fn add_to(&self, m: &mut Message) -> Result<(), stun::Error> { in add_to() argument
67 fn get_from(&mut self, m: &Message) -> Result<(), stun::Error> { in get_from() argument
84 fn add_to(&self, m: &mut Message) -> Result<(), stun::Error> { in add_to() argument
95 fn get_from(&mut self, m: &Message) -> Result<(), stun::Error> { in get_from() argument
135 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() argument
|
| /webrtc/util/src/marshal/ |
| H A D | mod.rs | 5 use crate::error::{Error, Result};
12 fn marshal_to(&self, buf: &mut [u8]) -> Result<usize>; in marshal_to()
14 fn marshal(&self) -> Result<Bytes> { in marshal()
30 fn unmarshal<B>(buf: &mut B) -> Result<Self> in unmarshal()
|
| /webrtc/stun/src/message/ |
| H A D | message_test.rs | 10 fn test_message_buffer() -> Result<()> { in test_message_buffer()
30 fn test_message_type_value() -> Result<()> { in test_message_type_value()
137 fn test_message_write_to() -> Result<()> { in test_message_write_to()
161 fn test_message_cookie() -> Result<()> { in test_message_cookie()
327 fn test_method_string() -> Result<()> { in test_method_string()
344 fn test_attribute_equal() -> Result<()> { in test_attribute_equal()
395 fn test_message_equal() -> Result<()> { in test_message_equal()
546 fn test_message_grow() -> Result<()> { in test_message_grow()
566 fn test_message_string() -> Result<()> { in test_message_string()
574 fn test_is_message() -> Result<()> { in test_is_message()
[all …]
|
| /webrtc/media/src/io/h264_reader/ |
| H A D | h264_reader_test.rs | 5 fn test_data_does_not_start_with_h264header() -> Result<()> { in test_data_does_not_start_with_h264header()
25 fn test_parse_header() -> Result<()> { in test_parse_header()
41 fn test_eof() -> Result<()> { in test_eof()
59 fn test_skip_sei() -> Result<()> { in test_skip_sei()
77 fn test_issue1734_next_nal() -> Result<()> { in test_issue1734_next_nal()
96 fn test_trailing01after_start_code() -> Result<()> { in test_trailing01after_start_code()
|
| /webrtc/mdns/src/message/resource/ |
| H A D | ptr.rs | 2 use crate::error::Result;
12 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() argument
28 ) -> Result<Vec<u8>> { in pack()
32 fn unpack(&mut self, msg: &[u8], off: usize, _length: usize) -> Result<usize> { in unpack()
|
| H A D | ns.rs | 2 use crate::error::Result;
12 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() argument
28 ) -> Result<Vec<u8>> { in pack()
32 fn unpack(&mut self, msg: &[u8], off: usize, _txt_length: usize) -> Result<usize> { in unpack()
|
| /webrtc/webrtc/src/track/track_local/ |
| H A D | mod.rs | 7 use crate::error::{Error, Result};
24 async fn write_rtp(&self, p: &rtp::packet::Packet) -> Result<usize>; in write_rtp()
27 async fn write(&self, b: &[u8]) -> Result<usize>; in write()
79 async fn bind(&self, t: &TrackLocalContext) -> Result<RTCRtpCodecParameters>; in bind()
83 async fn unbind(&self, t: &TrackLocalContext) -> Result<()>; in unbind() argument
137 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt() argument
144 async fn write_rtp(&self, pkt: &rtp::packet::Packet) -> Result<usize> { in write_rtp()
158 async fn write(&self, mut b: &[u8]) -> Result<usize> { in write()
|