| /xiu/protocol/hls/src/ |
| H A D | m3u8.rs | 9 pub duration: i64, field
19 duration: i64, in new()
26 duration, in new()
41 duration: i64, field
60 duration: i64, in new()
79 duration, in new()
99 duration: i64, in add_segment()
114 self.duration = std::cmp::max(duration, self.duration); in add_segment()
116 let segment = Segment::new(duration, discontinuity, ts_name, ts_path, is_eof); in add_segment()
171 segment.duration as f64 / 1000.0, in refresh_playlist()
[all …]
|
| H A D | flv2hls.rs | 26 duration: i64, field
36 pub fn new(duration: i64, app_name: String, stream_name: String, need_record: bool) -> Self { in new()
57 duration, in new()
63 m3u8_handler: M3u8::new(duration, 6, app_name, stream_name, need_record), in new()
126 if dts - self.last_ts_dts >= self.duration * 1000 { in process_demux_data()
|
| H A D | flv_data_receiver.rs | 38 duration: i64, in new()
49 media_processor: Flv2HlsRemuxer::new(duration, app_name, stream_name, need_record), in new()
|
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | utils.rs | 4 let duration = SystemTime::now().duration_since(SystemTime::UNIX_EPOCH); in current_time() localVariable
6 match duration { in current_time()
|
| /xiu/library/bytesio/src/ |
| H A D | bytesio.rs | 26 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError>; in read_timeout()
73 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError> { in read_timeout()
74 match tokio::time::timeout(duration, self.read()).await { in read_timeout()
118 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError> { in read_timeout()
119 match tokio::time::timeout(duration, self.read()).await { in read_timeout()
|
| H A D | bytes_writer.rs | 209 pub async fn flush_timeout(&mut self, duration: Duration) -> Result<(), BytesWriteError> { in flush_timeout()
211 duration, in flush_timeout()
|
| /xiu/library/streamhub/src/ |
| H A D | utils.rs | 55 let duration = SystemTime::now().duration_since(SystemTime::UNIX_EPOCH); in new() localVariable
56 let seconds = match duration { in new()
|
| /xiu/protocol/rtsp/src/rtp/ |
| H A D | utils.rs | 112 let duration = SystemTime::now().duration_since(SystemTime::UNIX_EPOCH); in current_time() localVariable
114 match duration { in current_time()
|
| /xiu/library/logger/src/ |
| H A D | logger.rs | 125 let duration = Duration::from_millis(500); in gen_log_file_thread_run() localVariable
128 if r.recv_timeout(duration).is_ok() { in gen_log_file_thread_run()
|
| /xiu/protocol/rtmp/src/netstream/ |
| H A D | writer.rs | 47 duration: &f64, in write_play()
55 self.amf0_writer.write_number(duration)?; in write_play()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | server_session.rs | 545 let mut duration: Option<f64> = None; in on_play() localVariable
571 duration = match other_values.remove(0) { in on_play()
597 duration.is_some(), in on_play()
|
| H A D | client_session.rs | 416 duration: &f64, in send_play()
421 .write_play(transaction_id, stream_name, start, duration, reset) in send_play()
|