Home
last modified time | relevance | path

Searched refs:write (Results 1 – 25 of 39) sorted by relevance

12

/xiu/library/streamhub/src/
H A Dstream.rs27 write!(f, "RTMP - app_name: {app_name}, stream_name: {stream_name}") in fmt()
32 write!(f, "RTSP - stream_name: {stream_name}") in fmt()
38 write!( in fmt()
44 write!(f, "Unkonwn") in fmt()
/xiu/protocol/rtsp/src/rtp/
H A Dmod.rs76 writer.write(&header_bytesmut[..])?; 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()
/xiu/protocol/rtsp/src/rtp/rtcp/
H A Drtcp_app.rs52 writer.write(&header_bytesmut[..])?; in marshal()
55 writer.write(&self.name[..])?; in marshal()
56 writer.write(&self.app_data[..])?; in marshal()
H A Drtcp_bye.rs58 writer.write(&header_bytesmut[..])?; in marshal()
65 writer.write(&self.reason[..])?; in marshal()
H A Drtcp_sr.rs87 writer.write(&header_bytesmut[..])?; in marshal()
97 writer.write(&data[..])?; in marshal()
H A Drtcp_rr.rs88 writer.write(&header_bytesmut[..])?; in marshal()
93 writer.write(&data[..])?; in marshal()
/xiu/library/container/flv/src/
H A Dmpeg4_avc.rs197 self.mpeg4_avc.sps_annexb_data.write(&H264_START_CODE)?; in decoder_configuration_record_load()
200 .write(&self.mpeg4_avc.sps[i].data[..])?; in decoder_configuration_record_load()
217 self.mpeg4_avc.pps_annexb_data.write(&H264_START_CODE)?; in decoder_configuration_record_load()
220 .write(&self.mpeg4_avc.pps[i].data[..])?; in decoder_configuration_record_load()
256 bytes_writer.write(&H264_START_CODE)?; in h264_mp4toannexb()
258 bytes_writer.write(&data[..])?; in h264_mp4toannexb()
293 bytes_writer.write(&nalu)?; in nalus_to_mpeg4avc()
312 bytes_writer.write(&self.mpeg4_avc.sps[i].data[..])?; in decoder_configuration_record_save()
319 bytes_writer.write(&self.mpeg4_avc.pps[i].data[..])? in decoder_configuration_record_save()
H A Dmuxer.rs33 self.writer.write(&FLV_HEADER)?; in write_flv_header()
59 self.writer.write(&body[..])?; in write_flv_tag_body()
/xiu/library/container/mpegts/src/
H A Dpmt.rs60 pub fn write(&mut self, pmt: &Pmt) -> Result<BytesMut, MpegTsError> { in write() method
80 tmp_bytes_writer.write(&pmt.program_info[..])?; in write()
102 .write(&tmp_bytes_writer.extract_current_bytes()[..])?; in write()
H A Dts.rs65 pub fn write( in write() method
108 let pat_data = pat::PatMuxer::new().write(self.pat.clone())?; in write()
119 let payload_data = pmt::PmtMuxer::new().write(pmt_data)?; in write()
155 self.bytes_writer.write(&payload)?; in write_ts_header_for_pat_pmt()
200 self.bytes_writer.write(&data[..])?; in write_pes()
266 ts_header.write(&pcr_result.extract_current_bytes()[..])?; in write_ts_header_for_pes()
H A Dpat.rs52 pub fn write(&mut self, pat: Pat) -> Result<BytesMut, MpegTsError> { in write() method
/xiu/library/logger/src/
H A Dtarget.rs20 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write() method
21 match self.cur_file_handler.lock().unwrap().write(buf) { in write()
/xiu/library/bytesio/src/
H A Dbytes_writer.rs97 pub fn write(&mut self, buf: &[u8]) -> Result<(), BytesWriteError> { in write() method
187 pub fn write(&mut self, buf: &[u8]) -> Result<(), BytesWriteError> { in write() method
188 self.bytes_writer.write(buf) in write()
203 .write(self.bytes_writer.bytes.clone().into()) in flush()
215 .write(self.bytes_writer.bytes.clone().into()), in flush_timeout()
258 let rv = v.write(&FLV_HEADER); in test_write_vec()
H A Dbytesio.rs24 async fn write(&mut self, bytes: Bytes) -> Result<(), BytesIOError>; in write() method
68 async fn write(&mut self, bytes: Bytes) -> Result<(), BytesIOError> { in write() method
112 async fn write(&mut self, bytes: Bytes) -> Result<(), BytesIOError> { in write() method
/xiu/protocol/rtmp/src/amf0/
H A Damf0_writer.rs60 self.writer.write(value.as_bytes())?; in write_string()
84 self.writer.write(key.as_bytes())?; in write_object()
102 self.writer.write(key.as_bytes())?; in write_eacm_array()
/xiu/protocol/rtsp/src/session/
H A Dmod.rs435 bytes_writer.write(&msg)?; in handle_play()
449 bytes_writer.write(&msg)?; in handle_play()
698 self.writer.write(response.marshal().as_bytes())?; in send_response()
749 bytes_writer.write(&ANNEXB_NALU_START_CODE)?; in send_prior_data()
750 bytes_writer.write(&data.sps)?; in send_prior_data()
751 bytes_writer.write(&ANNEXB_NALU_START_CODE)?; in send_prior_data()
752 bytes_writer.write(&data.pps)?; in send_prior_data()
764 bytes_writer.write(&ANNEXB_NALU_START_CODE)?; in send_prior_data()
765 bytes_writer.write(&data.sps)?; in send_prior_data()
767 bytes_writer.write(&data.pps)?; in send_prior_data()
[all …]
H A Ddefine.rs42 write!(f, "{client_type}") in fmt()
/xiu/protocol/rtmp/src/remuxer/
H A Drtsp2rtmp.rs246 writer.write(&tag_header_data)?; in on_rtsp_audio()
247 writer.write(audio_data)?; in on_rtsp_audio()
387 writer.write(&tag_header_data)?; in gen_rtmp_video_seq_header()
388 writer.write(&mpegavc_data)?; in gen_rtmp_video_seq_header()
416 writer.write(&tag_header_data)?; in gen_rtmp_video_frame_data()
417 writer.write(&mpegavc_data)?; in gen_rtmp_video_frame_data()
/xiu/protocol/rtmp/src/session/
H A Ddefine.rs40 write!(f, "{client_type}") in fmt()
/xiu/protocol/hls/src/
H A Dts.rs22 pub fn write(&mut self, data: BytesMut) -> Result<(String, String), MediaError> { in write() method
/xiu/protocol/rtmp/src/handshake/
H A Dhandshake_server.rs179 self.writer.write(&data[..])?; in write_s2()
223 writer.write(&define::RTMP_SERVER_VERSION)?; in write_s1()
234 self.writer.write(&content[..])?; in write_s1()
263 self.writer.write(&content[..])?; in write_s2()
H A Dhandshake_client.rs90 self.writer.write(&self.s1_bytes[0..])?; in write_c2()
/xiu/protocol/rtmp/src/chunk/
H A Dunpacketizer.rs41 write!(f, "ReadBasicHeader",) in fmt()
44 write!(f, "ReadMessageHeader",) in fmt()
47 write!(f, "ReadExtendedTimestamp",) in fmt()
50 write!(f, "ReadMessagePayload",) in fmt()
53 write!(f, "Finish",) in fmt()
/xiu/protocol/webrtc/src/
H A Dwhep.rs162 if let Err(err) = video_track.write(&data[..]).await { in handle_whep()
167 if let Err(err) = audio_track.write(&data[..]).await { in handle_whep()
/xiu/application/xiu/src/config/
H A Dconfig.toml67 # write log to file or not（Writing logs to file or console cannot be satisfied at the same time）.

12