Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFrançois Laignel <fengalin@free.fr>2022-10-17 20:48:43 +0300
committerFrançois Laignel <fengalin@mailo.com>2022-10-18 13:36:59 +0300
commit8011eadfd2137b4c21fa8e6dfffe6891cb2be406 (patch)
tree1db00e75b8cc26362bda0cfc86fd424b27482440 /net/raptorq
parente66378d2544f9e39acfac18143cfac4afa8ae7ac (diff)
Use new format constructors
See https://gitlab.freedesktop.org/gstreamer/gstreamer-rs/-/merge_requests/1128
Diffstat (limited to 'net/raptorq')
-rw-r--r--net/raptorq/src/raptorqdec/imp.rs4
-rw-r--r--net/raptorq/src/raptorqenc/imp.rs2
-rw-r--r--net/raptorq/tests/raptorq.rs5
3 files changed, 5 insertions, 6 deletions
diff --git a/net/raptorq/src/raptorqdec/imp.rs b/net/raptorq/src/raptorqdec/imp.rs
index f8cc4a6bb..b12f76a9d 100644
--- a/net/raptorq/src/raptorqdec/imp.rs
+++ b/net/raptorq/src/raptorqdec/imp.rs
@@ -547,8 +547,8 @@ impl RaptorqDec {
let tolerance = settings.repair_window_tolerance as u64;
let repair_window = fmtp_param_from_caps::<u64>("repair-window", incaps)?;
- let tolerance = gst::ClockTime::from_mseconds(tolerance);
- let repair_window = gst::ClockTime::from_useconds(repair_window);
+ let tolerance = tolerance.mseconds();
+ let repair_window = repair_window.useconds();
let repair_window = Some(repair_window + tolerance);
let media_packets_reset_threshold = settings.media_packets_reset_threshold as usize;
diff --git a/net/raptorq/src/raptorqenc/imp.rs b/net/raptorq/src/raptorqenc/imp.rs
index 339d6d3a2..f1bf9e8f5 100644
--- a/net/raptorq/src/raptorqenc/imp.rs
+++ b/net/raptorq/src/raptorqenc/imp.rs
@@ -177,7 +177,7 @@ impl RaptorqEnc {
.unwrap_or(0);
let delays = (1..=state.repair_packets_num)
- .map(|n| gst::ClockTime::from_mseconds((n * delay_step) as u64))
+ .map(|n| ((n * delay_step) as u64).mseconds())
.collect::<Vec<_>>();
let base_time = self.instance().base_time();
diff --git a/net/raptorq/tests/raptorq.rs b/net/raptorq/tests/raptorq.rs
index 8595c3071..0985e3201 100644
--- a/net/raptorq/tests/raptorq.rs
+++ b/net/raptorq/tests/raptorq.rs
@@ -195,8 +195,7 @@ impl RaptorqTest {
}
// Check if repair packets pushed from encoder are delayed properly
- let delay_step =
- gst::ClockTime::from_mseconds((self.repair_window / self.repair_packets) as u64);
+ let delay_step = ((self.repair_window / self.repair_packets) as u64).mseconds();
let mut delay = delay_step;
let repair_packets = (0..self.repair_packets)
@@ -556,7 +555,7 @@ fn test_raptorq_repair_window_tolerance() {
h_dec.set_src_caps_str("application/x-rtp");
h_dec_fec.set_src_caps(caps);
- h_enc_fec.set_time(gst::ClockTime::from_seconds(1)).unwrap();
+ h_enc_fec.set_time(1.seconds()).unwrap();
let result = h_enc.pull();
assert!(result.is_ok());