Searched refs:rtp_packet (Results 1 – 5 of 5) sorted by relevance
37 let mut rtp_packet = RtpPacket { in unmarshal() localVariable42 if rtp_packet.header.extension_flag == 1 { in unmarshal()51 rtp_packet.header_extension_profile = reader.read_u16::<BigEndian>()?; in unmarshal()52 rtp_packet.header_extension_length = reader.read_u16::<BigEndian>()?; in unmarshal()53 rtp_packet.header_extension_payload = in unmarshal()54 reader.read_bytes(4 * rtp_packet.header_extension_length as usize)?; in unmarshal()57 if rtp_packet.header.padding_flag == 1 { in unmarshal()59 rtp_packet in unmarshal()62 rtp_packet.padding.put(reader.read_bytes(padding_length)?); in unmarshal()64 rtp_packet.payload.put(reader.extract_remaining_bytes()); in unmarshal()[all …]
164 let rtp_packet = RtpPacket::unmarshal(reader)?; in unpack() localVariable167 f(rtp_packet.clone()); in unpack()170 self.timestamp = rtp_packet.header.timestamp; in unpack()171 self.sequence_number = rtp_packet.header.seq_number; in unpack()173 if let Some(packet_type) = rtp_packet.payload.first() { in unpack()176 return self.unpack_single(rtp_packet.payload.clone(), *packet_type); in unpack()179 return self.unpack_stap(rtp_packet.payload.clone(), *packet_type); in unpack()182 return self.unpack_mtap(rtp_packet.payload.clone(), *packet_type); in unpack()185 return self.unpack_fu(rtp_packet.payload.clone(), *packet_type); in unpack()
183 let rtp_packet = RtpPacket::unmarshal(reader)?; in unpack() localVariable186 f(rtp_packet.clone()); in unpack()189 self.timestamp = rtp_packet.header.timestamp; in unpack()190 self.sequence_number = rtp_packet.header.seq_number; in unpack()192 if let Some(packet_type) = rtp_packet.payload.first() { in unpack()195 return self.unpack_fu(rtp_packet.payload.clone()); in unpack()198 return self.unpack_ap(rtp_packet.payload); in unpack()203 return self.unpack_single(rtp_packet.payload.clone()); in unpack()
119 let rtp_packet = RtpPacket::unmarshal(reader)?; in unpack() localVariable122 f(rtp_packet.clone()); in unpack()125 let mut reader_payload = BytesReader::new(rtp_packet.payload); in unpack()149 timestamp: rtp_packet.header.timestamp + i as u32 * 1024, in unpack()
115 while let Ok((rtp_packet, _)) = track.read(&mut b).await { in handle_whip()121 let n = rtp_packet.marshal_to(&mut b)?; in handle_whip()123 match rtp_packet.header.payload_type { in handle_whip()127 timestamp: rtp_packet.header.timestamp, in handle_whip()137 timestamp: rtp_packet.header.timestamp, in handle_whip()