| /webrtc/data/src/ |
| H A D | error.rs | 3 use thiserror::Error; 7 #[derive(Debug, Error, PartialEq)] 9 pub enum Error { enum 24 Util(#[from] util::Error), 26 Sctp(#[from] sctp::Error), 35 impl From<Error> for util::Error { implementation 36 fn from(e: Error) -> Self { in from() 41 impl From<Error> for io::Error { implementation 44 e @ Error::Sctp(sctp::Error::ErrEof) => { in from() 55 impl PartialEq<util::Error> for Error { implementation [all …]
|
| /webrtc/dtls/src/ |
| H A D | error.rs | 1 use thiserror::Error; 11 #[derive(Debug, Error, PartialEq)] 13 pub enum Error { enum 155 Util(#[from] util::Error), 178 #[derive(Debug, Error)] 189 impl From<io::Error> for Error { implementation 191 Error::Io(IoError(e)) in from() 195 impl From<sec1::Error> for Error { implementation 197 Error::Sec1(e) in from() 201 #[derive(Debug, Error)] [all …]
|
| /webrtc/rtp/src/ |
| H A D | error.rs | 1 use thiserror::Error; 3 pub type Result<T> = std::result::Result<T, Error>; 5 #[derive(Error, Debug, PartialEq)] 7 pub enum Error { enum 59 Util(#[from] util::Error), 65 impl From<Error> for util::Error { implementation 66 fn from(e: Error) -> Self { in from() 67 util::Error::from_std(e) in from() 71 impl PartialEq<util::Error> for Error { implementation 72 fn eq(&self, other: &util::Error) -> bool { in eq() [all …]
|
| /webrtc/rtcp/src/ |
| H A D | error.rs | 1 use thiserror::Error; 3 pub type Result<T> = std::result::Result<T, Error>; 5 #[derive(Error, Debug, PartialEq)] 7 pub enum Error { enum 101 Util(#[from] util::Error), 107 impl From<Error> for util::Error { implementation 108 fn from(e: Error) -> Self { in from() 109 util::Error::from_std(e) in from() 113 impl PartialEq<util::Error> for Error { implementation 114 fn eq(&self, other: &util::Error) -> bool { in eq() [all …]
|
| /webrtc/ice/src/url/ |
| H A D | url_test.rs | 110 ("", Error::ErrSchemeType), in test_parse_url_failure() 111 (":::", Error::ErrUrlParse), in test_parse_url_failure() 112 ("stun:[::1]:123:", Error::ErrPort), in test_parse_url_failure() 113 ("stun:[::1]:123a", Error::ErrPort), in test_parse_url_failure() 114 ("google.de", Error::ErrSchemeType), in test_parse_url_failure() 115 ("stun:", Error::ErrHost), in test_parse_url_failure() 116 ("stun:google.de:abc", Error::ErrPort), in test_parse_url_failure() 117 ("stun:google.de?transport=udp", Error::ErrStunQuery), in test_parse_url_failure() 119 ("turn:google.de?trans=udp", Error::ErrInvalidQuery), in test_parse_url_failure() 123 Error::ErrInvalidQuery, in test_parse_url_failure() [all …]
|
| /webrtc/media/src/ |
| H A D | error.rs | 2 use thiserror::Error; 4 pub type Result<T> = std::result::Result<T, Error>; 6 #[derive(Error, Debug, PartialEq)] 8 pub enum Error { enum 49 Rtp(#[from] rtp::Error), 55 #[derive(Debug, Error)] 57 pub struct IoError(#[from] pub io::Error); 66 impl From<io::Error> for Error { implementation 67 fn from(e: io::Error) -> Self { in from() 68 Error::Io(IoError(e)) in from()
|
| /webrtc/dtls/examples/hub/src/ |
| H A D | utilities.rs | 9 use thiserror::Error; 11 #[derive(Debug, Error, PartialEq, Eq)] 12 pub enum Error { enum 28 impl From<Error> for dtls::Error { implementation 29 fn from(e: Error) -> Self { in from() 30 dtls::Error::Other(e.to_string()) in from() 34 impl From<io::Error> for Error { implementation 35 fn from(e: io::Error) -> Self { in from() 36 Error::Other(e.to_string()) in from() 51 Result::<(), Error>::Ok(()) in chat() [all …]
|
| /webrtc/srtp/src/ |
| H A D | error.rs | 2 use thiserror::Error; 7 #[derive(Error, Debug, PartialEq)] 9 pub enum Error { enum 87 Util(#[from] util::Error), 89 Rtcp(#[from] rtcp::Error), 91 AesGcm(#[from] aes_gcm::Error), 97 #[derive(Debug, Error)] 108 impl From<io::Error> for Error { implementation 109 fn from(e: io::Error) -> Self { in from() 110 Error::Io(IoError(e)) in from() [all …]
|
| /webrtc/interceptor/src/ |
| H A D | error.rs | 1 use thiserror::Error; 3 pub type Result<T> = std::result::Result<T, Error>; 5 #[derive(Error, Debug, PartialEq)] 7 pub enum Error { enum 26 Srtp(#[from] srtp::Error), 28 Rtcp(#[from] rtcp::Error), 30 Rtp(#[from] rtp::Error), 32 Util(#[from] util::Error), 39 pub fn flatten_errs(errs: Vec<Error>) -> Result<()> { in flatten_errs() 44 Err(Error::Other(errs_strs.join("\n"))) in flatten_errs()
|
| /webrtc/stun/src/ |
| H A D | error.rs | 1 use thiserror::Error; 9 #[derive(Debug, Error, PartialEq)] 11 pub enum Error { enum 73 Util(#[from] util::Error), 76 #[derive(Debug, Error)] 78 pub struct IoError(#[from] pub io::Error); 87 impl From<io::Error> for Error { implementation 88 fn from(e: io::Error) -> Self { in from() 89 Error::Io(IoError(e)) in from() 94 impl<T> From<MpscSendError<T>> for Error { implementation [all …]
|
| H A D | checks.rs | 11 Err(Error::ErrAttributeSizeInvalid) in check_size() 16 pub fn is_attr_size_invalid(err: &Error) -> bool { in is_attr_size_invalid() 17 Error::ErrAttributeSizeInvalid == *err in is_attr_size_invalid() 22 Err(Error::ErrIntegrityMismatch) in check_hmac() 32 Err(Error::ErrFingerprintMismatch) in check_fingerprint() 41 Err(Error::ErrAttributeSizeOverflow) in check_overflow() 46 pub fn is_attr_size_overflow(err: &Error) -> bool { in is_attr_size_overflow() 47 Error::ErrAttributeSizeOverflow == *err in is_attr_size_overflow()
|
| /webrtc/util/src/ |
| H A D | error.rs | 7 use thiserror::Error; 9 pub type Result<T> = std::result::Result<T, Error>; 11 #[derive(Error, Debug, PartialEq)] 13 pub enum Error { enum 124 impl Error { impl 133 if let Error::Std(s) = self { in downcast_ref() 141 #[derive(Debug, Error)] 152 impl From<io::Error> for Error { implementation 153 fn from(e: io::Error) -> Self { in from() 154 Error::Io(IoError(e)) in from() [all …]
|
| /webrtc/webrtc/src/ |
| H A D | error.rs | 6 use thiserror::Error; 15 #[derive(Error, Debug, PartialEq)] 17 pub enum Error { enum 388 Util(#[from] util::Error), 390 Ice(#[from] ice::Error), 392 Srtp(#[from] srtp::Error), 400 Sdp(#[from] sdp::Error), 406 Rtp(#[from] rtp::Error), 438 impl From<Error> for interceptor::Error { implementation 441 interceptor::Error::Util(util::Error::from_std(e)) in from() [all …]
|
| /webrtc/ice/src/ |
| H A D | error.rs | 1 use thiserror::Error; 10 #[derive(Debug, Error, PartialEq)] 12 pub enum Error { enum 204 Util(#[from] util::Error), 206 Stun(#[from] stun::Error), 210 Mdns(#[from] mdns::Error), 212 Turn(#[from] turn::Error), 218 #[derive(Debug, Error)] 229 impl From<io::Error> for Error { implementation 230 fn from(e: io::Error) -> Self { in from() [all …]
|
| /webrtc/sdp/src/ |
| H A D | error.rs | 1 use thiserror::Error; 8 pub type Result<T> = std::result::Result<T, Error>; 10 #[derive(Debug, Error, PartialEq)] 12 pub enum Error { enum 41 #[derive(Debug, Error)] 43 pub struct IoError(#[from] pub io::Error); 52 impl From<io::Error> for Error { implementation 53 fn from(e: io::Error) -> Self { in from() 54 Error::Io(IoError(e)) in from()
|
| /webrtc/mdns/src/ |
| H A D | error.rs | 1 use thiserror::Error; 7 pub type Result<T> = std::result::Result<T, Error>; 9 #[derive(Debug, Error, PartialEq)] 11 pub enum Error { enum 72 #[derive(Debug, Error)] 74 pub struct IoError(#[from] pub io::Error); 83 impl From<io::Error> for Error { implementation 84 fn from(e: io::Error) -> Self { in from() 85 Error::Io(IoError(e)) in from()
|
| /webrtc/turn/src/ |
| H A D | error.rs | 1 use thiserror::Error; 10 #[derive(Debug, Error, PartialEq)] 12 pub enum Error { enum 162 Util(#[from] util::Error), 164 Stun(#[from] stun::Error), 169 #[derive(Debug, Error)] 180 impl From<io::Error> for Error { implementation 181 fn from(e: io::Error) -> Self { in from() 182 Error::Io(IoError(e)) in from() 186 impl From<SystemTimeError> for Error { implementation [all …]
|
| /webrtc/mdns/src/message/ |
| H A D | builder.rs | 86 return Err(Error::ErrNotStarted); in start_check() 89 return Err(Error::ErrSectionDone); in start_check() 131 Section::Done => return Err(Error::ErrSectionDone), in increment_section_count() 132 Section::Header => return Err(Error::ErrSectionHeader), in increment_section_count() 146 return Err(Error::ErrNotStarted); in add_question() 149 return Err(Error::ErrSectionDone); in add_question() 163 return Err(Error::ErrNotStarted); in check_resource_section() 166 return Err(Error::ErrSectionDone); in check_resource_section() 178 return Err(Error::ErrNilResourceBody); in add_resource() 198 return Err(Error::ErrNotStarted); in finish() [all …]
|
| H A D | name.rs | 25 Err(Error::ErrCalcLen) in new() 50 return Err(Error::ErrNonCanonicalName); in pack() 68 return Err(Error::ErrSegTooLong); in pack() 73 return Err(Error::ErrZeroSegLen); in pack() 137 return Err(Error::ErrBaseLen); in unpack_compressed() 150 return Err(Error::ErrCalcLen); in unpack_compressed() 178 return Err(Error::ErrReserved); in unpack_compressed() 186 return Err(Error::ErrCalcLen); in unpack_compressed() 203 return Err(Error::ErrBaseLen); in skip() 216 return Err(Error::ErrCalcLen); in skip() [all …]
|
| /webrtc/ice/src/udp_mux/ |
| H A D | socket_addr_ext.rs | 5 use util::Error; 12 fn encode(&self, buffer: &mut [u8]) -> Result<usize, Error>; in encode() argument 16 fn decode(buffer: &[u8]) -> Result<SocketAddr, Error>; in decode() argument 31 return Err(Error::ErrBufferShort); in encode() 70 return Err(Error::ErrBufferShort); in decode() 85 return Err(Error::ErrBufferShort); in decode() 116 _ => Err(Error::ErrFailedToParseIpaddr), in decode() 208 assert_eq!(result, Err(Error::ErrBufferShort)); in test_encode_ipv4_with_short_buffer() 225 assert_eq!(result, Err(Error::ErrBufferShort)); in test_encode_ipv6_with_short_buffer() 234 assert_eq!(result, Err(Error::ErrBufferShort)); in test_decode_ipv4_with_short_buffer() [all …]
|
| /webrtc/stun/src/agent/ |
| H A D | agent_test.rs | 59 Error::ErrAgentClosed, in test_agent_process() 61 Error::ErrAgentClosed, in test_agent_process() 82 Error::ErrTransactionExists, in test_agent_start() 97 Error::ErrAgentClosed, in test_agent_start() 99 Error::ErrAgentClosed, in test_agent_start() 110 Error::ErrAgentClosed, in test_agent_start() 112 Error::ErrAgentClosed, in test_agent_start() 171 Error::ErrAgentClosed, in test_agent_stop() 173 Error::ErrAgentClosed, in test_agent_stop() 184 Error::ErrAgentClosed, in test_agent_stop() [all …]
|
| /webrtc/rtp/src/extension/video_orientation_extension/ |
| H A D | mod.rs | 10 use crate::Error; 74 return Err(Error::ErrBufferTooSmall.into()); in unmarshal() 104 type Error = util::Error; typedef 106 fn try_from(value: u8) -> Result<Self, Self::Error> { in try_from() argument 110 _ => Err(util::Error::Other(format!( in try_from() 118 type Error = util::Error; typedef 120 fn try_from(value: u8) -> Result<Self, Self::Error> { in try_from() argument 126 _ => Err(util::Error::Other(format!( in try_from()
|
| /webrtc/data/src/message/ |
| H A D | message_channel_open.rs | 2 use crate::error::Error; 4 type Result<T> = std::result::Result<T, util::Error>; 65 return Err(Error::UnexpectedEndOfBuffer { in marshal_to() 95 return Err(Error::UnexpectedEndOfBuffer { in unmarshal() 251 if let Some(&Error::InvalidChannelType(0x11)) = err.downcast_ref::<Error>() { in test_channel_type_unmarshal_invalid() 257 Error::InvalidMessageType(0x01) in test_channel_type_unmarshal_invalid() 272 }) = err.downcast_ref::<Error>() in test_channel_type_unmarshal_unexpected_end_of_buffer() 279 Error::InvalidMessageType(0x01) in test_channel_type_unmarshal_unexpected_end_of_buffer() 343 if let Some(&Error::InvalidChannelType(0x11)) = err.downcast_ref::<Error>() { in test_channel_open_unmarshal_invalid_channel_type() 364 }) = err.downcast_ref::<Error>() in test_channel_open_unmarshal_unexpected_end_of_buffer() [all …]
|
| /webrtc/sctp/src/ |
| H A D | error.rs | 2 use thiserror::Error; 4 pub type Result<T> = std::result::Result<T, Error>; 6 #[derive(Debug, Error, PartialEq, Eq, Clone)] 8 pub enum Error { enum 227 impl From<Error> for io::Error { implementation 228 fn from(error: Error) -> Self { in from() 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/ice/src/agent/ |
| H A D | agent_transport.rs | 39 return Err(Error::ErrCanceledByCaller); in dial() 74 return Err(Error::ErrCanceledByCaller); in accept() 167 Err(io::Error::new(io::ErrorKind::Other, "Not applicable").into()) in connect() 187 ) -> std::result::Result<(usize, SocketAddr), util::Error> { in recv_from() argument 192 Err(io::Error::new(io::ErrorKind::Other, "Not applicable").into()) in recv_from() 196 async fn send(&self, buf: &[u8]) -> std::result::Result<usize, util::Error> { in send() argument 202 return Err(util::Error::Other("ErrIceWriteStunMessage".into())); in send() 226 ) -> std::result::Result<usize, util::Error> { in send_to() argument 227 Err(io::Error::new(io::ErrorKind::Other, "Not applicable").into()) in send_to() 230 fn local_addr(&self) -> std::result::Result<SocketAddr, util::Error> { in local_addr() argument [all …]
|