Lines Matching refs:payload
164 fn payload(&mut self, mtu: usize, payload: &Bytes) -> Result<Vec<Bytes>> { in payload() method
165 if payload.is_empty() || mtu == 0 { in payload()
171 let (mut next_ind_start, mut next_ind_len) = H264Payloader::next_ind(payload, 0); in payload()
173 self.emit(payload, mtu, &mut payloads); in payload()
177 let (next_ind_start2, next_ind_len2) = H264Payloader::next_ind(payload, prev_start); in payload()
182 &payload.slice(prev_start..next_ind_start as usize), in payload()
188 self.emit(&payload.slice(prev_start..), mtu, &mut payloads); in payload()
215 let mut payload = BytesMut::new(); in depacketize() localVariable
225 payload.put_u32(packet.len() as u32); in depacketize()
227 payload.put(&*ANNEXB_NALUSTART_CODE); in depacketize()
229 payload.put(&*packet.clone()); in depacketize()
230 Ok(payload.freeze()) in depacketize()
247 payload.put_u32(nalu_size as u32); in depacketize()
249 payload.put(&*ANNEXB_NALUSTART_CODE); in depacketize()
251 payload.put(&*packet.slice(curr_offset..curr_offset + nalu_size)); in depacketize()
255 Ok(payload.freeze()) in depacketize()
277 payload.put_u32((fua_buffer.len() + 1) as u32); in depacketize()
279 payload.put(&*ANNEXB_NALUSTART_CODE); in depacketize()
281 payload.put_u8(nalu_ref_idc | fragmented_nalu_type); in depacketize()
282 payload.put(fua_buffer); in depacketize()
285 Ok(payload.freeze()) in depacketize()
295 fn is_partition_head(&self, payload: &Bytes) -> bool { in is_partition_head()
296 if payload.len() < 2 { in is_partition_head()
300 if payload[0] & NALU_TYPE_BITMASK == FUA_NALU_TYPE in is_partition_head()
301 || payload[0] & NALU_TYPE_BITMASK == FUB_NALU_TYPE in is_partition_head()
303 (payload[1] & FU_START_BITMASK) != 0 in is_partition_head()