mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2024-06-08 17:29:22 +00:00
Code Issues Projects Releases Wiki Activity

mccparse/sccparse: Ignore if pausing a task that does not exist anymore

Browse source 
Not really a problem anywhere here.
This commit is contained in:
Sebastian Dröge 2020-12-07 12:45:54 +02:00 committed by Sebastian Dröge
parent 2131d5bfda
commit 89b72b53d1
2 changed files with 12 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
video/closedcaption/src/mcc_parse/imp.rs
View file

@ -628,7 +628,7 @@ impl MccParse {
Some(element) => element,
None => {
if let Some(pad) = pad_weak.upgrade() {
pad.pause_task().unwrap();
let _ = pad.pause_task();
}
return;
}
@ -809,7 +809,7 @@ impl MccParse {
Err(gst::FlowError::Flushing) => {
gst_debug!(CAT, obj: &self.sinkpad, "Pausing after pulling buffer, reason: flushing");
self.sinkpad.pause_task().unwrap();
let _ = self.sinkpad.pause_task();
return;
}
Err(flow) => {
@ -821,7 +821,7 @@ impl MccParse {
["Streaming stopped, failed to pull buffer"]
);
self.sinkpad.pause_task().unwrap();
let _ = self.sinkpad.pause_task();
return;
}
};
@ -850,7 +850,7 @@ impl MccParse {
["Failed to scan duration"]
);
self.sinkpad.pause_task().unwrap();
let _ = self.sinkpad.pause_task();
}
}
}
@ -878,7 +878,7 @@ impl MccParse {
}
}
self.sinkpad.pause_task().unwrap();
let _ = self.sinkpad.pause_task();
}
}
}
@ -1010,7 +1010,7 @@ impl MccParse {
gst_debug!(CAT, obj: element, "Pushing event {:?}", event);
self.srcpad.push_event(event);
self.sinkpad.pause_task().unwrap();
let _ = self.sinkpad.pause_task();
let mut state = self.state.lock().unwrap();
let pull = state.pull.as_ref().unwrap();

12
video/closedcaption/src/scc_parse/imp.rs
View file

@ -513,7 +513,7 @@ impl SccParse {
Some(element) => element,
None => {
if let Some(pad) = pad_weak.upgrade() {
pad.pause_task().unwrap();
let _ = pad.pause_task();
}
return;
}
@ -682,7 +682,7 @@ impl SccParse {
Err(gst::FlowError::Flushing) => {
gst_debug!(CAT, obj: &self.sinkpad, "Pausing after pulling buffer, reason: flushing");
self.sinkpad.pause_task().unwrap();
let _ = self.sinkpad.pause_task();
return;
}
Err(flow) => {
@ -694,7 +694,7 @@ impl SccParse {
["Streaming stopped, failed to pull buffer"]
);
self.sinkpad.pause_task().unwrap();
let _ = self.sinkpad.pause_task();
return;
}
};
@ -722,7 +722,7 @@ impl SccParse {
["Failed to scan duration"]
);
self.sinkpad.pause_task().unwrap();
let _ = self.sinkpad.pause_task();
}
}
}
@ -750,7 +750,7 @@ impl SccParse {
}
}
self.sinkpad.pause_task().unwrap();
let _ = self.sinkpad.pause_task();
}
}
}
@ -879,7 +879,7 @@ impl SccParse {
gst_debug!(CAT, obj: element, "Pushing event {:?}", event);
self.srcpad.push_event(event);
self.sinkpad.pause_task().unwrap();
let _ = self.sinkpad.pause_task();
let mut state = self.state.lock().unwrap();
let pull = state.pull.as_ref().unwrap();