diff options
Diffstat (limited to 'plugins/elements/gstqueue.h')
| -rw-r--r-- | plugins/elements/gstqueue.h | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/plugins/elements/gstqueue.h b/plugins/elements/gstqueue.h index 6ab8617..57ccc2a 100644 --- a/plugins/elements/gstqueue.h +++ b/plugins/elements/gstqueue.h @@ -38,6 +38,8 @@ G_BEGIN_DECLS (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_QUEUE)) #define GST_IS_QUEUE_CLASS(klass) \ (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_QUEUE)) +#define GST_QUEUE_CAST(obj) \ + ((GstQueue *)(obj)) typedef struct _GstQueue GstQueue; typedef struct _GstQueueSize GstQueueSize; @@ -105,7 +107,7 @@ struct _GstQueue { gboolean eos; /* the queue of data we're keeping our grubby hands on */ - GQueue *queue; + GQueue queue; GstQueueSize cur_level, /* currently in the queue */ @@ -116,11 +118,11 @@ struct _GstQueue { /* whether we leak data, and at which end */ gint leaky; - GMutex *qlock; /* lock for queue (vs object lock) */ + GMutex qlock; /* lock for queue (vs object lock) */ gboolean waiting_add; - GCond *item_add; /* signals buffers now available for reading */ + GCond item_add; /* signals buffers now available for reading */ gboolean waiting_del; - GCond *item_del; /* signals space now available for writing */ + GCond item_del; /* signals space now available for writing */ gboolean head_needs_discont, tail_needs_discont; gboolean push_newsegment; @@ -129,6 +131,8 @@ struct _GstQueue { /* whether the first new segment has been applied to src */ gboolean newseg_applied_to_src; + + gboolean last_query; }; struct _GstQueueClass { |