| /xiu/protocol/rtsp/src/rtp/rtcp/ |
| H A D | rtcp_bye.rs | 25 pub length: u8, field
46 rtcp_bye.length = reader.read_u8()?; in unmarshal()
47 rtcp_bye.reason = reader.read_bytes(rtcp_bye.length as usize)?; in unmarshal()
64 writer.write_u8(self.length)?; in marshal()
|
| H A D | rtcp_header.rs | 20 pub length: u16, // 16 bits field
35 rtcp_header.length = reader.read_u16::<BigEndian>()?; in unmarshal()
49 writer.write_u16::<BigEndian>(self.length)?; in marshal()
|
| H A D | rtcp_app.rs | 41 rtcp_app.app_data = reader.read_bytes(rtcp_app.header.length as usize * 4)?; in unmarshal()
|
| H A D | rtcp_context.rs | 207 length: (4 + 24) / 4, in generate_rr()
|
| /xiu/library/container/mpegts/src/ |
| H A D | pes.rs | 107 let mut length: u8 = 0x00; in write_pes_header() localVariable
110 length += 5; in write_pes_header()
115 length += 5; in write_pes_header()
122 self.bytes_writer.write_u8(length)?; //8 in write_pes_header()
|
| H A D | pat.rs | 57 let length = pat.pmt.len() as u16 * 4 + 5 + 4; in write() localVariable
58 self.bytes_writer.write_u16::<BigEndian>(0xb000 | length)?; in write()
|
| /xiu/library/streamhub/src/ |
| H A D | utils.rs | 38 let length = uuid.len(); in from_str2() localVariable
39 if !(10..=16).contains(&length) { in from_str2()
43 let random_count = u8_to_enum(length as u8 - 10); in from_str2()
|
| /xiu/library/container/flv/src/ |
| H A D | mpeg4_avc.rs | 276 length: usize, in write_nalu_size()
281 let num = ((length >> shift) & 0xFF) as u8; in write_nalu_size()
291 let length = nalu.len(); in nalus_to_mpeg4avc() localVariable
292 self.write_nalu_size(&mut bytes_writer, length)?; in nalus_to_mpeg4avc()
356 let length = 4; in test_bigend_to_bytes() localVariable
359 for i in 0..length { in test_bigend_to_bytes()
360 let shift = (length - i - 1) * 8; in test_bigend_to_bytes()
|
| /xiu/protocol/webrtc/src/clients/ |
| H A D | whep.js | 107 for (let i = 1; i < items.length; ++i) {
189 if ((!config.iceServer || !config.iceServer.length) && links.hasOwnProperty("ice-server")) {
214 if (config.iceServers.length)
261 … if (!(this.candidates.length || this.endOfcandidates || this.restartIce) || !this.resourceURL)
298 if (candidates.length || endOfcandidates)
|
| /xiu/library/bytesio/src/ |
| H A D | bytes_writer.rs | 114 pub fn write_random_bytes(&mut self, length: u32) -> Result<(), BytesWriteError> { in write_random_bytes()
116 for _ in 0..length { in write_random_bytes()
191 pub fn write_random_bytes(&mut self, length: u32) -> Result<(), BytesWriteError> { in write_random_bytes()
192 self.bytes_writer.write_random_bytes(length) in write_random_bytes()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | server_session.rs | 540 let length = other_values.len() as u8; in on_play() localVariable
549 if index >= length { in on_play()
558 if index >= length { in on_play()
567 if index >= length { in on_play()
576 if index >= length { in on_play()
669 let length = other_values.len(); in on_publish() localVariable
671 if length < 2 { in on_publish()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 77 length: u16, field
93 let length = reader.read_u16::<BigEndian>()?; in new() localVariable
94 log::debug!("length: {}", length); in new()
97 length, in new()
138 if self.reader.len() < a.length as usize { in run()
142 self.on_rtp_over_rtsp_message(a.channel_identifier, a.length as usize) in run()
156 length: usize, in on_rtp_over_rtsp_message()
158 let mut cur_reader = BytesReader::new(self.reader.read_bytes(length)?); in on_rtp_over_rtsp_message()
|
| /xiu/protocol/rtsp/src/rtp/ |
| H A D | rtp_h264.rs | 359 let length = payload_reader.read_u16::<BigEndian>()? as usize; in unpack_stap() localVariable
360 let nalu = payload_reader.read_bytes(length)?; in unpack_stap()
|