| /xiu/protocol/rtmp/src/utils/ |
| H A D | print.rs | 2 pub fn print(data: BytesMut) { in print()
3 println!("==========={}", data.len()); in print()
5 for i in data { in print()
16 pub fn print2(title: &str, data: BytesMut) { in print2()
17 println!("==========={}:{}", title, data.len()); in print2()
19 for i in data { in print2()
30 pub fn printu8(data: BytesMut) { in printu8()
31 println!("==========={}", data.len()); in printu8()
33 for i in data { in printu8()
44 pub fn print_array(data: &[u8], len: usize) { in print_array()
[all …]
|
| H A D | mod.rs | 69 let data: Vec<&str> = self.raw_domain_name.split(':').collect(); in parse_raw_domain_name() localVariable
70 self.domain_name = data[0].to_string(); in parse_raw_domain_name()
71 if data.len() > 1 { in parse_raw_domain_name()
72 self.port = data[1].to_string(); in parse_raw_domain_name()
78 let data: Vec<&str> = self.raw_stream_name.split('?').collect(); in parse_raw_stream_name() localVariable
79 self.stream_name = data[0].to_string(); in parse_raw_stream_name()
80 if data.len() > 1 { in parse_raw_stream_name()
81 self.parameters = data[1].to_string(); in parse_raw_stream_name()
|
| /xiu/protocol/hls/src/ |
| H A D | flv2hls.rs | 89 let data = self.ts_muxer.get_data(); in flush_remaining_data() localVariable
98 data, in flush_remaining_data()
118 FlvDemuxerData::Video { data } => { in process_demux_data()
119 pts = data.pts; in process_demux_data()
120 dts = data.dts; in process_demux_data()
122 payload.extend_from_slice(&data.data[..]); in process_demux_data()
131 FlvDemuxerData::Audio { data } => { in process_demux_data()
132 if !data.has_data { in process_demux_data()
136 pts = data.pts; in process_demux_data()
137 dts = data.dts; in process_demux_data()
[all …]
|
| H A D | test_flv2hls.rs | 15 pub fn print(data: BytesMut) { in print()
16 println!("==========={}", data.len()); in print()
18 for i in data { in print()
29 pub fn print_flv_data(data: FlvData) { in print_flv_data()
30 match data { in print_flv_data()
35 print(data); in print_flv_data()
42 print(data); in print_flv_data()
60 let mut data = BytesMut::new(); in test_flv2hls() localVariable
61 data.extend(contents); in test_flv2hls()
63 let mut demuxer = FlvDemuxer::new(data); in test_flv2hls()
[all …]
|
| H A D | define.rs | 6 Video { data: FlvDemuxerVideoData },
7 Audio { data: FlvDemuxerAudioData },
|
| H A D | flv_data_receiver.rs | 66 if let Some(data) = self.data_consumer.recv().await { in receive_flv_data()
67 let flv_data: FlvData = match data { in receive_flv_data()
68 FrameData::Audio { timestamp, data } => FlvData::Audio { timestamp, data }, in receive_flv_data()
69 FrameData::Video { timestamp, data } => FlvData::Video { timestamp, data }, in receive_flv_data()
|
| H A D | ts.rs | 22 pub fn write(&mut self, data: BytesMut) -> Result<(String, String), MediaError> { in write()
28 ts_file_handler.write_all(&data[..])?; in write()
|
| /xiu/library/container/flv/src/ |
| H A D | demuxer.rs | 79 pub data: BytesMut, field
89 data: BytesMut::new(), in new()
99 pub data: BytesMut, field
109 data: BytesMut::new(), in new()
128 data: BytesMut, in demux()
130 let mut reader = BytesReader::new(data); in demux()
149 data, in demux()
177 data: BytesMut, in demux()
217 pub fn new(data: BytesMut) -> Self { in new()
253 data: body, in read_flv_tag()
[all …]
|
| H A D | mpeg4_avc.rs | 17 pub data: BytesMut, field
24 data: BytesMut::new(), in new()
28 self.data.len() in len()
39 pub data: BytesMut, field
46 data: BytesMut::new(), in new()
50 self.data.len() in len()
83 pub fn print(data: BytesMut) { in print()
84 println!("==========={}", data.len()); in print()
86 for i in data { in print()
200 .write(&self.mpeg4_avc.sps[i].data[..])?; in decoder_configuration_record_load()
[all …]
|
| H A D | demuxer_tag.rs | 82 pub fn new(data: BytesMut) -> Self { in new()
84 bytes_reader: BytesReader::new(data), in new()
155 pub fn new(data: BytesMut) -> Self { in new()
157 bytes_reader: BytesReader::new(data), in new()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 82 match data { in send_channel_data()
118 data, in send_audio()
136 data, in send_video()
148 data: BytesMut, in send_metadata()
158 data, in send_metadata()
170 data: &mut BytesMut, in on_video_data()
175 data: data.clone(), in on_video_data()
197 data: &mut BytesMut, in on_audio_data()
202 data: data.clone(), in on_audio_data()
224 data: &mut BytesMut, in on_meta_data()
[all …]
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 79 if let Some(data) = self.data_consumer.recv().await { in send_media_stream()
80 if let Err(err) = self.write_flv_tag(data) { in send_media_stream()
104 FrameData::Audio { timestamp, data } => (data, timestamp, tag_type::AUDIO), in write_flv_tag()
105 FrameData::Video { timestamp, data } => (data, timestamp, tag_type::VIDEO), in write_flv_tag()
106 FrameData::MetaData { timestamp, data } => { in write_flv_tag()
108 metadata.save(&data); in write_flv_tag()
109 let data = metadata.remove_set_data_frame()?; in write_flv_tag() localVariable
111 (data, timestamp, tag_type::SCRIPT_DATA_AMF) in write_flv_tag()
133 let data = self.muxer.writer.extract_current_bytes(); in flush_response_data() localVariable
134 self.http_response_data_producer.start_send(Ok(data))?; in flush_response_data()
|
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | handshake_server.rs | 45 pub fn extend_data(&mut self, data: &[u8]) { in extend_data()
46 self.reader.extend_from_slice(data); in extend_data()
98 pub fn extend_data(&mut self, data: &[u8]) { in extend_data()
99 self.reader.extend_from_slice(data); in extend_data()
178 let data = self.c1_bytes.clone(); in write_s2() localVariable
179 self.writer.write(&data[..])?; in write_s2()
254 let mut data: BytesMut = BytesMut::new(); in write_s2() localVariable
260 let content = [data, digtest].concat(); in write_s2()
288 pub fn extend_data(&mut self, data: &[u8]) { in extend_data()
291 self.saved_data.extend_from_slice(data); in extend_data()
[all …]
|
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 65 data = receiver.recv() => { in receive_frame_data_loop()
66 if let Some(val) = data { in receive_frame_data_loop()
70 data: _, in receive_frame_data_loop()
75 data: data.clone(), in receive_frame_data_loop()
89 data: data.clone(), in receive_frame_data_loop()
119 data = receiver.recv() => { in receive_packet_data_loop()
120 if let Some(val) = data { in receive_packet_data_loop()
126 data: data.clone(), in receive_packet_data_loop()
140 data: data.clone(), in receive_packet_data_loop()
331 log::info!("event data: {}", data); in event_loop()
[all …]
|
| /xiu/protocol/rtmp/src/cache/ |
| H A D | gop.rs | 18 fn save_frame_data(&mut self, data: FrameData) { in save_frame_data()
19 self.datas.push(data); in save_frame_data()
55 pub fn save_frame_data(&mut self, data: FrameData, is_key_frame: bool) { in save_frame_data()
69 gop.save_frame_data(data); in save_frame_data()
|
| H A D | mod.rs | 70 let data = self.metadata.get_chunk_body(); in get_metadata() localVariable
71 if !data.is_empty() { in get_metadata()
74 data, in get_metadata()
88 data: chunk_body.clone(), in save_audio_data()
121 data: self.audio_seq.clone(), in get_audio_seq()
131 data: self.video_seq.clone(), in get_video_seq()
144 data: chunk_body.clone(), in save_video_data()
|
| /xiu/application/xiu/src/ |
| H A D | api.rs | 46 let mut data = Vec::new(); in get_stream_status() localVariable
54 data.push(stream_statistics); in get_stream_status()
56 if data.len() == size { in get_stream_status()
66 if let Ok(data) = serde_json::to_string(&data) { in get_stream_status()
67 return Ok(data); in get_stream_status()
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp_utils.rs | 11 pub fn print(title: &str, data: BytesMut) { in print()
12 println!("==========={}:{}", title, data.len()); in print()
14 for i in data { in print()
|
| H A D | rtsp_track.rs | 68 Ok(data) => { in rtp_receive_loop()
69 reader.extend_from_slice(&data[..]); in rtp_receive_loop()
91 let data = match rtcp_io.lock().await.read().await { in rtcp_receive_loop() localVariable
92 Ok(data) => data, in rtcp_receive_loop()
98 reader.extend_from_slice(&data[..]); in rtcp_receive_loop()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 132 self.reader.extend_from_slice(&data[..]); in run()
136 match data { in run()
178 let data = self.reader.extract_remaining_bytes(); in on_rtsp_message() localVariable
248 if let Some(sdp) = Sdp::unmarshal(&data) { in handle_describe()
488 mut data, in handle_play()
501 mut data, in handle_play()
748 Fmtp::H264(data) => { in send_prior_data()
763 Fmtp::H265(data) => { in send_prior_data()
781 Fmtp::Mpeg4(data) => { in send_prior_data()
784 data: data.asc.clone(), in send_prior_data()
[all …]
|
| /xiu/protocol/rtmp/src/messages/ |
| H A D | parser.rs | 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() localVariable
86 return Ok(Some(data)); in parse()
144 let data: [u8; 205] = [ in test_message_parse() localVariable
163 unpacker.extend_data(&data[..]); in test_message_parse()
|
| /xiu/library/bytesio/src/ |
| H A D | bytesio.rs | 75 Ok(data) => data, in read_timeout()
120 Ok(data) => data, in read_timeout()
131 Some(data) => match data { in read()
|
| /xiu/protocol/webrtc/src/ |
| H A D | whep.rs | 159 if let Some(data) = av_data { in handle_whep()
160 match data { in handle_whep()
161 PacketData::Video { timestamp: _, data } => { in handle_whep()
162 if let Err(err) = video_track.write(&data[..]).await { in handle_whep()
166 PacketData::Audio { timestamp: _, data } => { in handle_whep()
167 if let Err(err) = audio_track.write(&data[..]).await { in handle_whep()
|
| /xiu/protocol/rtsp/src/rtp/rtcp/ |
| H A D | rtcp_rr.rs | 62 fn unmarshal(data: BytesMut) -> Result<Self, RtcpError> in unmarshal()
66 let mut reader = BytesReader::new(data); in unmarshal()
92 let data = report_block.marshal()?; in marshal() localVariable
93 writer.write(&data[..])?; in marshal()
|
| /xiu/library/container/mpegts/src/ |
| H A D | crc32.rs | 59 let data: [u8; 12] = [ in test_gen_crc32() localVariable
64 payload.extend_from_slice(&data[..]); in test_gen_crc32()
|