From 09988a97bf136b54f71bcbcbbae45459b0d5d69c Mon Sep 17 00:00:00 2001 From: Vincent Penquerc'h Date: Mon, 9 Mar 2015 18:26:33 +0000 Subject: [PATCH] Revert "validate: use segments to detect success of flushing seeks too" This reverts commit c47cc7ba90e96ffaefe201087428ef448670f3be. Regressions on the test server, apparently linked to this patchset. --- validate/gst/validate/gst-validate-scenario.c | 33 ++++++++++--------- 1 file changed, 17 insertions(+), 16 deletions(-) diff --git a/validate/gst/validate/gst-validate-scenario.c b/validate/gst/validate/gst-validate-scenario.c index b2bafcb6cd..d1a4ed0b97 100644 --- a/validate/gst/validate/gst-validate-scenario.c +++ b/validate/gst/validate/gst-validate-scenario.c @@ -86,9 +86,6 @@ static GList *action_types = NULL; static void gst_validate_scenario_dispose (GObject * object); static void gst_validate_scenario_finalize (GObject * object); static GstValidateActionType *_find_action_type (const gchar * type_name); -static void -gst_validate_scenario_update_segment_from_seek (GstValidateScenario * scenario, - GstEvent * seek); static GPrivate main_thread_priv; @@ -441,20 +438,10 @@ _check_new_segment_done (GstPad * pad, GstPadProbeInfo * info, GstValidateAction * action) { GstEvent *event = GST_EVENT (info->data); - GstValidateScenarioPrivate *priv = action->scenario->priv; - - if (priv->last_seek && GST_EVENT_TYPE (event) == GST_EVENT_SEGMENT) { + if (GST_EVENT_TYPE (event) == GST_EVENT_SEGMENT) { if (GST_EVENT_SEQNUM (event) == action->scenario->priv->expected_seqnum) { if (!--action->scenario->priv->segments_needed) { - gst_validate_scenario_update_segment_from_seek (action->scenario, - priv->last_seek); - - if (priv->target_state == GST_STATE_PAUSED) - priv->seeked_in_pause = TRUE; - - gst_event_replace (&priv->last_seek, NULL); gst_validate_action_set_done (action); - return GST_PAD_PROBE_REMOVE; } } @@ -611,8 +598,11 @@ gst_validate_scenario_execute_seek (GstValidateScenario * scenario, } gst_event_unref (seek); - /* After seeking, we wait for a new segment with a matching seqnum */ - if (ret != GST_VALIDATE_EXECUTE_ACTION_ERROR) { + /* Flushing seeks will be deemed done when an ASYNC_DONE message gets + received on the bus. We don't get one for non flushing seeks though, + so we look for a new segment event with a matching seqnum. */ + if (ret != GST_VALIDATE_EXECUTE_ACTION_ERROR + && !(flags & GST_SEEK_FLAG_FLUSH)) { action->scenario->priv->segments_needed = _run_for_all_sinks (scenario, _add_segment_check_probe, action); } @@ -1776,6 +1766,17 @@ message_cb (GstBus * bus, GstMessage * message, GstValidateScenario * scenario) switch (GST_MESSAGE_TYPE (message)) { case GST_MESSAGE_ASYNC_DONE: + if (priv->last_seek) { + gst_validate_scenario_update_segment_from_seek (scenario, + priv->last_seek); + + if (priv->target_state == GST_STATE_PAUSED) + priv->seeked_in_pause = TRUE; + + gst_event_replace (&priv->last_seek, NULL); + gst_validate_action_set_done (priv->actions->data); + } + if (priv->needs_parsing) { GList *tmp;