| /xiu/protocol/rtsp/src/rtp/ |
| H A D | mod.rs | 23 pub header: RtpHeader, field
38 header: RtpHeader::unmarshal(reader)?, in unmarshal()
42 if rtp_packet.header.extension_flag == 1 { in unmarshal()
57 if rtp_packet.header.padding_flag == 1 { in unmarshal()
75 let header_bytesmut = self.header.marshal()?; in marshal()
78 if self.header.extension_flag == 1 { in marshal()
85 if self.header.padding_flag == 1 { in marshal()
94 fn new(header: RtpHeader) -> Self { in new()
96 header, in new()
|
| H A D | rtp_h265.rs | 25 header: RtpHeader, field
41 header: RtpHeader { in new()
100 let mut packet = RtpPacket::new(self.header.clone()); in pack_fu()
104 packet.header.marker = if fu_header & define::FU_END > 0 { 1 } else { 0 }; in pack_fu()
118 self.header.seq_number += 1; in pack_fu()
124 let mut packet = RtpPacket::new(self.header.clone()); in pack_single()
125 packet.header.marker = 1; in pack_single()
128 self.header.seq_number += 1; in pack_single()
144 self.header.timestamp = timestamp; in pack()
189 self.timestamp = rtp_packet.header.timestamp; in unpack()
[all …]
|
| H A D | rtp_aac.rs | 26 header: RtpHeader, field
40 header: RtpHeader { in new()
57 self.header.timestamp = timestamp; in pack()
60 let mut packet = RtpPacket::new(self.header.clone()); in pack()
74 self.header.seq_number += 1; in pack()
149 timestamp: rtp_packet.header.timestamp + i as u32 * 1024, in unpack()
|
| H A D | rtp_h264.rs | 25 header: RtpHeader, field
41 header: RtpHeader { in new()
75 let mut packet = RtpPacket::new(self.header.clone()); in pack_fu_a()
84 packet.header.marker = if fu_header & define::FU_END > 0 { 1 } else { 0 }; in pack_fu_a()
96 self.header.seq_number += 1; in pack_fu_a()
102 let mut packet = RtpPacket::new(self.header.clone()); in pack_single()
103 packet.header.marker = 1; in pack_single()
107 self.header.seq_number += 1; in pack_single()
125 … self.header.timestamp = timestamp; // ((timestamp as u64 * self.clock_rate as u64) / 1000) as u32; in pack()
170 self.timestamp = rtp_packet.header.timestamp; in unpack()
[all …]
|
| /xiu/protocol/rtsp/src/rtp/rtcp/ |
| H A D | rtcp_app.rs | 23 pub header: RtcpHeader, field
37 rtcp_app.header = RtcpHeader::unmarshal(&mut reader)?; in unmarshal()
41 rtcp_app.app_data = reader.read_bytes(rtcp_app.header.length as usize * 4)?; in unmarshal()
51 let header_bytesmut = self.header.marshal()?; in marshal()
|
| H A D | rtcp_bye.rs | 23 pub header: RtcpHeader, field
37 header: RtcpHeader::unmarshal(&mut reader)?, in unmarshal()
41 for _ in 0..rtcp_bye.header.report_count { in unmarshal()
57 let header_bytesmut = self.header.marshal()?; in marshal()
|
| H A D | rtcp_sr.rs | 49 pub header: RtcpHeader, field
64 header: RtcpHeader::unmarshal(reader)?, in unmarshal()
73 for _ in 0..sender_report.header.report_count { in unmarshal()
86 let header_bytesmut = self.header.marshal()?; in marshal()
|
| H A D | rtcp_rr.rs | 56 pub header: RtcpHeader, field
69 header: RtcpHeader::unmarshal(&mut reader)?, in unmarshal()
74 for _ in 0..receiver_report.header.report_count { in unmarshal()
87 let header_bytesmut = self.header.marshal()?; in marshal()
|
| H A D | rtcp_context.rs | 157 header: RtcpHeader { in generate_bye()
203 header: RtcpHeader { in generate_rr()
218 self.last_rtp_timestamp = pkt.header.timestamp; in send_rtp()
229 if 0 == self.source.update_sequence(pkt.header.seq_number) { in received_rtp()
239 - (pkt.header.timestamp - self.last_rtp_timestamp) as i64; in received_rtp()
248 self.last_rtp_timestamp = pkt.header.timestamp; in received_rtp()
|
| /xiu/protocol/webrtc/src/ |
| H A D | whip.rs | 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()
|
| /xiu/library/container/mpegts/src/ |
| H A D | pes.rs | 163 let header: [u8; 6] = [0x00, 0x00, 0x00, 0x01, 0x09, 0xF0]; in write_pes_header() localVariable
164 self.bytes_writer.write(&header)?; in write_pes_header()
|
| /xiu/protocol/webrtc/src/clients/ |
| H A D | whep.js | 99 for (const header of linkHeaders) {
103 const items = header.split(";");
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | unpacketizer.rs | 321 Some(header) => { in read_basic_header()
322 self.current_chunk_info.message_header = header.clone(); in read_basic_header()
|
| /xiu/ |
| H A D | Cargo.lock | 1339 name = "http-range-header"
2963 "http-range-header",
|