mirror of
https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git
synced 2024-11-20 02:21:00 +00:00
Fixes for removal of SpecificFormattedValues ops on ref
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/874>
This commit is contained in:
parent
caefa6d33e
commit
0b7259afac
2 changed files with 3 additions and 5 deletions
|
@ -117,9 +117,7 @@ impl StartedState {
|
||||||
}
|
}
|
||||||
|
|
||||||
fn fragment_duration_since(&self, fragment_closed: gst::ClockTime) -> f32 {
|
fn fragment_duration_since(&self, fragment_closed: gst::ClockTime) -> f32 {
|
||||||
assert!(self.fragment_opened_at.is_some());
|
let segment_duration = fragment_closed - self.fragment_opened_at.unwrap();
|
||||||
let fragment_opened_at = &self.fragment_opened_at.unwrap();
|
|
||||||
let segment_duration = fragment_closed - fragment_opened_at;
|
|
||||||
segment_duration.mseconds() as f32 / 1_000f32
|
segment_duration.mseconds() as f32 / 1_000f32
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -192,13 +192,13 @@ impl RaptorqEnc {
|
||||||
for (target_time, repair_packet) in Iterator::zip(
|
for (target_time, repair_packet) in Iterator::zip(
|
||||||
delays
|
delays
|
||||||
.iter()
|
.iter()
|
||||||
.map(|delay| base_time.opt_add(running_time).opt_add(delay)),
|
.map(|&delay| base_time.opt_add(running_time).opt_add(delay)),
|
||||||
encoder
|
encoder
|
||||||
.repair_packets(0, repair_symbols as u32)
|
.repair_packets(0, repair_symbols as u32)
|
||||||
.chunks_exact(state.symbols_per_packet)
|
.chunks_exact(state.symbols_per_packet)
|
||||||
.enumerate()
|
.enumerate()
|
||||||
.zip(&delays)
|
.zip(&delays)
|
||||||
.map(|((n, packets), delay)| {
|
.map(|((n, packets), &delay)| {
|
||||||
let esi = packets[0].payload_id().encoding_symbol_id();
|
let esi = packets[0].payload_id().encoding_symbol_id();
|
||||||
|
|
||||||
let payload_id = RepairPayloadId {
|
let payload_id = RepairPayloadId {
|
||||||
|
|
Loading…
Reference in a new issue