FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

aggregator: Check after waiting if we're still running and otherwise stop

Browse Source 
Previously we might've produced a buffer needlessly.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/8897>
This commit is contained in:
Sebastian Dröge 2025-04-25 12:15:17 +03:00
parent 036801222f
commit b05a498187
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
subprojects/gstreamer/libs/gst/base/gstaggregator.c
View File

@ -924,6 +924,13 @@ gst_aggregator_wait_and_check (GstAggregator * self, gboolean * timeout)
*/ */
GST_OBJECT_UNLOCK (self); GST_OBJECT_UNLOCK (self);
SRC_WAIT (self); SRC_WAIT (self);
/* After waiting, check if we're actually still running */
if (!self->priv->running || !self->priv->send_eos) {
SRC_UNLOCK (self);
return FALSE;
}
} else { } else {
GstClockTime base_time, time; GstClockTime base_time, time;
GstClock *clock; GstClock *clock;
@ -965,6 +972,13 @@ gst_aggregator_wait_and_check (GstAggregator * self, gboolean * timeout)
"clock returned %d (jitter: %" GST_STIME_FORMAT ")", "clock returned %d (jitter: %" GST_STIME_FORMAT ")",
status, GST_STIME_ARGS (jitter)); status, GST_STIME_ARGS (jitter));
/* After waiting, check if we're actually still running */
if (!self->priv->running || !self->priv->send_eos) {
SRC_UNLOCK (self);
return FALSE;
}
/* we timed out */ /* we timed out */
if (status == GST_CLOCK_OK || status == GST_CLOCK_EARLY) { if (status == GST_CLOCK_OK || status == GST_CLOCK_EARLY) {
GList *l; GList *l;