diff options
author | François Laignel <fengalin@free.fr> | 2022-10-17 20:48:43 +0300 |
---|---|---|
committer | François Laignel <fengalin@mailo.com> | 2022-10-18 13:36:59 +0300 |
commit | 8011eadfd2137b4c21fa8e6dfffe6891cb2be406 (patch) | |
tree | 1db00e75b8cc26362bda0cfc86fd424b27482440 /net/raptorq | |
parent | e66378d2544f9e39acfac18143cfac4afa8ae7ac (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.rs | 4 | ||||
-rw-r--r-- | net/raptorq/src/raptorqenc/imp.rs | 2 | ||||
-rw-r--r-- | net/raptorq/tests/raptorq.rs | 5 |
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()); |