Home
last modified time | relevance | path

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

123

/xiu/protocol/rtmp/src/chunk/
H A Ddefine.rs2 pub const PROTOCOL_USER_CONTROL: u32 = 2;
3 pub const COMMAND_AMF0_AMF3: u32 = 3;
4 pub const AUDIO: u32 = 4;
5 pub const VIDEO: u32 = 5;
6 pub const DATA_AMF0_AMF3: u32 = 6;
16 pub const CHUNK_SIZE: u32 = 4096;
17 pub const INIT_CHUNK_SIZE: u32 = 128;
H A Dmod.rs15 pub chunk_stream_id: u32,
19 pub fn new(fmt: u8, csid: u32) -> ChunkBasicHeader { in new()
42 pub timestamp: u32,
43 pub msg_length: u32,
45 pub msg_streamd_id: u32,
50 pub timestamp_delta: u32,
59 pub fn new(timestamp: u32, msg_length: u32, msg_type_id: u8, msg_stream_id: u32) -> Self { in new() argument
131 csid: u32, in new() argument
133 timestamp: u32, in new() argument
134 msg_length: u32, in new() argument
[all …]
H A Dpacketizer.rs19 csid_2_chunk_header: HashMap<u32, ChunkHeader>,
27 extended_timestamp: Option<u32>,
86 fn write_basic_header(&mut self, fmt: u8, csid: u32) -> Result<(), PackError> { in write_basic_header()
105 let message_header_timestamp: u32; in write_message_header()
163 fn write_extened_timestamp(&mut self, timestamp: u32) -> Result<(), PackError> { in write_extened_timestamp()
/xiu/protocol/rtsp/src/rtp/rtcp/
H A Drtcp_context.rs25 const MIN_SEQUENTIAL: u32 = 2;
26 const RTP_SEQ_MOD: u32 = 1 << 16;
27 const MAX_DROPOUT: u32 = 3000;
28 const MAX_MISORDER: u32 = 100;
96 self.base_seq = seq as u32; in init_seq()
113 ssrc: u32,
114 sender_ssrc: u32,
119 last_rtp_timestamp: u32,
120 sample_rate: u32,
128 pub fn new(ssrc: u32, seq: u16, sample_rate: u32) -> Self { in new() argument
[all …]
H A Drtcp_rr.rs12 pub ssrc: u32,
14 pub cumutlative_num_of_packets_lost: u32,
15 pub extended_highest_seq_number: u32,
16 pub jitter: u32,
17 pub lsr: u32,
18 pub dlsr: u32,
57 pub ssrc: u32,
H A Drtcp_sr.rs50 pub ssrc: u32,
52 rtp_timestamp: u32,
53 sender_packet_count: u32,
54 sender_octet_count: u32,
/xiu/protocol/rtmp/src/messages/
H A Ddefine.rs5 pub window_size: u32,
10 pub fn new(window_size: u32, limit_type: u8) -> Self { in new() argument
29 chunk_size: u32,
32 chunk_stream_id: u32,
35 sequence_number: u32,
38 size: u32,
50 stream_id: u32,
51 buffer_length: u32,
54 stream_id: u32,
57 stream_id: u32,
/xiu/library/codec/h264/src/
H A Dsps.rs12 seq_parameter_set_id: u32, // ue(v)
14 chroma_format_idc: u32, // ue(v)
25 log2_max_frame_num_minus4: u32, // ue(v)
26 pic_order_cnt_type: u32, // ue(v)
40 pic_width_in_mbs_minus1: u32, // ue(v)
41 pic_height_in_map_units_minus1: u32, // ue(v)
50 frame_crop_left_offset: u32, // ue(v)
51 frame_crop_right_offset: u32, // ue(v)
52 frame_crop_top_offset: u32, // ue(v)
53 frame_crop_bottom_offset: u32, // ue(v)
[all …]
/xiu/library/container/mpegts/src/
H A Dcrc32.rs3 const CRC32_TABLE: [u32; 256] = [
38 pub fn gen_crc32(crc: u32, buffer: BytesMut) -> u32 { in gen_crc32() argument
39 let mut result: u32 = crc; in gen_crc32()
42 let a = result ^ i as u32; in gen_crc32()
/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()
33 pub async fn write_stream_begin(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_begin()
43 pub async fn write_stream_eof(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_eof()
54 pub async fn write_stream_dry(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_dry()
67 stream_id: u32, in write_set_buffer_length() argument
68 ms: u32, in write_set_buffer_length() argument
83 stream_id: u32, in write_stream_is_record() argument
95 pub async fn write_ping_request(&mut self, timestamp: u32) -> Result<(), EventMessagesError> { in write_ping_request()
106 pub async fn write_ping_response(&mut self, timestamp: u32) -> Result<(), EventMessagesError> { in write_ping_response()
/xiu/protocol/rtmp/src/protocol_control_messages/
H A Dwriter.rs18 len: u32, in write_control_message_header() argument
35 chunk_size: u32, in write_set_chunk_size() argument
47 chunk_stream_id: u32, in write_abort_message() argument
58 sequence_number: u32, in write_acknowledgement() argument
69 window_size: u32, in write_window_acknowledgement_size() argument
80 window_size: u32, in write_set_peer_bandwidth() argument
H A Dreader.rs15 pub fn read_set_chunk_size(&mut self) -> Result<u32, ProtocolControlMessageReaderError> { in read_set_chunk_size() argument
20 pub fn read_abort_message(&mut self) -> Result<u32, ProtocolControlMessageReaderError> { in read_abort_message() argument
25 pub fn read_acknowledgement(&mut self) -> Result<u32, ProtocolControlMessageReaderError> { in read_acknowledgement() argument
32 ) -> Result<u32, ProtocolControlMessageReaderError> { in read_window_acknowledgement_size() argument
/xiu/library/container/flv/src/
H A Dmuxer.rs14 pub const HEADER_LENGTH: u32 = 11;
40 data_size: u32, in write_flv_tag_header() argument
41 timestamp: u32, in write_flv_tag_header() argument
63 pub fn write_previous_tag_size(&mut self, size: u32) -> Result<(), FlvMuxerError> { in write_previous_tag_size()
H A Dmpeg4_avc.rs63 pub width: u32,
64 pub height: u32,
264 …pub fn read_nalu_size(&mut self, bytes_reader: &mut BytesReader) -> Result<u32, Mpeg4AvcHevcError>… in read_nalu_size() argument
265 let mut size: u32 = 0; in read_nalu_size()
268 size = bytes_reader.read_u8()? as u32 + (size << 8); in read_nalu_size()
343 let mut size: u32 = 0; in test_bytes_to_bigend()
349 size = bytes_reader.read_u8().unwrap() as u32 + (size << 8); in test_bytes_to_bigend()
H A Ddemuxer.rs127 timestamp: u32, in demux() argument
176 timestamp: u32, in demux() argument
244 let dts: u32 = (timestamp & 0xffffff) | ((timestamp_ext as u32) << 24); in read_flv_tag()
H A Ddefine.rs161 Video { timestamp: u32, data: BytesMut },
162 Audio { timestamp: u32, data: BytesMut },
163 MetaData { timestamp: u32, data: BytesMut },
/xiu/protocol/rtmp/src/handshake/
H A Dutils.rs3 pub fn current_time() -> u32 { in current_time()
7 Ok(result) => result.as_nanos() as u32, in current_time()
/xiu/library/streamhub/src/statistics/
H A Dmod.rs14 width: u32,
15 height: u32,
25 samplerate: u32,
/xiu/protocol/rtmp/src/cache/
H A Dmod.rs27 metadata_timestamp: u32,
29 video_timestamp: u32,
31 audio_timestamp: u32,
64 pub fn save_metadata(&mut self, chunk_body: &BytesMut, timestamp: u32) { in save_metadata() argument
84 timestamp: u32, in save_audio_data() argument
140 timestamp: u32, in save_video_data() argument
/xiu/protocol/rtmp/src/session/
H A Ddefine.rs3 pub const WINDOW_ACKNOWLEDGEMENT_SIZE: u32 = 4096;
4 pub const PEER_BANDWIDTH: u32 = 4096;
H A Dcommon.rs110 pub async fn send_audio(&mut self, data: BytesMut, timestamp: u32) -> Result<(), SessionError> { in send_audio()
115 data.len() as u32, in send_audio()
133 data.len() as u32, in send_video()
149 timestamp: u32, in send_metadata() argument
155 data.len() as u32, in send_metadata()
171 timestamp: &u32, in on_video_data() argument
198 timestamp: &u32, in on_audio_data() argument
225 timestamp: &u32, in on_meta_data() argument
456 timestamp: u32, in save_video_data() argument
467 timestamp: u32, in save_audio_data() argument
[all …]
/xiu/protocol/rtmp/src/remuxer/
H A Drtsp2rtmp.rs45 video_clock_rate: u32,
46 audio_clock_rate: u32,
47 base_video_timestamp: u32,
48 base_audio_timestamp: u32,
226 timestamp: u32, in on_rtsp_audio() argument
261 timestamp: u32, in on_rtsp_video() argument
287 let mut width: u32 = 0; in on_rtsp_video()
288 let mut height: u32 = 0; in on_rtsp_video()
342 fn gen_rtmp_meta_data(&self, width: u32, height: u32) -> Result<BytesMut, RtmpRemuxerError> { in gen_rtmp_meta_data() argument
/xiu/library/streamhub/src/
H A Ddefine.rs115 pub audio_clock_rate: u32,
116 pub video_clock_rate: u32,
122 Video { timestamp: u32, data: BytesMut },
123 Audio { timestamp: u32, data: BytesMut },
124 MetaData { timestamp: u32, data: BytesMut },
131 Video { timestamp: u32, data: BytesMut },
132 Audio { timestamp: u32, data: BytesMut },
/xiu/protocol/rtsp/src/rtp/
H A Drtp_header.rs20 pub timestamp: u32,
21 pub ssrc: u32,
22 pub csrcs: Vec<u32>,
/xiu/library/bytesio/src/
H A Dbytes_writer.rs76 pub fn write_u24<T: ByteOrder>(&mut self, bytes: u32) -> Result<(), BytesWriteError> { in write_u24()
82 pub fn write_u32<T: ByteOrder>(&mut self, bytes: u32) -> Result<(), BytesWriteError> { in write_u32()
114 pub fn write_random_bytes(&mut self, length: u32) -> Result<(), BytesWriteError> { in write_random_bytes()
175 pub fn write_u24<T: ByteOrder>(&mut self, bytes: u32) -> Result<(), BytesWriteError> { in write_u24()
179 pub fn write_u32<T: ByteOrder>(&mut self, bytes: u32) -> Result<(), BytesWriteError> { in write_u32()
191 pub fn write_random_bytes(&mut self, length: u32) -> Result<(), BytesWriteError> { in write_random_bytes()

123