- GstQueueEventResponse *er = g_queue_pop_head (queue->events);
-
- GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "sending event upstream");
+ GstQueueEventResponse *er;
+
+ er = g_queue_pop_head (queue->events);
+
+ GST_CAT_DEBUG_OBJECT (queue_dataflow, queue,
+ "sending event %p (%d) from event response %p upstream",
+ er->event, GST_EVENT_TYPE (er->event), er);
+ if (er->handled) {
+ /* change this to an assert when this file gets reviewed properly. */
+ GST_ELEMENT_ERROR (queue, CORE, EVENT, (NULL),
+ ("already handled event %p (%d) from event response %p upstream",
+ er->event, GST_EVENT_TYPE (er->event), er));
+ break;
+ }
+ g_mutex_unlock (queue->event_lock);