Home
last modified time | relevance | path

Searched refs:message_header (Results 1 – 6 of 6) sorted by relevance

/xiu/protocol/rtmp/src/chunk/
H A Dpacketizer.rs46 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()
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()
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()
127 (None, message_header.timestamp_delta) in write_message_header()
[all …]
H A Dmod.rs73 pub message_header: ChunkMessageHeader, field
86 message_header: ChunkMessageHeader::new(0, 0, 0, 0), in new()
100 pub message_header: ChunkMessageHeader, field
118 self.basic_header, self.message_header, formatted_payload in fmt()
141 message_header: ChunkMessageHeader::new( in new()
H A Dunpacketizer.rs148 let msg_type_id = chunk_info.message_header.msg_type_id; in read_chunks()
322 self.current_chunk_info.message_header = header.clone(); 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()
564 self.current_chunk_info.message_header, in read_extended_timestamp()
623 .insert(csid, self.current_chunk_info.message_header.clone()); in read_message_payload()
[all …]
/xiu/protocol/rtmp/src/messages/
H A Dparser.rs27 match self.chunk_info.message_header.msg_type_id { in parse()
29 if self.chunk_info.message_header.msg_type_id == msg_type_id::COMMAND_AMF3 { in parse()
64 self.chunk_info.message_header.msg_length in parse()
74 self.chunk_info.message_header.msg_length in parse()
83 self.chunk_info.message_header.msg_length in parse()
127 self.chunk_info.message_header.msg_type_id in parse()
177 let _ = chunk_info.message_header.msg_streamd_id; in test_message_parse()
178 let _ = chunk_info.message_header.timestamp; in test_message_parse()
/xiu/protocol/rtmp/src/session/
H A Dserver_session.rs187 let timestamp = chunk_info.message_header.timestamp; in read_parse_chunks()
188 let msg_stream_id = chunk_info.message_header.msg_streamd_id; in read_parse_chunks()
H A Dclient_session.rs195 let timestamp = chunk_info.message_header.timestamp; in run()