Home
last modified time | relevance | path

Searched refs:len (Results 1 – 25 of 51) sorted by relevance

123

/xiu/protocol/rtmp/src/utils/
H A Dprint.rs3 println!("==========={}", data.len()); in print()
17 println!("==========={}:{}", title, data.len()); in print2()
31 println!("==========={}", data.len()); in printu8()
44 pub fn print_array(data: &[u8], len: usize) { in print_array()
47 for item in data.iter().take(len) { in print_array()
H A Dmod.rs47 if url_parts.len() != 3 { in parse_url()
71 if data.len() > 1 { in parse_raw_domain_name()
80 if data.len() > 1 { in parse_raw_stream_name()
/xiu/protocol/rtmp/src/amf0/
H A Damf0_writer.rs52 if value.len() > (u16::max_value() as usize) { in write_string()
59 self.writer.write_u16::<BigEndian>(value.len() as u16)?; in write_string()
83 self.writer.write_u16::<BigEndian>(key.len() as u16)?; in write_object()
98 .write_u32::<BigEndian>(properties.len() as u32)?; in write_eacm_array()
101 self.writer.write_u16::<BigEndian>(key.len() as u16)?; in write_eacm_array()
122 pub fn len(&self) -> usize { in len() method
123 self.writer.len() in len()
126 self.len() == 0 in is_empty()
/xiu/protocol/rtmp/src/cache/
H A Dgop.rs26 pub fn len(&self) -> usize { in len() method
27 self.datas.len() in len()
31 self.len() == 0 in is_empty()
62 if self.gops.len() == self.size { in save_frame_data()
H A Dmetadata.rs38 let (_, right) = self.chunk_body.split_at(amf_writer.len()); in remove_set_data_frame()
56 if values.len() < 2 { in is_metadata()
/xiu/library/container/flv/src/
H A Dmpeg4_avc.rs27 pub fn len(&self) -> usize { in len() method
28 self.data.len() in len()
32 self.len() == 0 in is_empty()
49 pub fn len(&self) -> usize { in len() method
50 self.data.len() in len()
53 self.len() == 0 in is_empty()
84 println!("==========={}", data.len()); in print()
291 let length = nalu.len(); in nalus_to_mpeg4avc()
311 bytes_writer.write_u16::<BigEndian>(self.mpeg4_avc.sps[i].len() as u16)?; in decoder_configuration_record_save()
318 bytes_writer.write_u16::<BigEndian>(self.mpeg4_avc.pps[i].len() as u16)?; in decoder_configuration_record_save()
H A Dmpeg4_aac.rs168 if 5 != extension_audio_object_type && self.bits_reader.len() >= 16 { in audio_specific_config_load2()
179 if self.bits_reader.len() >= 12 { in audio_specific_config_load2()
369 let rv = (pce_bits_vec.len() + 7) / 8; in pce_load()
407 let len = (self.bytes_reader.len() + 7) as u32; in adts_save() localVariable
423 .write_u8(((channel_configuration & 0x03) << 6) | ((len >> 11) as u8 & 0x03))?; //3 in adts_save()
424 self.bytes_writer.write_u8((len >> 3) as u8)?; //4 in adts_save()
426 .write_u8((((len & 0x07) as u8) << 5) | 0x1F)?; //5 in adts_save()
/xiu/library/bytesio/src/
H A Dbytes_reader.rs22 let extend_length = extend.len(); in extend_from_slice()
33 if self.buffer.len() < bytes_num { in read_bytes()
42 if self.buffer.len() < bytes_num { in advance_bytes()
127 if index >= self.len() { in get()
136 pub fn len(&self) -> usize { in len() method
137 self.buffer.len() in len()
141 self.len() == 0 in is_empty()
145 self.buffer.split_to(self.buffer.len()) in extract_remaining_bytes()
174 while self.bytes_reader.len() < bytes_num { in check()
H A Dbytes_writer.rs35 if position > self.bytes.len() { in or_u8_at()
46 if position > self.bytes.len() { in add_u8_at()
57 if position > self.bytes.len() { in write_u8_at()
145 pub fn len(&self) -> usize { in len() method
146 self.bytes.len() in len()
150 self.len() == 0 in is_empty()
243 assert_eq!(1, v.len()); in test_write_vec()
264 assert_eq!(10, v.len()); in test_write_vec()
H A Dbits_reader.rs26 pub fn len(&self) -> usize { in len() method
27 self.reader.len() * 8 + self.cur_bit_left as usize in len()
31 self.len() == 0 in is_empty()
H A Dbits_writer.rs119 pub fn len(&self) -> usize { in len() method
120 self.writer.len() * 8 + self.cur_bit_num as usize in len()
123 self.len() == 0 in is_empty()
H A Dbytesio.rs84 let len = self.socket.recv(&mut buf).await?; in read() localVariable
86 rv.put(&buf[..len]); in read()
/xiu/protocol/webrtc/src/http/
H A Dmod.rs45 let start_index = request_data.find(start)? + start.len(); in parse_content_length()
54 log::trace!("len: {} content: {}", request_data.len(), request_data); in unmarshal()
71 if path_data.len() > 1 { in unmarshal()
115 request_data.len() in unmarshal()
118 if request_data.len() > header_end_idx { in unmarshal()
138 request_str += &format!("Content-Length: {}\r\n", body.len()); in marshal()
197 if request_data.len() > header_end_idx { in unmarshal()
220 response_str += &format!("Content-Length: {}\r\n", body.len()); in marshal()
/xiu/library/container/mpegts/src/
H A Dpes.rs72 pub fn len(&self) -> usize { in len() method
73 self.bytes_writer.len() in len()
77 self.len() == 0 in is_empty()
168 self.bytes_writer.len() - define::PES_HEADER_LEN as usize + payload_data_length; in write_pes_header()
H A Dts.rs157 let left_size = ts::TS_PACKET_SIZE - payload.len() as u8 - 5; in write_ts_header_for_pat_pmt()
175 payload_reader.len(), in write_pes()
181 let pes_header_length: usize = pes_muxer.len(); in write_pes()
182 let mut payload_length = payload_reader.len(); in write_pes()
290 let ts_header_length = ts_header.len(); in write_ts_header_for_pes()
372 if pmt.streams.len() == 4 { in pmt_add_stream()
413 if self.pat.pmt.len() == 4 { in add_program()
H A Dpmt.rs76 let program_info_length = pmt.program_info.len() as u16; in write()
99 .write_u16::<BigEndian>(0xB000 | ((tmp_bytes_writer.len() as u16) + 4))?; in write()
/xiu/protocol/rtsp/src/
H A Drtsp_range.rs25 if kv.len() < 2 { in unmarshal()
47 if ranges.len() > 1 { in unmarshal()
78 if ranges.len() == 2 && !ranges[1].is_empty() { in unmarshal()
H A Drtsp_utils.rs12 println!("==========={}:{}", title, data.len()); in print()
/xiu/protocol/rtsp/src/rtp/
H A Dutils.rs78 nalus.windows(pattern.len()).position(|w| w == pattern) in find_start_code()
99 nalus.split_to(nalus.len()) in split_annexb_and_process()
127 nalus.windows(pattern.len()).position(|w| w == pattern) in find_start_code()
154 nalus.split_to(nalus.len()) in test_annexb_split()
H A Dmod.rs58 let padding_length = reader.get(reader.len() - 1)? as usize; in unmarshal()
61 .put(reader.read_bytes(reader.len() - padding_length)?); in unmarshal()
/xiu/protocol/rtmp/src/chunk/
H A Dunpacketizer.rs116 self.reader.len(), in extend_data()
119 .split_to(self.reader.len()) in extend_data()
383 self.reader.len(), in read_message_header()
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()
601 self.reader.len(), 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()
/xiu/protocol/rtsp/src/sdp/
H A Dfmtp.rs76 if eles.len() < 2 { in unmarshal()
88 if kv.len() < 2 { in unmarshal()
139 if eles.len() < 2 { in unmarshal()
151 if kv.len() < 2 { in unmarshal()
197 if eles.len() < 2 { in unmarshal()
209 if kv.len() < 2 { in unmarshal()
/xiu/protocol/rtmp/src/protocol_control_messages/
H A Dwriter.rs18 len: u32, in write_control_message_header()
27 self.writer.write_u24::<BigEndian>(len)?; //msg length in write_control_message_header()
/xiu/protocol/rtsp/src/http/
H A Dmod.rs77 if request_data.len() > header_end_idx { in unmarshal()
95 request_str += &format!("Content-Length: {}\r\n", body.len()); in marshal()
149 if request_data.len() > header_end_idx { in unmarshal()
170 response_str += &format!("Content-Length: {}\r\n", body.len()); in marshal()
/xiu/protocol/rtmp/src/user_control_messages/
H A Dwriter.rs17 fn write_control_message_header(&mut self, len: u32) -> Result<(), EventMessagesError> { in write_control_message_header()
26 self.writer.write_u24::<BigEndian>(len)?; //msg length in write_control_message_header()

123