Searched refs:msg_type_id (Results 1 – 10 of 10) sorted by relevance
| /xiu/protocol/rtmp/src/messages/ |
| H A D | parser.rs | 3 define::{msg_type_id, RtmpMessageData},
28 msg_type_id::COMMAND_AMF0 | msg_type_id::COMMAND_AMF3 => { in parse()
29 if self.chunk_info.message_header.msg_type_id == msg_type_id::COMMAND_AMF3 { in parse()
61 msg_type_id::AUDIO => { in parse()
71 msg_type_id::VIDEO => { in parse()
88 msg_type_id::SET_CHUNK_SIZE => { in parse()
92 msg_type_id::ABORT => { in parse()
97 msg_type_id::ACKNOWLEDGEMENT => { in parse()
112 msg_type_id::DATA_AMF0 | msg_type_id::DATA_AMF3 => { in parse()
119 msg_type_id::SHARED_OBJ_AMF3 | msg_type_id::SHARED_OBJ_AMF0 => {} in parse()
[all …]
|
| H A D | define.rs | 63 pub mod msg_type_id { module
|
| /xiu/protocol/rtmp/src/protocol_control_messages/ |
| H A D | writer.rs | 2 super::errors::ControlMessagesError, crate::messages::define::msg_type_id,
17 msg_type_id: u8, in write_control_message_header()
28 self.writer.write_u8(msg_type_id)?; //msg type id in write_control_message_header()
37 self.write_control_message_header(msg_type_id::SET_CHUNK_SIZE, 4)?; in write_set_chunk_size()
49 self.write_control_message_header(msg_type_id::ABORT, 4)?; in write_abort_message()
60 self.write_control_message_header(msg_type_id::ACKNOWLEDGEMENT, 4)?; in write_acknowledgement()
71 self.write_control_message_header(msg_type_id::WIN_ACKNOWLEDGEMENT_SIZE, 4)?; in write_window_acknowledgement_size()
83 self.write_control_message_header(msg_type_id::SET_PEER_BANDWIDTH, 5)?; in write_set_peer_bandwidth()
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | mod.rs | 44 pub msg_type_id: u8, field
59 pub fn new(timestamp: u32, msg_length: u32, msg_type_id: u8, msg_stream_id: u32) -> Self { in new()
63 msg_type_id, in new()
135 msg_type_id: u8, in new()
144 msg_type_id, in new()
|
| H A D | unpacketizer.rs | 7 crate::messages::define::msg_type_id,
148 let msg_type_id = chunk_info.message_header.msg_type_id; in read_chunks() localVariable
152 if msg_type_id == msg_type_id::SET_CHUNK_SIZE { in read_chunks()
375 self.current_chunk_info.message_header.msg_type_id, in print_current_message_header()
428 self.current_message_header().msg_type_id = self.reader.read_u8()?; in read_message_header()
432 self.current_message_header().msg_type_id in read_message_header()
480 self.current_message_header().msg_type_id = self.reader.read_u8()?; in read_message_header()
484 self.current_message_header().msg_type_id in read_message_header()
513 self.current_message_header().msg_type_id in read_message_header()
|
| H A D | packetizer.rs | 61 if cur_msg_header.msg_type_id == pre_msg_header.msg_type_id in zip_chunk_header()
142 self.writer.write_u8(message_header.msg_type_id)?; in write_message_header()
151 self.writer.write_u8(message_header.msg_type_id)?; in write_message_header()
|
| /xiu/protocol/rtmp/src/user_control_messages/ |
| H A D | writer.rs | 3 crate::messages::define::msg_type_id,
27 self.writer.write_u8(msg_type_id::USER_CONTROL_EVENT)?; //msg type id in write_control_message_header()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 17 messages::define::msg_type_id,
116 msg_type_id::AUDIO, in send_audio()
134 msg_type_id::VIDEO, in send_video()
156 msg_type_id::DATA_AMF0, in send_metadata()
|
| /xiu/protocol/rtmp/src/netstream/ |
| H A D | writer.rs | 34 messages_define::msg_type_id::COMMAND_AMF0, in write_chunk()
|
| /xiu/protocol/rtmp/src/netconnection/ |
| H A D | writer.rs | 84 messages_define::msg_type_id::COMMAND_AMF0, in write_chunk()
|