| /xiu/protocol/rtmp/src/user_control_messages/ |
| H A D | writer.rs | 9 writer: AsyncBytesWriter, field
15 Self { writer } in new()
35 self.writer in write_stream_begin()
39 self.writer.flush().await?; in write_stream_begin()
45 self.writer in write_stream_eof()
49 self.writer.flush().await?; in write_stream_eof()
56 self.writer in write_stream_dry()
71 self.writer in write_set_buffer_length()
86 self.writer in write_stream_is_record()
97 self.writer in write_ping_request()
[all …]
|
| H A D | mod.rs | 1 pub mod writer; module
|
| /xiu/protocol/rtmp/src/protocol_control_messages/ |
| H A D | writer.rs | 7 writer: AsyncBytesWriter, field
12 pub fn new(writer: AsyncBytesWriter) -> Self { in new()
13 Self { writer } in new()
28 self.writer.write_u8(msg_type_id)?; //msg type id in write_control_message_header()
38 self.writer in write_set_chunk_size()
41 self.writer.flush().await?; in write_set_chunk_size()
52 self.writer.flush().await?; in write_abort_message()
63 self.writer.flush().await?; in write_acknowledgement()
74 self.writer.flush().await?; in write_window_acknowledgement_size()
85 self.writer.write_u8(limit_type)?; in write_set_peer_bandwidth()
[all …]
|
| H A D | mod.rs | 1 pub mod writer; module
|
| /xiu/protocol/rtmp/src/amf0/ |
| H A D | amf0_writer.rs | 11 writer: BytesWriter, field
17 writer: BytesWriter::new(), in new()
47 self.writer.write_u8(*value as u8)?; in write_bool()
60 self.writer.write(value.as_bytes())?; in write_string()
71 self.writer in write_object_eof()
84 self.writer.write(key.as_bytes())?; in write_object()
97 self.writer in write_eacm_array()
102 self.writer.write(key.as_bytes())?; in write_eacm_array()
115 self.writer.extract_current_bytes() in extract_current_bytes()
119 self.writer.get_current_bytes() in get_current_bytes()
[all …]
|
| /xiu/library/container/flv/src/ |
| H A D | muxer.rs | 16 pub writer: BytesWriter, field
28 writer: BytesWriter::new(), in new()
33 self.writer.write(&FLV_HEADER)?; in write_flv_header()
44 self.writer.write_u8(tag_type)?; in write_flv_tag_header()
46 self.writer.write_u24::<BigEndian>(data_size)?; in write_flv_tag_header()
48 self.writer.write_u24::<BigEndian>(timestamp & 0xffffff)?; in write_flv_tag_header()
51 self.writer.write_u8(timestamp_ext)?; in write_flv_tag_header()
53 self.writer.write_u24::<BigEndian>(0)?; in write_flv_tag_header()
59 self.writer.write(&body[..])?; in write_flv_tag_body()
64 self.writer.write_u32::<BigEndian>(size)?; in write_previous_tag_size()
|
| H A D | flv_tag_header.rs | 106 let mut writer = BytesWriter::default(); in marshal() localVariable
110 writer.write_u8(byte_1st)?; in marshal()
113 writer.write_u8(self.aac_packet_type)?; in marshal()
116 Ok(writer.extract_current_bytes()) in marshal()
199 let mut writer = BytesWriter::default(); in marshal() localVariable
202 writer.write_u8(byte_1st)?; in marshal()
207 writer.write_u8(self.avc_packet_type)?; in marshal()
211 writer.write_u8((cts & 0xFF) as u8)?; in marshal()
216 Ok(writer.extract_current_bytes()) in marshal()
|
| /xiu/protocol/rtsp/src/rtp/rtcp/ |
| H A D | rtcp_rr.rs | 40 let mut writer = BytesWriter::default(); in marshal() localVariable
42 writer.write_u32::<BigEndian>(self.ssrc)?; in marshal()
43 writer.write_u8(self.fraction_lost)?; in marshal()
47 writer.write_u32::<BigEndian>(self.lsr)?; in marshal()
48 writer.write_u32::<BigEndian>(self.dlsr)?; in marshal()
50 Ok(writer.extract_current_bytes()) in marshal()
85 let mut writer = BytesWriter::default(); in marshal() localVariable
88 writer.write(&header_bytesmut[..])?; in marshal()
90 writer.write_u32::<BigEndian>(self.ssrc)?; in marshal()
93 writer.write(&data[..])?; in marshal()
[all …]
|
| H A D | rtcp_sr.rs | 84 let mut writer = BytesWriter::default(); in marshal() localVariable
87 writer.write(&header_bytesmut[..])?; in marshal()
89 writer.write_u32::<BigEndian>(self.ssrc)?; in marshal()
90 writer.write_u64::<BigEndian>(self.ntp)?; in marshal()
91 writer.write_u32::<BigEndian>(self.rtp_timestamp)?; in marshal()
92 writer.write_u32::<BigEndian>(self.sender_packet_count)?; in marshal()
93 writer.write_u32::<BigEndian>(self.sender_octet_count)?; in marshal()
97 writer.write(&data[..])?; in marshal()
100 Ok(writer.extract_current_bytes()) in marshal()
|
| H A D | rtcp_app.rs | 49 let mut writer = BytesWriter::default(); in marshal() localVariable
52 writer.write(&header_bytesmut[..])?; in marshal()
54 writer.write_u32::<BigEndian>(self.ssrc)?; in marshal()
55 writer.write(&self.name[..])?; in marshal()
56 writer.write(&self.app_data[..])?; in marshal()
58 Ok(writer.extract_current_bytes()) in marshal()
|
| H A D | rtcp_bye.rs | 55 let mut writer = BytesWriter::default(); in marshal() localVariable
58 writer.write(&header_bytesmut[..])?; in marshal()
61 writer.write_u32::<BigEndian>(*ssrc)?; in marshal()
64 writer.write_u8(self.length)?; in marshal()
65 writer.write(&self.reason[..])?; in marshal()
67 Ok(writer.extract_current_bytes()) in marshal()
|
| H A D | rtcp_header.rs | 43 let mut writer = BytesWriter::default(); in marshal() localVariable
47 writer.write_u8(byte_1st)?; in marshal()
48 writer.write_u8(self.payload_type)?; in marshal()
49 writer.write_u16::<BigEndian>(self.length)?; in marshal()
51 Ok(writer.extract_current_bytes()) in marshal()
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | packetizer.rs | 25 writer: AsyncBytesWriter, field
34 writer: AsyncBytesWriter::new(io), in new()
88 self.writer.write_u8(fmt << 6 | 1)?; in write_basic_header()
91 self.writer.write_u8(fmt << 6)?; in write_basic_header()
138 self.writer in write_message_header()
140 self.writer in write_message_header()
143 self.writer in write_message_header()
147 self.writer in write_message_header()
149 self.writer in write_message_header()
154 self.writer in write_message_header()
[all …]
|
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | handshake_server.rs | 18 pub writer: AsyncBytesWriter, field
27 pub writer: AsyncBytesWriter, field
38 writer: AsyncBytesWriter::new(io), in new()
64 self.writer.flush().await?; in handshake()
90 writer: AsyncBytesWriter::new(io), in new()
172 self.writer in write_s1()
179 self.writer.write(&data[..])?; in write_s2()
220 let mut writer = BytesWriter::new(); in write_s1() localVariable
234 self.writer.write(&content[..])?; in write_s1()
240 let mut writer = BytesWriter::new(); in write_s2() localVariable
[all …]
|
| H A D | handshake_client.rs | 19 writer: AsyncBytesWriter, field
28 writer: AsyncBytesWriter::new(io), in new()
38 self.writer.flush().await?; in flush()
78 self.writer.write_u8(define::RTMP_VERSION as u8)?; in write_c0()
82 self.writer.write_u32::<BigEndian>(utils::current_time())?; in write_c1()
83 self.writer.write_u32::<BigEndian>(0)?; in write_c1()
85 self.writer in write_c1()
90 self.writer.write(&self.s1_bytes[0..])?; in write_c2()
|
| /xiu/protocol/rtsp/src/rtp/ |
| H A D | rtp_header.rs | 67 let mut writer = BytesWriter::default(); in marshal() localVariable
73 writer.write_u8(byte_1st)?; in marshal()
76 writer.write_u8(byte_2nd)?; in marshal()
78 writer.write_u16::<BigEndian>(self.seq_number)?; in marshal()
79 writer.write_u32::<BigEndian>(self.timestamp)?; in marshal()
80 writer.write_u32::<BigEndian>(self.ssrc)?; in marshal()
83 writer.write_u32::<BigEndian>(*csrc)?; in marshal()
86 Ok(writer.extract_current_bytes()) in marshal()
|
| H A D | mod.rs | 73 let mut writer = BytesWriter::new(); in marshal() localVariable
76 writer.write(&header_bytesmut[..])?; in marshal()
79 writer.write_u16::<BigEndian>(self.header_extension_profile)?; in marshal()
80 writer.write_u16::<BigEndian>(self.header_extension_length)?; in marshal()
81 writer.write(&self.header_extension_payload[..])?; in marshal()
84 writer.write(&self.payload[..])?; in marshal()
86 writer.write(&self.padding[..])?; in marshal()
89 Ok(writer.extract_current_bytes()) in marshal()
|
| /xiu/library/bytesio/src/ |
| H A D | bits_writer.rs | 10 writer: BytesWriter, field
16 pub fn new(writer: BytesWriter) -> Self { in new()
18 writer, in new()
25 self.writer.write(&data[..])?; in write_bytes()
34 self.writer.write_u8(self.cur_byte)?; in write_bit()
49 self.writer.write_u8(b)?; in write_8bit()
55 self.writer.write_u8(self.cur_byte)?; in flush()
116 self.writer.get_current_bytes() in get_current_bytes()
120 self.writer.len() * 8 + self.cur_bit_num as usize in len()
|
| H A D | bytes_writer.rs | 110 pub fn append(&mut self, writer: &mut BytesWriter) { in append()
111 self.bytes.append(&mut writer.bytes); in append()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | rtsp2rtmp.rs | 245 let mut writer = BytesWriter::new(); in on_rtsp_audio() localVariable
246 writer.write(&tag_header_data)?; in on_rtsp_audio()
247 writer.write(audio_data)?; in on_rtsp_audio()
386 let mut writer = BytesWriter::new(); in gen_rtmp_video_seq_header() localVariable
387 writer.write(&tag_header_data)?; in gen_rtmp_video_seq_header()
388 writer.write(&mpegavc_data)?; in gen_rtmp_video_seq_header()
390 Ok(writer.extract_current_bytes()) in gen_rtmp_video_seq_header()
415 let mut writer = BytesWriter::new(); in gen_rtmp_video_frame_data() localVariable
416 writer.write(&tag_header_data)?; in gen_rtmp_video_frame_data()
417 writer.write(&mpegavc_data)?; in gen_rtmp_video_frame_data()
[all …]
|
| /xiu/protocol/rtmp/src/netstream/ |
| H A D | mod.rs | 1 pub mod writer; module
|
| /xiu/protocol/rtmp/src/netconnection/ |
| H A D | mod.rs | 1 pub mod writer; module
|
| /xiu/library/bytesio/ |
| H A D | README.md | 6 Add bits reader and writer.
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 41 writer: AsyncBytesWriter, field
59 writer: AsyncBytesWriter::new(io), in new()
503 self.writer.write(response.marshal().as_bytes())?; in send_response()
504 self.writer.flush().await?; in send_response()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | client_session.rs | 19 netconnection::writer::{ConnectProperties, NetConnection},
20 netstream::writer::NetStreamWriter,
21 protocol_control_messages::writer::ProtocolControlMessagesWriter,
22 user_control_messages::writer::EventMessagesWriter,
|