Home
last modified time | relevance | path

Searched refs:payload (Results 1 – 12 of 12) sorted by relevance

/xiu/protocol/rtsp/src/rtp/
H A Drtp_h264.rs76 packet.payload.put_u8(fu_indicator); in pack_fu_a()
77 packet.payload.put_u8(fu_header); in pack_fu_a()
83 packet.payload.put(fu_payload); in pack_fu_a()
104 packet.payload.put(nalu); in pack_single()
208 payload: BytesMut, in unpack_single()
214 annexb_payload.put(payload); in unpack_single()
293 data: payload, in unpack_fu()
364 payload.put(nalu); in unpack_stap()
368 data: payload, in unpack_stap()
458 payload.put(nalu); in unpack_mtap()
[all …]
H A Drtp_h265.rs101 packet.payload.put_u16(payload_hdr); in pack_fu()
102 packet.payload.put_u8(fu_header); in pack_fu()
103 packet.payload.put(fu_payload); in pack_fu()
126 packet.payload.put(nalu); in pack_single()
224 annexb_payload.put(payload); in unpack_single()
274 let mut payload = BytesMut::new(); in unpack_ap() localVariable
276 payload.put(nalu); in unpack_ap()
281 data: payload, in unpack_ap()
342 let mut payload = BytesMut::new(); in unpack_fu() localVariable
344 payload.put(self.fu_buffer.clone()); in unpack_fu()
[all …]
H A Dmod.rs27 pub payload: BytesMut, field
60 .payload in unmarshal()
64 rtp_packet.payload.put(reader.extract_remaining_bytes()); in unmarshal()
84 writer.write(&self.payload[..])?; in marshal()
H A Drtp_aac.rs61 packet.payload.put_u16(16); in pack()
62 packet.payload.put_u8((data_len >> 5) as u8); in pack()
63 packet.payload.put_u8(((data_len & 0x1F) << 3) as u8); in pack()
64 packet.payload.put(data); in pack()
125 let mut reader_payload = BytesReader::new(rtp_packet.payload); in unpack()
/xiu/library/container/mpegts/src/
H A Dcrc32.rs63 let mut payload = BytesMut::new(); in test_gen_crc32() localVariable
64 payload.extend_from_slice(&data[..]); in test_gen_crc32()
66 let result = gen_crc32(0xffffffff, payload); in test_gen_crc32()
H A Dts.rs71 payload: BytesMut, in write()
130 self.write_pes(payload)?; in write()
138 payload: BytesMut, in write_ts_header_for_pat_pmt()
155 self.bytes_writer.write(&payload)?; in write_ts_header_for_pat_pmt()
157 let left_size = ts::TS_PACKET_SIZE - payload.len() as u8 - 5; in write_ts_header_for_pat_pmt()
164 pub fn write_pes(&mut self, payload: BytesMut) -> Result<(), MpegTsError> { in write_pes()
166 let mut payload_reader = BytesReader::new(payload); in write_pes()
/xiu/protocol/rtmp/src/chunk/
H A Dmod.rs101 pub payload: BytesMut, field
106 let hex_payload = hex::encode(&self.payload); in fmt()
137 payload: BytesMut, in new()
147 payload, in new()
H A Dunpacketizer.rs554 || (cur_format_id == 3 && self.current_chunk_info.payload.is_empty()) in read_extended_timestamp()
565 self.current_chunk_info.payload.len(), in read_extended_timestamp()
580 let remaining_bytes = whole_msg_length - self.current_chunk_info.payload.len(); in read_message_payload()
593 let remaining_mut = self.current_chunk_info.payload.remaining_mut(); in read_message_payload()
596 self.current_chunk_info.payload.reserve(additional); in read_message_payload()
607 .payload in read_message_payload()
612 self.current_chunk_info.payload.len() in read_message_payload()
615 if self.current_chunk_info.payload.len() == whole_msg_length { in read_message_payload()
619 self.current_chunk_info.payload.clear(); in read_message_payload()
H A Dpacketizer.rs177 let mut whole_payload_size = chunk_info.payload.len(); in write_chunk()
198 let payload_bytes = chunk_info.payload.split_to(cur_payload_size); in write_chunk()
/xiu/protocol/hls/src/
H A Dflv2hls.rs115 let mut payload: BytesMut = BytesMut::new(); in process_demux_data() localVariable
122 payload.extend_from_slice(&data.data[..]); in process_demux_data()
139 payload.extend_from_slice(&data.data[..]); in process_demux_data()
165 .write(pid, pts * 90, dts * 90, flags, payload)?; in process_demux_data()
/xiu/protocol/rtmp/src/messages/
H A Dparser.rs25 let mut reader = BytesReader::new(self.chunk_info.payload); in parse()
/xiu/protocol/rtsp/src/rtp/rtcp/
H A Drtcp_context.rs216 self.send_bytes += pkt.payload.len() as u64; in send_rtp()