Home
last modified time | relevance | path

Searched refs:usize (Results 1 – 25 of 53) sorted by relevance

123

/xiu/protocol/rtmp/src/handshake/
H A Ddigest.rs54 fn find_digest_offset(&mut self, version: SchemaVersion) -> Result<usize, DigestError> { in find_digest_offset() argument
55 let mut digest_offset: usize = 0; in find_digest_offset()
59 digest_offset += self.reader.get(772)? as usize; in find_digest_offset()
60 digest_offset += self.reader.get(773)? as usize; in find_digest_offset()
61 digest_offset += self.reader.get(774)? as usize; in find_digest_offset()
62 digest_offset += self.reader.get(775)? as usize; in find_digest_offset()
68 digest_offset += self.reader.get(8)? as usize; in find_digest_offset()
69 digest_offset += self.reader.get(9)? as usize; in find_digest_offset()
70 digest_offset += self.reader.get(10)? as usize; in find_digest_offset()
71 digest_offset += self.reader.get(11)? as usize; in find_digest_offset()
[all …]
H A Ddefine.rs21 pub const RTMP_VERSION: usize = 3;
22 pub const RTMP_HANDSHAKE_SIZE: usize = 1536;
27 pub const RTMP_DIGEST_LENGTH: usize = 32;
/xiu/application/xiu/src/config/
H A Dmod.rs22 rtmp_port: usize, in new() argument
23 rtsp_port: usize, in new() argument
24 webrtc_port: usize, in new() argument
26 hls_port: usize, in new() argument
94 pub port: usize,
109 pub port: usize,
115 pub port: usize,
121 pub port: usize,
127 pub port: usize,
133 pub port: usize,
[all …]
/xiu/application/xiu/src/
H A Dmain.rs36 .value_parser(value_parser!(usize)) in main()
45 .value_parser(value_parser!(usize)) in main()
54 .value_parser(value_parser!(usize)) in main()
63 .value_parser(value_parser!(usize)) in main()
72 .value_parser(value_parser!(usize)) in main()
119 let rtmp_port_o = matches.get_one::<usize>("rtmp"); in main()
120 let rtsp_port_o = matches.get_one::<usize>("rtsp"); in main()
121 let webrtc_port_o = matches.get_one::<usize>("webrtc"); in main()
143 let httpflv_port = match matches.get_one::<usize>("httpflv") { in main()
147 let hls_port = match matches.get_one::<usize>("hls") { in main()
/xiu/library/bytesio/src/
H A Dbytes_reader.rs32 pub fn read_bytes(&mut self, bytes_num: usize) -> Result<BytesMut, BytesReadError> { in read_bytes()
41 pub fn advance_bytes(&mut self, bytes_num: usize) -> Result<BytesMut, BytesReadError> { in advance_bytes()
54 bytes_num: usize, in read_bytes_cursor() argument
63 bytes_num: usize, in advance_bytes_cursor() argument
126 pub fn get(&self, index: usize) -> Result<u8, BytesReadError> { in get()
136 pub fn len(&self) -> usize { in len() argument
173 async fn check(&mut self, bytes_num: usize) -> Result<(), BytesReadError> { in check()
181 pub async fn read_bytes(&mut self, bytes_num: usize) -> Result<BytesMut, BytesReadError> { in read_bytes()
186 pub async fn advance_bytes(&mut self, bytes_num: usize) -> Result<BytesMut, BytesReadError> { in advance_bytes()
193 bytes_num: usize, in read_bytes_cursor() argument
[all …]
H A Dbits_writer.rs66 pub fn write_n_bits(&mut self, data: u64, bit_num: usize) -> Result<(), BitError> { in write_n_bits()
79 let cur_byte_left_bit_num = 8 - self.cur_bit_num as usize; in write_n_bits()
119 pub fn len(&self) -> usize { in len() argument
120 self.writer.len() * 8 + self.cur_bit_num as usize in len()
H A Dbytes_writer.rs34 pub fn or_u8_at(&mut self, position: usize, byte: u8) -> Result<(), BytesWriteError> { in or_u8_at() argument
45 pub fn add_u8_at(&mut self, position: usize, byte: u8) -> Result<(), BytesWriteError> { in add_u8_at() argument
56 pub fn write_u8_at(&mut self, position: usize, byte: u8) -> Result<(), BytesWriteError> { in write_u8_at() argument
67 pub fn get(&mut self, position: usize) -> Option<&u8> { in get()
139 pub fn pop_bytes(&mut self, size: usize) { in pop_bytes() argument
145 pub fn len(&self) -> usize { in len() argument
H A Dbits_reader.rs26 pub fn len(&self) -> usize { in len() argument
27 self.reader.len() * 8 + self.cur_bit_left as usize in len()
54 pub fn read_n_bits(&mut self, n: usize) -> Result<u64, BitError> { in read_n_bits()
/xiu/protocol/rtmp/src/cache/
H A Dgop.rs26 pub fn len(&self) -> usize { in len() argument
38 size: usize,
48 pub fn new(size: usize) -> Self { in new()
/xiu/library/container/flv/src/
H A Dmpeg4_avc.rs27 pub fn len(&self) -> usize { in len() argument
49 pub fn len(&self) -> usize { in len() argument
167 for i in 0..self.mpeg4_avc.nb_sps as usize { in decoder_configuration_record_load()
173 data: bytes_reader.read_bytes(sps_data_size as usize)?, in decoder_configuration_record_load()
209 for i in 0..self.mpeg4_avc.nb_pps as usize { in decoder_configuration_record_load()
213 data: bytes_reader.read_bytes(pps_data_size as usize)?, in decoder_configuration_record_load()
257 let data = bytes_reader.read_bytes(size as usize)?; in h264_mp4toannexb()
276 length: usize, in write_nalu_size() argument
310 for i in 0..self.mpeg4_avc.nb_sps as usize { in decoder_configuration_record_save()
317 for i in 0..self.mpeg4_avc.nb_pps as usize { in decoder_configuration_record_save()
H A Dmpeg4_aac.rs10 const AAC_FREQUENCE_SIZE: usize = 13;
23 pub sbr: usize,
24 pub ps: usize,
26 pub npce: usize,
90 AAC_FREQUENCE[self.mpeg4_aac.sampling_frequency_index as usize]; in audio_specific_config_load()
176 self.mpeg4_aac.sbr = self.bits_reader.read_n_bits(1)? as usize; in audio_specific_config_load2()
182 self.mpeg4_aac.ps = self.bits_reader.read_n_bits(1)? as usize; in audio_specific_config_load2()
188 self.mpeg4_aac.sbr = self.bits_reader.read_n_bits(1)? as usize; in audio_specific_config_load2()
281 read_len: usize, in mpeg4_bits_copy() argument
/xiu/library/container/mpegts/src/
H A Dts.rs24 cur_pmt_index: usize,
25 cur_stream_index: usize,
27 packet_number: usize,
181 let pes_header_length: usize = pes_muxer.len(); in write_pes()
208 pes_header_length: usize, in write_ts_header_for_pes() argument
209 payload_data_length: usize, in write_ts_header_for_pes() argument
211 ) -> Result<usize, MpegTsError> { in write_ts_header_for_pes() argument
324 let mut stream_index: usize = 0; in find_stream()
366 pmt_index: usize, in pmt_add_stream() argument
H A Dpes.rs16 pub esinfo_length: usize,
72 pub fn len(&self) -> usize { in len() argument
83 payload_data_length: usize, in write_pes_header() argument
168 self.bytes_writer.len() - define::PES_HEADER_LEN as usize + payload_data_length; in write_pes_header()
H A Ddefine.rs36 pub const TS_PACKET_SIZE: usize = 188;
/xiu/library/streamhub/src/statistics/
H A Dmod.rs18 frame_rate: usize,
19 gop: usize,
H A Davstatistics.rs28 frame_count: Arc<Mutex<usize>>,
30 gop_frame_count: Arc<Mutex<usize>>,
65 pub async fn notify_audio_statistics_info(&mut self, data_size: usize, aac_packet_type: u8) { in notify_audio_statistics_info() argument
75 pub async fn notify_video_statistics_info(&mut self, data_size: usize, is_key_frame: bool) { in notify_video_statistics_info() argument
/xiu/protocol/rtmp/src/
H A Drtmp.rs11 gop_num: usize,
15 pub fn new(address: String, event_producer: StreamHubEventSender, gop_num: usize) -> Self { in new()
/xiu/protocol/rtsp/src/rtp/
H A Drtp_h264.rs26 mtu: usize,
37 mtu: usize, in new() argument
62 let mut left_nalu_bytes: usize = nalu_reader.len(); in pack_fu_a()
63 let mut fu_payload_len: usize; in pack_fu_a()
359 let length = payload_reader.read_u16::<BigEndian>()? as usize; in unpack_stap()
441 let nalu_size = payload_reader.read_u16::<BigEndian>()? as usize; in unpack_mtap()
H A Ddefine.rs19 pub const RTP_FIXED_HEADER_LEN: usize = 12;
H A Drtp_h265.rs26 mtu: usize,
37 mtu: usize, in new() argument
86 let mut left_nalu_bytes: usize = nalu_reader.len(); in pack_fu()
87 let mut fu_payload_len: usize; in pack_fu()
270 let nalu_len = payload_reader.read_u16::<BigEndian>()? as usize; in unpack_ap()
H A Dmod.rs54 reader.read_bytes(4 * rtp_packet.header_extension_length as usize)?; in unmarshal()
58 let padding_length = reader.get(reader.len() - 1)? as usize; in unmarshal()
/xiu/library/streamhub/src/
H A Dutils.rs71 let random_size = random_digit_count as usize; in new()
104 .take(10 + self.random_count as usize) in fmt()
/xiu/protocol/rtmp/src/chunk/
H A Dpacketizer.rs23 max_chunk_size: usize,
35 max_chunk_size: CHUNK_SIZE as usize, in new()
190 let mut cur_payload_size: usize; in write_chunk()
H A Dunpacketizer.rs15 const PARSE_ERROR_NUMVER: usize = 5;
84 max_chunk_size: usize,
87 parse_error_number: usize,
104 max_chunk_size: define::INIT_CHUNK_SIZE as usize, in new()
124 pub fn update_max_chunk_size(&mut self, chunk_size: usize) { in update_max_chunk_size() argument
579 let whole_msg_length = self.current_message_header().msg_length as usize; in read_message_payload()
/xiu/protocol/rtmp/src/utils/
H A Dprint.rs44 pub fn print_array(data: &[u8], len: usize) { in print_array() argument

123