gst/gstevent.c: Set invalid timestamp by default instead of zero on events.

Original commit message from CVS:
* gst/gstevent.c: (gst_event_new):
Set invalid timestamp by default instead of zero on events.
* gst/gstqueue.c: (gst_queue_chain), (gst_queue_get):
Clear interrupt state after handling.
This commit is contained in:
Ronald S. Bultje 2005-06-05 09:07:32 +00:00
parent 6dc13c13e1
commit 69202dfe80
5 changed files with 13 additions and 2 deletions

View file

@ -1,3 +1,10 @@
2005-06-05 Ronald S. Bultje <rbultje@ronald.bitfreak.net>
* gst/gstevent.c: (gst_event_new):
Set invalid timestamp by default instead of zero on events.
* gst/gstqueue.c: (gst_queue_chain), (gst_queue_get):
Clear interrupt state after handling.
2005-06-03 Ronald S. Bultje <rbultje@ronald.bitfreak.net>
* gst/gstvalue.c: (gst_value_list_append_value):

2
common

@ -1 +1 @@
Subproject commit 67b7e6c0db99415e0440d0c576495641b53e976a
Subproject commit 495d6e30b3e513aebbc98467707c609c49ea654d

View file

@ -185,7 +185,7 @@ gst_event_new (GstEventType type)
(GstDataCopyFunction) _gst_event_copy);
GST_EVENT_TYPE (event) = type;
GST_EVENT_TIMESTAMP (event) = G_GINT64_CONSTANT (0);
GST_EVENT_TIMESTAMP (event) = GST_CLOCK_TIME_NONE;
GST_EVENT_SRC (event) = NULL;
GST_DATA_FLAG_SET (GST_DATA (event), GST_EVENT_COMMON_FLAG_NEED_RESPONSE);

View file

@ -724,6 +724,7 @@ restart:
g_cond_wait (queue->item_del, queue->qlock);
STATUS (queue, "received item_del signal from thread using qlock");
} else {
queue->interrupt = FALSE;
GST_CAT_DEBUG_OBJECT (queue_dataflow, queue,
"Not waiting, just adding buffer, after interrupt (bad!)");
break;
@ -809,6 +810,7 @@ restart:
GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted");
GST_QUEUE_MUTEX_UNLOCK;
sched = gst_pad_get_scheduler (queue->srcpad);
queue->interrupt = FALSE;
if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue)))
return GST_DATA (gst_event_new (GST_EVENT_INTERRUPT));
goto restart;

View file

@ -724,6 +724,7 @@ restart:
g_cond_wait (queue->item_del, queue->qlock);
STATUS (queue, "received item_del signal from thread using qlock");
} else {
queue->interrupt = FALSE;
GST_CAT_DEBUG_OBJECT (queue_dataflow, queue,
"Not waiting, just adding buffer, after interrupt (bad!)");
break;
@ -809,6 +810,7 @@ restart:
GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted");
GST_QUEUE_MUTEX_UNLOCK;
sched = gst_pad_get_scheduler (queue->srcpad);
queue->interrupt = FALSE;
if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue)))
return GST_DATA (gst_event_new (GST_EVENT_INTERRUPT));
goto restart;