Home
last modified time | relevance | path

Searched refs:u16 (Results 1 – 25 of 32) sorted by relevance

12

/xiu/protocol/rtmp/src/user_control_messages/
H A Ddefine.rs2 pub const RTMP_EVENT_STREAM_BEGIN: u16 = 0;
3 pub const RTMP_EVENT_STREAM_EOF: u16 = 1;
4 pub const RTMP_EVENT_STREAM_DRY: u16 = 2;
5 pub const RTMP_EVENT_SET_BUFFER_LENGTH: u16 = 3;
6 pub const RTMP_EVENT_STREAM_IS_RECORDED: u16 = 4;
8 pub const RTMP_EVENT_PING: u16 = 6;
9 pub const RTMP_EVENT_PONG: u16 = 7;
/xiu/library/container/mpegts/src/
H A Ddefine.rs2 pub const PAT_TID_PAS: u16 = 0x00;
3 pub const PAT_TID_CAS: u16 = 0x01; // conditional_access_section(CA_section)
4 pub const PAT_TID_PMS: u16 = 0x02; // TS_program_map_section
38 pub const MPEG_FLAG_IDR_FRAME: u16 = 0x0001;
39 pub const MPEG_FLAG_H264_H265_WITH_AUD: u16 = 0x8000;
H A Dpmt.rs14 pub pid: u16,
15 pub program_number: u16,
18 pub pcr_pid: u16, //13 bits
76 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()
H A Dts.rs19 pid: u16,
67 pid: u16, in write() argument
70 flags: u16, in write() argument
137 pid: u16, in write_ts_header_for_pat_pmt() argument
322 pub fn find_stream(&mut self, pid: u16) -> Result<(), MpegTsError> { in find_stream()
356 pub fn add_stream(&mut self, codecid: u8, extra_data: BytesMut) -> Result<u16, MpegTsError> { in add_stream() argument
369 ) -> Result<u16, MpegTsError> { in pmt_add_stream() argument
404 pub fn add_program(&mut self, program_number: u16, info: BytesMut) -> Result<(), MpegTsError> { in add_program() argument
H A Dpat.rs10 transport_stream_id: u16,
57 let length = pat.pmt.len() as u16 * 4 + 5 + 4; in write()
H A Dpes.rs10 pub program_number: u16,
11 pub pid: u16,
/xiu/protocol/rtsp/src/
H A Drtsp_transport.rs25 pub client_port: Option<[u16; 2]>,
26 pub server_port: Option<[u16; 2]>,
54 let ports = scanf!(kv[1], '-', u16, u16); in unmarshal()
56 let mut client_ports: [u16; 2] = [0, 0]; in unmarshal()
67 let ports = scanf!(kv[1], '-', u16, u16); in unmarshal()
69 let mut server_ports: [u16; 2] = [0, 0]; in unmarshal()
H A Drtsp_channel.rs47 init_sequence: u16,
206 bytes_writer.write_u16::<BigEndian>(msg.len() as u16)?; in send_rr()
/xiu/protocol/rtsp/src/rtp/rtcp/
H A Drtcp_context.rs17 pub fn distance(new: u16, old: u16) -> u16 { in distance() argument
35 max_seq: u16, /* highest seq. number seen */
48 fn update_sequence(&mut self, seq: u16) -> usize { in update_sequence()
66 } else if delta < MAX_DROPOUT as u16 { in update_sequence()
76 if seq == self.bad_seq as u16 { in update_sequence()
95 fn init_seq(&mut self, seq: u16) { in init_seq() argument
128 pub fn new(ssrc: u32, seq: u16, sample_rate: u32) -> Self { in new() argument
H A Drtcp_header.rs20 pub length: u16, // 16 bits
/xiu/protocol/rtsp/src/sdp/
H A Dfmtp.rs9 pub payload_type: u16,
17 pub payload_type: u16,
24 pub payload_type: u16,
28 size_length: u16,
29 index_length: u16,
30 index_delta_length: u16,
81 if let Ok(payload_type) = eles[0].parse::<u16>() { in unmarshal()
144 if let Ok(payload_type) = eles[0].parse::<u16>() { in unmarshal()
202 if let Ok(payload_type) = eles[0].parse::<u16>() { in unmarshal()
225 if let Ok(size_length) = kv[1].parse::<u16>() { in unmarshal()
[all …]
H A Drtpmap.rs5 pub payload_type: u16,
21 if let Ok(payload_type) = part_0.parse::<u16>() { in unmarshal()
H A Dmod.rs13 bandwidth: u16,
27 if let Ok(bandwidth) = bandwidth.parse::<u16>() { in unmarshal()
89 version: u16,
219 if let Ok(version) = kv[1].parse::<u16>() { in unmarshal()
/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()
101 self.writer.write_u16::<BigEndian>(key.len() as u16)?; in write_eacm_array()
/xiu/protocol/hls/src/
H A Dflv2hls.rs29 video_pid: u16,
30 audio_pid: u16,
111 let pid: u16; in process_demux_data()
114 let mut flags: u16 = 0; in process_demux_data()
/xiu/library/container/flv/src/
H A Dmpeg4_hevc.rs13 min_spatial_segmentation_idc: u16,
18 avg_frame_rate: u16,
/xiu/protocol/rtsp/src/rtp/
H A Drtp_h265.rs36 init_seq: u16, in new() argument
73 let payload_hdr: u16 = ((nalu_header_1st_byte as u16 & 0x81) | ((define::FU as u16) << 1)) in pack_fu()
75 | nalu_header_2nd_byte as u16; in pack_fu()
173 sequence_number: u16,
H A Drtp_aac.rs36 init_seq: u16, in new() argument
133 let au_length = (((reader_payload.read_u8()? as u16) << 8) in unpack()
134 | ((reader_payload.read_u8()? as u16) & 0xF8)) as usize; in unpack()
H A Dmod.rs24 pub header_extension_profile: u16,
25 pub header_extension_length: u16,
H A Drtp_header.rs19 pub seq_number: u16,
/xiu/library/bytesio/src/
H A Dbytesio.rs35 pub async fn new(remote_domain: String, remote_port: u16, local_port: u16) -> Option<Self> { in new() argument
52 pub fn get_local_port(&self) -> Option<u16> { in get_local_port() argument
H A Dbytes_writer.rs71 pub fn write_u16<T: ByteOrder>(&mut self, bytes: u16) -> Result<(), BytesWriteError> { in write_u16()
171 pub fn write_u16<T: ByteOrder>(&mut self, bytes: u16) -> Result<(), BytesWriteError> { in write_u16()
/xiu/protocol/rtsp/src/http/
H A Dmod.rs12 pub port: u16,
47 rtsp_utils::scanf!(address_with_port, ':', String, u16); in unmarshal()
108 pub status_code: u16,
128 if let Ok(status) = status.parse::<u16>() { in unmarshal()
/xiu/protocol/webrtc/src/http/
H A Dmod.rs25 pub port: u16,
97 let (address_val, port_val) = scanf!(value, ':', String, u16); in unmarshal()
156 pub status_code: u16,
176 if let Ok(status) = status.parse::<u16>() { in unmarshal()
/xiu/application/xiu/src/
H A Dapi.rs118 axum::Server::bind(&([0, 0, 0, 0], port as u16).into()) in run()

12