| /xiu/protocol/rtmp/src/handshake/ |
| H A D | utils.rs | 1 use std::time::SystemTime;
|
| H A D | errors.rs | 4 std::{fmt, io::Error, time::SystemTimeError},
|
| /xiu/library/streamhub/src/statistics/ |
| H A D | avstatistics.rs | 5 std::{sync::Arc, time::Duration},
12 time,
88 let mut interval = time::interval(Duration::from_secs(1)); in start()
|
| /xiu/library/bytesio/src/ |
| H A D | bytesio.rs | 2 use std::time::Duration;
74 match tokio::time::timeout(duration, self.read()).await { in read_timeout()
119 match tokio::time::timeout(duration, self.read()).await { in read_timeout()
|
| H A D | bytesio_errors.rs | 15 TimeoutError(tokio::time::error::Elapsed),
|
| H A D | bytes_writer.rs | 10 std::{io::Write, sync::Arc, time::Duration},
11 tokio::{sync::Mutex, time::timeout},
|
| /xiu/library/container/flv/src/ |
| H A D | demuxer_tag.rs | 176 let time = self.bytes_reader.read_u8()?; in parse_tag_header() localVariable
179 self.tag.composition_time = (self.tag.composition_time << 8) + time as i32; in parse_tag_header()
|
| H A D | flv_tag_header.rs | 180 let time = reader.read_u8()?; in unmarshal() localVariable
183 tag_header.composition_time = (tag_header.composition_time << 8) + time as i32; in unmarshal()
|
| /xiu/confs/online/ |
| H A D | pprtmp.Cargo.toml | 20 #features = ["rt-core", "rt-threaded", "macros", "time","sync"]
|
| H A D | xiu.Cargo.toml | 44 #features = ["rt-core", "rt-threaded", "macros", "time","sync"]
|
| /xiu/application/pprtmp/ |
| H A D | Cargo.toml | 20 #features = ["rt-core", "rt-threaded", "macros", "time","sync"]
|
| /xiu/confs/local/ |
| H A D | pprtmp.Cargo.toml | 19 #features = ["rt-core", "rt-threaded", "macros", "time","sync"]
|
| H A D | xiu.Cargo.toml | 44 #features = ["rt-core", "rt-threaded", "macros", "time","sync"]
|
| /xiu/application/http-server/ |
| H A D | Cargo.toml | 23 #features = ["rt-core", "rt-threaded", "macros", "time","sync"]
|
| /xiu/application/pprtmp/src/ |
| H A D | main.rs | 12 tokio::time::Duration,
78 tokio::time::sleep(Duration::from_secs(2)).await; in main()
|
| /xiu/library/bytesio/ |
| H A D | Cargo.toml | 26 #features = ["rt-core", "rt-threaded", "macros", "time","sync"]
|
| /xiu/protocol/hls/src/ |
| H A D | flv_data_receiver.rs | 9 std::time::Duration,
18 tokio::{sync::mpsc, time::sleep},
|
| H A D | test_flv2hls.rs | 12 use std::time::Instant;
|
| /xiu/application/xiu/ |
| H A D | Cargo.toml | 44 #features = ["rt-core", "rt-threaded", "macros", "time","sync"]
|
| /xiu/protocol/webrtc/src/ |
| H A D | whip.rs | 7 use tokio::time::Duration;
93 let timeout = tokio::time::sleep(Duration::from_secs(3)); in handle_whip()
|
| /xiu/application/xiu/src/config/ |
| H A D | config.toml | 67 # write log to file or not（Writing logs to file or console cannot be satisfied at the same time）.
|
| /xiu/library/logger/src/ |
| H A D | logger.rs | 17 time::Duration,
191 use std::time::Duration;
|
| /xiu/library/streamhub/src/ |
| H A D | utils.rs | 3 use std::time::SystemTime;
|
| /xiu/protocol/rtmp/src/amf0/ |
| H A D | amf0_reader.rs | 281 let time = bytes_reader.read_u8().unwrap(); in test_number() localVariable
284 t = (t << 8) + time as u32; in test_number()
|
| /xiu/protocol/rtsp/src/rtp/ |
| H A D | utils.rs | 12 use std::time::SystemTime;
|