for (tmp = mqueue->queues; tmp; tmp = g_list_next (tmp)) {
sq = (GstSingleQueue *) tmp->data;
sq->flushing = FALSE;
+ sq->sink_stream_gid = sq->src_stream_gid = GST_GROUP_ID_INVALID;
}
/* the visible limit might not have been set on single queues that have grown because of other queueus were empty */
}
sq->sink_tainted = sq->src_tainted = TRUE;
- sq->sink_stream_gid = sq->src_stream_gid = GST_GROUP_ID_INVALID;
- sq->sink_stream_gid_changed = FALSE;
- sq->src_stream_gid_changed = FALSE;
+
return result;
}
gst_object_unref (srcpad);
}
sq->sink_tainted = sq->src_tainted = TRUE;
- sq->sink_stream_gid = sq->src_stream_gid = GST_GROUP_ID_INVALID;
- sq->sink_stream_gid_changed = FALSE;
- sq->src_stream_gid_changed = FALSE;
+
return result;
}