Searched refs:csid (Results 1 – 3 of 3) sorted by relevance
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | unpacketizer.rs | 284 let mut csid = (byte & 0b00111111) as u32; in read_basic_header() localVariable
286 match csid { in read_basic_header()
291 csid = 64; in read_basic_header()
292 csid += self.reader.read_u8()? as u32; in read_basic_header()
298 csid = 64; in read_basic_header()
299 csid += self.reader.read_u8()? as u32; in read_basic_header()
300 csid += self.reader.read_u8()? as u32 * 256; in read_basic_header()
313 csid, in read_basic_header()
320 match self.chunk_message_headers.get_mut(&csid) { in read_basic_header()
331 csid, in read_basic_header()
[all …]
|
| H A D | mod.rs | 19 pub fn new(fmt: u8, csid: u32) -> ChunkBasicHeader { in new()
22 chunk_stream_id: csid, in new()
131 csid: u32, in new()
140 basic_header: ChunkBasicHeader::new(format, csid), in new()
|
| H A D | packetizer.rs | 86 fn write_basic_header(&mut self, fmt: u8, csid: u32) -> Result<(), PackError> { in write_basic_header()
87 if csid >= 64 + 255 { in write_basic_header()
89 self.writer.write_u16::<BigEndian>((csid - 64) as u16)?; in write_basic_header()
90 } else if csid >= 64 { in write_basic_header()
92 self.writer.write_u8((csid - 64) as u8)?; in write_basic_header()
94 self.writer.write_u8(fmt << 6 | csid as u8)?; in write_basic_header()
|