Searched refs:chunk_size (Results 1 – 8 of 8) sorted by relevance
16 let chunk_size = self.reader.read_u32::<BigEndian>()?; in read_set_chunk_size() localVariable17 Ok(chunk_size) in read_set_chunk_size()
35 chunk_size: u32, in write_set_chunk_size()39 .write_u32::<BigEndian>(chunk_size & 0x7FFFFFFF)?; //first bit must be 0 in write_set_chunk_size()
17 InvalidMaxChunkSize { chunk_size: usize },
89 let chunk_size = ProtocolControlMessageReader::new(reader).read_set_chunk_size()?; in parse() localVariable90 return Ok(Some(RtmpMessageData::SetChunkSize { chunk_size })); in parse()
29 chunk_size: u32,
263 RtmpMessageData::SetChunkSize { chunk_size } => { in process_messages()264 self.on_set_chunk_size(*chunk_size as usize)?; in process_messages()351 fn on_set_chunk_size(&mut self, chunk_size: usize) -> Result<(), SessionError> { in on_set_chunk_size()356 chunk_size in on_set_chunk_size()358 self.unpacketizer.update_max_chunk_size(chunk_size); in on_set_chunk_size()
254 RtmpMessageData::SetChunkSize { chunk_size } => { in process_messages()256 self.on_set_chunk_size(chunk_size)?; in process_messages()494 pub fn on_set_chunk_size(&mut self, chunk_size: &mut u32) -> Result<(), SessionError> { in on_set_chunk_size()496 .update_max_chunk_size(*chunk_size as usize); in on_set_chunk_size()
124 pub fn update_max_chunk_size(&mut self, chunk_size: usize) { in update_max_chunk_size()125 log::trace!("update max chunk size: {}", chunk_size); in update_max_chunk_size()126 self.max_chunk_size = chunk_size; in update_max_chunk_size()