| /webrtc/rtcp/src/ |
| H A D | packet.rs | 83 let h = Header::unmarshal(raw_data)?; in unmarshaller() 96 PacketType::Goodbye => Box::new(Goodbye::unmarshal(&mut in_packet)?), in unmarshaller() 101 FORMAT_TCC => Box::new(TransportLayerCc::unmarshal(&mut in_packet)?), in unmarshaller() 102 _ => Box::new(RawPacket::unmarshal(&mut in_packet)?), in unmarshaller() 108 FORMAT_FIR => Box::new(FullIntraRequest::unmarshal(&mut in_packet)?), in unmarshaller() 109 _ => Box::new(RawPacket::unmarshal(&mut in_packet)?), in unmarshaller() 112 _ => Box::new(RawPacket::unmarshal(&mut in_packet)?), in unmarshaller() 156 let packet = unmarshal(&mut data).expect("Error unmarshalling packets"); in test_packet_unmarshal() 210 let result = unmarshal(&mut Bytes::new()); in test_packet_unmarshal_empty() 229 let result = unmarshal(&mut data); in test_packet_invalid_header_length() [all …]
|
| H A D | raw_packet.rs | 23 match Header::unmarshal(&mut self.0.clone()) { in header() 65 let h = Header::unmarshal(&mut self.0.clone())?; in marshal_to() 76 fn unmarshal<B>(raw_packet: &mut B) -> Result<Self, util::Error> in unmarshal() method 86 let h = Header::unmarshal(raw_packet)?; in unmarshal() 143 let result = RawPacket::unmarshal(&mut data); in test_raw_packet_roundtrip()
|
| /webrtc/sctp/src/ |
| H A D | packet.rs | 84 pub(crate) fn unmarshal(raw: &Bytes) -> Result<Self> { in unmarshal() method 118 CT_INIT => Box::new(ChunkInit::unmarshal(&raw.slice(offset..))?), in unmarshal() 119 CT_INIT_ACK => Box::new(ChunkInit::unmarshal(&raw.slice(offset..))?), in unmarshal() 120 CT_ABORT => Box::new(ChunkAbort::unmarshal(&raw.slice(offset..))?), in unmarshal() 128 CT_ERROR => Box::new(ChunkError::unmarshal(&raw.slice(offset..))?), in unmarshal() 132 Box::new(ChunkShutdownComplete::unmarshal(&raw.slice(offset..))?) in unmarshal() 134 _ => Box::new(ChunkUnknown::unmarshal(&raw.slice(offset..))?), in unmarshal() 242 let result = Packet::unmarshal(&Bytes::new()); in test_packet_unmarshal() 251 let pkt = Packet::unmarshal(&header_only)?; in test_packet_unmarshal() 280 Packet::unmarshal(&raw_chunk)?; in test_packet_unmarshal() [all …]
|
| /webrtc/sctp/src/param/ |
| H A D | mod.rs | 36 fn unmarshal(raw: &Bytes) -> Result<Self> in unmarshal() method 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 | 41 let actual = ParamHeader::unmarshal(&binary)?; in test_param_header_success() 63 let result = ParamHeader::unmarshal(&binary); in test_param_header_unmarshal_failure() 85 let actual = ParamForwardTsnSupported::unmarshal(&binary)?; in test_param_forward_tsn_supported_success() 99 let result = ParamForwardTsnSupported::unmarshal(&binary); in test_param_forward_tsn_supported_failure() 143 let actual = ParamOutgoingResetRequest::unmarshal(&binary)?; in test_param_outgoing_reset_request_success() 160 let result = ParamOutgoingResetRequest::unmarshal(&binary); in test_param_outgoing_reset_request_failure() 187 let actual = ParamReconfigResponse::unmarshal(&binary)?; in test_param_reconfig_response_success() 207 let result = ParamReconfigResponse::unmarshal(&binary); in test_param_reconfig_response_failure()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_test.rs | 58 let abort2 = ChunkAbort::unmarshal(&b)?; in test_abort_chunk_one_error_cause() 90 let abort2 = ChunkAbort::unmarshal(&b)?; in test_abort_chunk_many_error_causes() 127 let c = ChunkError::unmarshal(&RAW_IN)?; in test_chunk_error_unrecognized_chunk_type_unmarshal() 482 let pkt = Packet::unmarshal(&raw_pkt)?; in test_init_chunk() 516 let pkt = Packet::unmarshal(&raw_pkt)?; in test_init_ack() 536 let pkt = Packet::unmarshal(&raw_pkt)?; in test_chrome_chunk1_init() 575 let pkt = Packet::unmarshal(&raw_pkt)?; in test_chrome_chunk2_init_ack() 607 let pkt = Packet::unmarshal(&raw_pkt)?; in test_init_marshal_unmarshal() 644 let pkt = Packet::unmarshal(&raw_pkt)?; in test_payload_data_marshal_unmarshal() 662 let pkt = Packet::unmarshal(&raw_pkt)?; in test_select_ack_chunk() [all …]
|
| H A D | chunk_error.rs | 55 fn unmarshal(raw: &Bytes) -> Result<Self> { in unmarshal() method 56 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() 65 let e = ErrorCause::unmarshal( in unmarshal()
|
| H A D | chunk_abort.rs | 53 fn unmarshal(raw: &Bytes) -> Result<Self> { in unmarshal() method 54 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() 63 let e = ErrorCause::unmarshal( in unmarshal()
|
| /webrtc/dtls/src/record_layer/ |
| H A D | mod.rs | 58 pub fn unmarshal<R: Read>(reader: &mut R) -> Result<Self> { in unmarshal() method 59 let record_layer_header = RecordLayerHeader::unmarshal(reader)?; in unmarshal() 61 ContentType::Alert => Content::Alert(Alert::unmarshal(reader)?), in unmarshal() 63 Content::ApplicationData(ApplicationData::unmarshal(reader)?) in unmarshal() 66 Content::ChangeCipherSpec(ChangeCipherSpec::unmarshal(reader)?) in unmarshal() 68 ContentType::Handshake => Content::Handshake(Handshake::unmarshal(reader)?), in unmarshal()
|
| /webrtc/dtls/src/handshake/ |
| H A D | mod.rs | 196 pub fn unmarshal<R: Read>(reader: &mut R) -> Result<Self> { in unmarshal() method 197 let handshake_header = HandshakeHeader::unmarshal(reader)?; in unmarshal() 201 HandshakeMessage::ClientHello(HandshakeMessageClientHello::unmarshal(reader)?) in unmarshal() 204 HandshakeMessage::ServerHello(HandshakeMessageServerHello::unmarshal(reader)?) in unmarshal() 207 HandshakeMessageHelloVerifyRequest::unmarshal(reader)?, in unmarshal() 213 HandshakeMessageServerKeyExchange::unmarshal(reader)?, in unmarshal() 216 HandshakeMessageCertificateRequest::unmarshal(reader)?, in unmarshal() 219 HandshakeMessageServerHelloDone::unmarshal(reader)?, in unmarshal() 222 HandshakeMessageCertificateVerify::unmarshal(reader)?, in unmarshal() 225 HandshakeMessageClientKeyExchange::unmarshal(reader)?, in unmarshal() [all …]
|
| /webrtc/dtls/src/extension/ |
| H A D | mod.rs | 103 pub fn unmarshal<R: Read>(reader: &mut R) -> Result<Self> { in unmarshal() method 107 ExtensionServerName::unmarshal(reader)?, in unmarshal() 110 ExtensionSupportedEllipticCurves::unmarshal(reader)?, in unmarshal() 113 ExtensionSupportedPointFormats::unmarshal(reader)?, in unmarshal() 117 ExtensionSupportedSignatureAlgorithms::unmarshal(reader)?, in unmarshal() 120 ExtensionValue::UseSrtp => Ok(Extension::UseSrtp(ExtensionUseSrtp::unmarshal(reader)?)), in unmarshal() 122 ExtensionUseExtendedMasterSecret::unmarshal(reader)?, in unmarshal() 125 ExtensionRenegotiationInfo::unmarshal(reader)?, in unmarshal()
|
| /webrtc/rtcp/src/payload_feedbacks/receiver_estimated_maximum_bitrate/ |
| H A D | receiver_estimated_maximum_bitrate_test.rs | 36 let packet = ReceiverEstimatedMaximumBitrate::unmarshal(&mut input).unwrap(); in test_receiver_estimated_maximum_bitrate_unmarshal() 54 let mut packet = ReceiverEstimatedMaximumBitrate::unmarshal(&mut buf).unwrap(); in test_receiver_estimated_maximum_bitrate_truncate() 80 let packet = ReceiverEstimatedMaximumBitrate::unmarshal(&mut output).unwrap(); in test_receiver_estimated_maximum_bitrate_truncate() 107 let packet = ReceiverEstimatedMaximumBitrate::unmarshal(&mut buf).unwrap(); in test_receiver_estimated_maximum_bitrate_overflow() 118 let packet = ReceiverEstimatedMaximumBitrate::unmarshal(&mut input).unwrap(); in test_receiver_estimated_maximum_bitrate_overflow()
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | session_description.rs | 32 let parsed = desc.unmarshal()?; in answer() 47 let parsed = desc.unmarshal()?; in offer() 63 let parsed = desc.unmarshal()?; in pranswer() 70 pub fn unmarshal(&self) -> Result<SessionDescription> { in unmarshal() method 72 let parsed = SessionDescription::unmarshal(&mut reader)?; in unmarshal() 163 assert_eq!(answer.unmarshal()?.marshal(), desc.unmarshal()?.marshal()); in test_session_description_answer() 182 assert_eq!(offer.unmarshal()?.marshal(), desc.unmarshal()?.marshal()); in test_session_description_offer() 228 let parsed1 = desc.unmarshal()?; in test_session_description_unmarshal() 229 let parsed2 = desc.unmarshal()?; in test_session_description_unmarshal()
|
| /webrtc/rtcp/src/extended_report/ |
| H A D | mod.rs | 121 fn unmarshal<B>(raw_packet: &mut B) -> Result<Self> in unmarshal() method 248 fn unmarshal<B>(raw_packet: &mut B) -> Result<Self> in unmarshal() method 258 let header = Header::unmarshal(raw_packet)?; in unmarshal() 274 BlockType::LossRLE => Box::new(LossRLEReportBlock::unmarshal(raw_packet)?), in unmarshal() 276 Box::new(DuplicateRLEReportBlock::unmarshal(raw_packet)?) in unmarshal() 279 Box::new(PacketReceiptTimesReportBlock::unmarshal(raw_packet)?) in unmarshal() 282 Box::new(ReceiverReferenceTimeReportBlock::unmarshal(raw_packet)?) in unmarshal() 284 BlockType::DLRR => Box::new(DLRRReportBlock::unmarshal(raw_packet)?), in unmarshal() 286 Box::new(StatisticsSummaryReportBlock::unmarshal(raw_packet)?) in unmarshal() 288 BlockType::VoIPMetrics => Box::new(VoIPMetricsReportBlock::unmarshal(raw_packet)?), in unmarshal() [all …]
|
| /webrtc/rtp/src/extension/video_orientation_extension/ |
| H A D | video_orientation_extension_test.rs | 8 let result = VideoOrientationExtension::unmarshal(&mut buf); in test_video_orientation_extension_too_small() 18 let a1 = VideoOrientationExtension::unmarshal(buf)?; in test_video_orientation_extension_back_facing_camera() 38 let a1 = VideoOrientationExtension::unmarshal(buf)?; in test_video_orientation_extension_flip_true() 58 let a1 = VideoOrientationExtension::unmarshal(buf)?; in test_video_orientation_extension_degree_90() 78 let a1 = VideoOrientationExtension::unmarshal(buf)?; in test_video_orientation_extension_degree_180() 98 let a1 = VideoOrientationExtension::unmarshal(buf)?; in test_video_orientation_extension_degree_270()
|
| /webrtc/dtls/src/ |
| H A D | content.rs | 68 pub fn unmarshal<R: Read>(content_type: ContentType, reader: &mut R) -> Result<Self> { in unmarshal() method 71 ChangeCipherSpec::unmarshal(reader)?, in unmarshal() 73 ContentType::Alert => Ok(Content::Alert(Alert::unmarshal(reader)?)), in unmarshal() 74 ContentType::Handshake => Ok(Content::Handshake(Handshake::unmarshal(reader)?)), in unmarshal() 76 ApplicationData::unmarshal(reader)?, in unmarshal()
|
| /webrtc/rtp/src/extension/transport_cc_extension/ |
| H A D | transport_cc_extension_test.rs | 8 let result = TransportCcExtension::unmarshal(&mut buf); in test_transport_cc_extension_too_small() 18 let t1 = TransportCcExtension::unmarshal(buf)?; in test_transport_cc_extension() 36 let t1 = TransportCcExtension::unmarshal(buf)?; in test_transport_cc_extension_extra_bytes()
|
| /webrtc/data/src/message/ |
| H A D | message_channel_open.rs | 88 fn unmarshal<B>(buf: &mut B) -> Result<Self> in unmarshal() method 187 fn unmarshal<B>(buf: &mut B) -> Result<Self> in unmarshal() method 200 let channel_type = ChannelType::unmarshal(buf)?; in unmarshal() 239 let channel_type = ChannelType::unmarshal(&mut bytes)?; in test_channel_type_unmarshal_success() 248 match ChannelType::unmarshal(&mut bytes) { in test_channel_type_unmarshal_invalid() 266 match ChannelType::unmarshal(&mut bytes) { in test_channel_type_unmarshal_unexpected_end_of_buffer() 321 let channel_open = DataChannelOpen::unmarshal(&mut bytes)?; in test_channel_open_unmarshal_success() 340 match DataChannelOpen::unmarshal(&mut bytes) { in test_channel_open_unmarshal_invalid_channel_type() 358 match DataChannelOpen::unmarshal(&mut bytes) { in test_channel_open_unmarshal_unexpected_end_of_buffer() 386 match DataChannelOpen::unmarshal(&mut bytes) { in test_channel_open_unmarshal_unexpected_length_mismatch()
|
| H A D | message_type.rs | 38 fn unmarshal<B>(buf: &mut B) -> Result<Self> in unmarshal() method 69 let msg_type = MessageType::unmarshal(&mut bytes)?; in test_message_type_unmarshal_open_success() 79 let msg_type = MessageType::unmarshal(&mut bytes)?; in test_message_type_unmarshal_ack_success() 88 match MessageType::unmarshal(&mut bytes) { in test_message_type_unmarshal_invalid()
|
| H A D | message_test.rs | 20 let actual = Message::unmarshal(&mut bytes).unwrap(); in test_message_unmarshal_open_success() 37 let actual = Message::unmarshal(&mut bytes)?; in test_message_unmarshal_ack_success() 49 let result = Message::unmarshal(&mut bytes); in test_message_unmarshal_invalid_message_type()
|
| H A D | mod.rs | 49 fn unmarshal<B>(buf: &mut B) -> Result<Self, util::Error> in unmarshal() method 62 match MessageType::unmarshal(buf)? { in unmarshal() 65 Ok(Self::DataChannelOpen(DataChannelOpen::unmarshal(buf)?)) in unmarshal()
|
| /webrtc/rtp/src/extension/audio_level_extension/ |
| H A D | audio_level_extension_test.rs | 8 let result = AudioLevelExtension::unmarshal(&mut buf); in test_audio_level_extension_too_small() 18 let a1 = AudioLevelExtension::unmarshal(buf)?; in test_audio_level_extension_voice_true() 37 let a1 = AudioLevelExtension::unmarshal(buf)?; in test_audio_level_extension_voice_false()
|
| /webrtc/sdp/benches/ |
| H A D | bench.rs | 33 let sdp = SessionDescription::unmarshal(&mut reader).unwrap(); in benchmark_sdp() 45 let _ = SessionDescription::unmarshal(&mut reader).unwrap(); in benchmark_sdp()
|
| /webrtc/dtls/src/handshake/handshake_message_certificate/ |
| H A D | handshake_message_certificate_test.rs | 38 let c = HandshakeMessageCertificate::unmarshal(&mut reader)?; in test_handshake_message_certificate() 71 let c = HandshakeMessageCertificate::unmarshal(&mut reader)?; in test_empty_handshake_message_certificate()
|
| /webrtc/dtls/src/change_cipher_spec/ |
| H A D | change_cipher_spec_test.rs | 15 let cnew = ChangeCipherSpec::unmarshal(&mut reader)?; in test_change_cipher_spec_round_trip() 29 let result = ChangeCipherSpec::unmarshal(&mut reader); in test_change_cipher_spec_invalid()
|