Lines Matching refs:current_chunk_info
80 pub current_chunk_info: ChunkInfo, field
100 current_chunk_info: ChunkInfo::default(), in new()
230 self.current_chunk_info.basic_header.chunk_stream_id, in print_current_basic_header()
231 self.current_chunk_info.basic_header.format in print_current_basic_header()
310 if csid != self.current_chunk_info.basic_header.chunk_stream_id { in read_basic_header()
314 self.current_chunk_info.basic_header.chunk_stream_id, in read_basic_header()
322 self.current_chunk_info.message_header = header.clone(); in read_basic_header()
353 self.current_chunk_info.basic_header.chunk_stream_id = csid; in read_basic_header()
354 self.current_chunk_info.basic_header.format = format_id; in read_basic_header()
365 &mut self.current_chunk_info.message_header in current_message_header()
372 self.current_chunk_info.message_header.timestamp, in print_current_message_header()
373 self.current_chunk_info.message_header.timestamp_delta, in print_current_message_header()
374 self.current_chunk_info.message_header.msg_length, in print_current_message_header()
375 self.current_chunk_info.message_header.msg_type_id, in print_current_message_header()
376 self.current_chunk_info.message_header.msg_streamd_id in print_current_message_header()
391 if self.current_chunk_info.basic_header.format != 3 { in read_message_header()
395 match self.current_chunk_info.basic_header.format { in read_message_header()
551 let cur_format_id = self.current_chunk_info.basic_header.format; in read_extended_timestamp()
554 || (cur_format_id == 3 && self.current_chunk_info.payload.is_empty()) in read_extended_timestamp()
563 self.current_chunk_info.basic_header, in read_extended_timestamp()
564 self.current_chunk_info.message_header, in read_extended_timestamp()
565 self.current_chunk_info.payload.len(), in read_extended_timestamp()
580 let remaining_bytes = whole_msg_length - self.current_chunk_info.payload.len(); in read_message_payload()
593 let remaining_mut = self.current_chunk_info.payload.remaining_mut(); in read_message_payload()
596 self.current_chunk_info.payload.reserve(additional); in read_message_payload()
606 self.current_chunk_info in read_message_payload()
612 self.current_chunk_info.payload.len() in read_message_payload()
615 if self.current_chunk_info.payload.len() == whole_msg_length { in read_message_payload()
618 let chunk_info = self.current_chunk_info.clone(); in read_message_payload()
619 self.current_chunk_info.payload.clear(); in read_message_payload()
621 let csid = self.current_chunk_info.basic_header.chunk_stream_id; in read_message_payload()
623 .insert(csid, self.current_chunk_info.message_header.clone()); in read_message_payload()