Home
last modified time | relevance | path

Searched refs:reader (Results 1 – 25 of 38) sorted by relevance

12

/xiu/protocol/rtmp/src/protocol_control_messages/
H A Dreader.rs8 pub reader: BytesReader, field
12 pub fn new(reader: BytesReader) -> Self { in new()
13 Self { reader } in new()
16 let chunk_size = self.reader.read_u32::<BigEndian>()?; in read_set_chunk_size()
21 let chunk_stream_id = self.reader.read_u32::<BigEndian>()?; in read_abort_message()
26 let sequence_number = self.reader.read_u32::<BigEndian>()?; in read_acknowledgement()
33 let window_acknowledgement_size = self.reader.read_u32::<BigEndian>()?; in read_window_acknowledgement_size()
40 let window_size = self.reader.read_u32::<BigEndian>()?; in read_set_peer_bandwidth()
41 let limit_type = self.reader.read_u8()?; in read_set_peer_bandwidth()
H A Dmod.rs3 pub mod reader; module
/xiu/protocol/rtsp/src/rtp/
H A Dmod.rs33 fn unmarshal(reader: &mut BytesReader) -> Result<Self, BytesReadError> in unmarshal()
38 header: RtpHeader::unmarshal(reader)?, in unmarshal()
51 rtp_packet.header_extension_profile = reader.read_u16::<BigEndian>()?; in unmarshal()
52 rtp_packet.header_extension_length = reader.read_u16::<BigEndian>()?; in unmarshal()
54 reader.read_bytes(4 * rtp_packet.header_extension_length as usize)?; in unmarshal()
58 let padding_length = reader.get(reader.len() - 1)? as usize; in unmarshal()
61 .put(reader.read_bytes(reader.len() - padding_length)?); in unmarshal()
62 rtp_packet.padding.put(reader.read_bytes(padding_length)?); in unmarshal()
64 rtp_packet.payload.put(reader.extract_remaining_bytes()); in unmarshal()
H A Drtp_header.rs26 fn unmarshal(reader: &mut BytesReader) -> Result<Self, BytesReadError> in unmarshal()
32 let byte_1st: u8 = reader.read_u8()?; in unmarshal()
38 let byte_2nd = reader.read_u8()?; in unmarshal()
41 rtp_header.seq_number = reader.read_u16::<BigEndian>()?; in unmarshal()
42 rtp_header.timestamp = reader.read_u32::<BigEndian>()?; in unmarshal()
43 rtp_header.ssrc = reader.read_u32::<BigEndian>()?; in unmarshal()
46 rtp_header.csrcs.push(reader.read_u32::<BigEndian>()?); in unmarshal()
/xiu/protocol/rtmp/src/user_control_messages/
H A Dreader.rs9 pub reader: BytesReader, field
13 pub fn new(reader: BytesReader) -> Self { in new()
14 Self { reader } in new()
20 let event_type = self.reader.read_u16::<BigEndian>()?; in parse_event()
44 let stream_id = self.reader.read_u32::<BigEndian>()?; in read_set_buffer_length()
45 let ms = self.reader.read_u32::<BigEndian>()?; in read_set_buffer_length()
56 let stream_id = self.reader.read_u32::<BigEndian>()?; in read_stream_begin()
66 let stream_id = self.reader.read_u32::<BigEndian>()?; in read_stream_is_recorded()
H A Dmod.rs2 pub mod reader; module
/xiu/protocol/rtsp/src/rtp/rtcp/
H A Drtcp_rr.rs22 fn unmarshal(reader: &mut BytesReader) -> Result<Self, RtcpError> in unmarshal()
27 ssrc: reader.read_u32::<BigEndian>()?, in unmarshal()
28 fraction_lost: reader.read_u8()?, in unmarshal()
30 extended_highest_seq_number: reader.read_u32::<BigEndian>()?, in unmarshal()
31 jitter: reader.read_u32::<BigEndian>()?, in unmarshal()
32 lsr: reader.read_u32::<BigEndian>()?, in unmarshal()
33 dlsr: reader.read_u32::<BigEndian>()?, in unmarshal()
66 let mut reader = BytesReader::new(data); in unmarshal() localVariable
69 header: RtcpHeader::unmarshal(&mut reader)?, in unmarshal()
70 ssrc: reader.read_u32::<BigEndian>()?, in unmarshal()
[all …]
H A Drtcp_sr.rs59 fn unmarshal(reader: &mut BytesReader) -> Result<Self, RtcpError> in unmarshal()
64 header: RtcpHeader::unmarshal(reader)?, in unmarshal()
65 ssrc: reader.read_u32::<BigEndian>()?, in unmarshal()
66 ntp: reader.read_u64::<BigEndian>()?, in unmarshal()
67 rtp_timestamp: reader.read_u32::<BigEndian>()?, in unmarshal()
68 sender_packet_count: reader.read_u32::<BigEndian>()?, in unmarshal()
69 sender_octet_count: reader.read_u32::<BigEndian>()?, in unmarshal()
74 let report_block = ReportBlock::unmarshal(reader)?; in unmarshal()
H A Drtcp_app.rs34 let mut reader = BytesReader::new(data); in unmarshal() localVariable
37 rtcp_app.header = RtcpHeader::unmarshal(&mut reader)?; in unmarshal()
39 rtcp_app.ssrc = reader.read_u32::<BigEndian>()?; in unmarshal()
40 rtcp_app.name = reader.read_bytes(4)?; in unmarshal()
41 rtcp_app.app_data = reader.read_bytes(rtcp_app.header.length as usize * 4)?; in unmarshal()
H A Drtcp_bye.rs34 let mut reader = BytesReader::new(data); in unmarshal() localVariable
37 header: RtcpHeader::unmarshal(&mut reader)?, in unmarshal()
42 let ssrc = reader.read_u32::<BigEndian>()?; in unmarshal()
46 rtcp_bye.length = reader.read_u8()?; in unmarshal()
47 rtcp_bye.reason = reader.read_bytes(rtcp_bye.length as usize)?; in unmarshal()
H A Drtcp_header.rs24 fn unmarshal(reader: &mut BytesReader) -> Result<Self, RtcpError> in unmarshal()
30 let byte_1st: u8 = reader.read_u8()?; in unmarshal()
34 rtcp_header.payload_type = reader.read_u8()?; in unmarshal()
35 rtcp_header.length = reader.read_u16::<BigEndian>()?; in unmarshal()
/xiu/protocol/rtmp/src/messages/
H A Dparser.rs9 protocol_control_messages::reader::ProtocolControlMessageReader,
10 user_control_messages::reader::EventMessagesReader,
25 let mut reader = BytesReader::new(self.chunk_info.payload); in parse() localVariable
30 reader.read_u8()?; in parse()
32 let mut amf_reader = Amf0Reader::new(reader); in parse()
68 data: reader.extract_remaining_bytes(), in parse()
77 data: reader.extract_remaining_bytes(), in parse()
85 let data = EventMessagesReader::new(reader).parse_event()?; in parse()
94 ProtocolControlMessageReader::new(reader).read_abort_message()?; in parse()
99 ProtocolControlMessageReader::new(reader).read_acknowledgement()?; in parse()
[all …]
/xiu/protocol/rtmp/src/handshake/
H A Ddigest.rs14 reader: BytesReader, field
21 reader: BytesReader::new(data), in new()
59 digest_offset += self.reader.get(772)? as usize; in find_digest_offset()
60 digest_offset += self.reader.get(773)? as usize; in find_digest_offset()
61 digest_offset += self.reader.get(774)? as usize; in find_digest_offset()
62 digest_offset += self.reader.get(775)? as usize; in find_digest_offset()
68 digest_offset += self.reader.get(8)? as usize; in find_digest_offset()
69 digest_offset += self.reader.get(9)? as usize; in find_digest_offset()
70 digest_offset += self.reader.get(10)? as usize; in find_digest_offset()
71 digest_offset += self.reader.get(11)? as usize; in find_digest_offset()
[all …]
H A Dhandshake_server.rs17 pub reader: BytesReader, field
26 pub reader: BytesReader, field
37 reader: BytesReader::new(BytesMut::new()), in new()
46 self.reader.extend_from_slice(data); in extend_data()
89 reader: BytesReader::new(BytesMut::new()), in new()
99 self.reader.extend_from_slice(data); in extend_data()
142 self.reader.read_u8()?; in read_c0()
150 let mut reader = BytesReader::new(c1_bytes); in read_c1() localVariable
151 self.c1_timestamp = reader.read_u32::<BigEndian>()?; in read_c1()
157 self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c2()
[all …]
H A Dhandshake_client.rs18 reader: BytesReader, field
27 reader: BytesReader::new(BytesMut::new()), in new()
35 self.reader.extend_from_slice(data); in extend_data()
95 self.reader.read_u8()?; in read_s0()
99 self.s1_bytes = self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_s1()
103 let _ = self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_s2()
/xiu/protocol/rtmp/src/chunk/
H A Dunpacketizer.rs68 pub reader: BytesReader, field
99 reader: BytesReader::new(BytesMut::new()), in new()
112 self.reader.extend_from_slice(data); in extend_data()
116 self.reader.len(), in extend_data()
117 self.reader in extend_data()
119 .split_to(self.reader.len()) in extend_data()
281 let byte = self.reader.read_u8()?; in read_basic_header()
288 if self.reader.is_empty() { in read_basic_header()
295 if self.reader.is_empty() { in read_basic_header()
383 self.reader.len(), in read_message_header()
[all …]
/xiu/protocol/rtsp/src/
H A Drtsp_track.rs64 let mut reader = BytesReader::new(BytesMut::new()); in rtp_receive_loop() localVariable
69 reader.extend_from_slice(&data[..]); in rtp_receive_loop()
70 if let Err(err) = rtp_channel_in.on_packet(&mut reader) { in rtp_receive_loop()
87 let mut reader = BytesReader::new(BytesMut::new()); in rtcp_receive_loop() localVariable
98 reader.extend_from_slice(&data[..]); in rtcp_receive_loop()
99 rtcp_channel_in.on_rtcp(&mut reader, rtcp_io.clone()).await; in rtcp_receive_loop()
117 pub async fn on_rtp(&mut self, reader: &mut BytesReader) -> Result<(), UnPackerError> { in on_rtp()
118 self.rtp_channel.lock().await.on_packet(reader) in on_rtp()
123 reader: &mut BytesReader, in on_rtcp()
126 self.rtcp_channel.lock().await.on_rtcp(reader, io).await; in on_rtcp()
/xiu/library/bytesio/src/
H A Dbytes_reader.rs255 reader.borrow_mut().extend_from_slice(&xs[..]); in test_rc_refcell()
257 let mut rv = reader.borrow_mut().read_u8().unwrap(); in test_rc_refcell()
260 rv = reader.borrow_mut().read_u8().unwrap(); in test_rc_refcell()
263 rv = reader.borrow_mut().read_u8().unwrap(); in test_rc_refcell()
268 pub reader: Rc<RefCell<BytesReader>>, field
273 Self { reader } in new()
289 let mut ref_struct = RefStruct::new(reader); in test_struct_rc_refcell()
294 let mut reader = ref_struct.reader.borrow_mut(); in test_struct_rc_refcell() localVariable
296 let mut rv = reader.read_u8().unwrap(); in test_struct_rc_refcell()
299 rv = reader.read_u8().unwrap(); in test_struct_rc_refcell()
[all …]
H A Dbits_reader.rs8 reader: BytesReader, field
14 pub fn new(reader: BytesReader) -> Self { in new()
16 reader, in new()
23 self.reader.extend_from_slice(&bytes[..]); in extend_data()
27 self.reader.len() * 8 + self.cur_bit_left as usize in len()
41 let byte = self.reader.read_u8()?; in read_byte()
47 self.cur_byte = self.reader.read_u8()?; in read_bit()
/xiu/protocol/rtmp/src/amf0/
H A Damf0_reader.rs10 reader: BytesReader, field
14 pub fn new(reader: BytesReader) -> Self { in new()
15 Self { reader } in new()
34 if self.reader.is_empty() { in read_any()
37 let markers = self.reader.read_u8()?; in read_any()
57 let marker = self.reader.advance_u8()?; in read_with_type()
75 let value = self.reader.read_u8()?; in read_bool()
84 let l = self.reader.read_u16::<BigEndian>()?; in read_raw_string()
104 self.reader.read_u24::<BigEndian>()?; in is_read_object_eof()
130 let len = self.reader.read_u32::<BigEndian>()?; in read_ecma_array()
[all …]
/xiu/library/container/flv/src/
H A Dflv_tag_header.rs84 fn unmarshal(reader: &mut BytesReader) -> Result<Self, FlvDemuxerError> in unmarshal()
90 let flags = reader.read_u8()?; in unmarshal()
97 tag_header.aac_packet_type = reader.read_u8()?; in unmarshal()
162 fn unmarshal(reader: &mut BytesReader) -> Result<Self, FlvDemuxerError> in unmarshal()
168 let flags = reader.read_u8()?; in unmarshal()
175 tag_header.avc_packet_type = reader.read_u8()?; in unmarshal()
180 let time = reader.read_u8()?; in unmarshal()
H A Ddemuxer.rs130 let mut reader = BytesReader::new(data); in demux() localVariable
132 let tag_header = VideoTagHeader::unmarshal(&mut reader)?; in demux()
137 .decoder_configuration_record_load(&mut reader)?; in demux()
142 let data = self.avc_processor.h264_mp4toannexb(&mut reader)?; in demux()
179 let mut reader = BytesReader::new(data); in demux() localVariable
181 let tag_header = AudioTagHeader::unmarshal(&mut reader)?; in demux()
183 .extend_data(reader.extract_remaining_bytes()); in demux()
/xiu/protocol/rtmp/src/cache/
H A Dmod.rs92 let mut reader = BytesReader::new(chunk_body.clone()); in save_audio_data() localVariable
93 let tag_header = AudioTagHeader::unmarshal(&mut reader)?; in save_audio_data()
103 .extend_data(reader.extract_remaining_bytes()) in save_audio_data()
147 let mut reader = BytesReader::new(chunk_body.clone()); in save_video_data() localVariable
148 let tag_header = VideoTagHeader::unmarshal(&mut reader)?; in save_video_data()
155 avc_processor.decoder_configuration_record_load(&mut reader)?; in save_video_data()
H A Dmetadata.rs44 let reader = BytesReader::new(body); in is_metadata() localVariable
45 let result = Amf0Reader::new(reader).read_all(); in is_metadata()
/xiu/protocol/rtmp/src/netconnection/
H A Dmod.rs3 pub mod reader; module

12