Lines Matching refs:message_header

46             let cur_msg_header = &mut chunk_info.message_header;  in zip_chunk_header()
47 let pre_msg_header = &mut pre_header.message_header; in zip_chunk_header()
71 assert_eq!(chunk_info.message_header.timestamp_delta, 0); in zip_chunk_header()
79 message_header: chunk_info.message_header.clone(), in zip_chunk_header()
103 message_header: &mut ChunkMessageHeader, in write_message_header()
108 if message_header.timestamp >= 0xFFFFFF { in write_message_header()
109 message_header.extended_timestamp_type = ExtendTimestampType::FORMAT0; in write_message_header()
110 (Some(message_header.timestamp), 0xFFFFFF) in write_message_header()
112 (None, message_header.timestamp) in write_message_header()
116 if message_header.timestamp_delta >= 0xFFFFFF { in write_message_header()
122 message_header.timestamp_delta in write_message_header()
124 message_header.extended_timestamp_type = ExtendTimestampType::FORMAT12; in write_message_header()
125 (Some(message_header.timestamp_delta), 0xFFFFFF) in write_message_header()
127 (None, message_header.timestamp_delta) in write_message_header()
141 .write_u24::<BigEndian>(message_header.msg_length)?; in write_message_header()
142 self.writer.write_u8(message_header.msg_type_id)?; in write_message_header()
144 .write_u32::<LittleEndian>(message_header.msg_streamd_id)?; in write_message_header()
150 .write_u24::<BigEndian>(message_header.msg_length)?; in write_message_header()
151 self.writer.write_u8(message_header.msg_type_id)?; in write_message_header()
174 chunk_info.message_header.timestamp, in write_chunk()
184 self.write_message_header(&chunk_info.basic_header, &mut chunk_info.message_header)?; in write_chunk()