mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-17 11:45:25 +00:00
Code Issues 1 Projects Releases Wiki Activity

queue: whitespace fixes

Browse source
This commit is contained in:
Wim Taymans 2009-08-28 17:49:11 +02:00
parent e54e5eb9bb
commit eaf7582b8f
2 changed files with 16 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
plugins/elements/gstqueue.c
View file

@ -585,7 +585,7 @@ apply_buffer (GstQueue * queue, GstBuffer * buffer, GstSegment * segment,
timestamp = GST_BUFFER_TIMESTAMP (buffer); timestamp = GST_BUFFER_TIMESTAMP (buffer);
duration = GST_BUFFER_DURATION (buffer); duration = GST_BUFFER_DURATION (buffer);
/* if no timestamp is set, assume it's continuous with the previous /* if no timestamp is set, assume it's continuous with the previous
* time */ * time */
if (timestamp == GST_CLOCK_TIME_NONE) if (timestamp == GST_CLOCK_TIME_NONE)
timestamp = segment->last_stop; timestamp = segment->last_stop;
@ -640,7 +640,7 @@ gst_queue_locked_enqueue (GstQueue * queue, gpointer item)
/* if this is the first buffer update the end side as well, but without the /* if this is the first buffer update the end side as well, but without the
* duration. */ * duration. */
/* FIXME : This will only be useful for current time level if the /* FIXME : This will only be useful for current time level if the
* source task is running, which is not the case for ex in * source task is running, which is not the case for ex in
* gstplaybasebin when pre-rolling. * gstplaybasebin when pre-rolling.
* See #482147 */ * See #482147 */
/* if (queue->cur_level.buffers == 1) */ /* if (queue->cur_level.buffers == 1) */

28
plugins/elements/gstqueue.h
View file

@ -40,9 +40,9 @@ G_BEGIN_DECLS
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_QUEUE)) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_QUEUE))
enum { enum {
GST_QUEUE_NO_LEAK = 0, GST_QUEUE_NO_LEAK = 0,
GST_QUEUE_LEAK_UPSTREAM = 1, GST_QUEUE_LEAK_UPSTREAM = 1,
GST_QUEUE_LEAK_DOWNSTREAM = 2 GST_QUEUE_LEAK_DOWNSTREAM = 2
}; };
typedef struct _GstQueue GstQueue; typedef struct _GstQueue GstQueue;
@ -94,18 +94,18 @@ struct _GstQueue {
GQueue *queue; GQueue *queue;
GstQueueSize GstQueueSize
cur_level, /* currently in the queue */ cur_level, /* currently in the queue */
max_size, /* max. amount of data allowed in the queue */ max_size, /* max. amount of data allowed in the queue */
min_threshold, /* min. amount of data required to wake reader */ min_threshold, /* min. amount of data required to wake reader */
orig_min_threshold; /* Original min.threshold, for reset in EOS */ orig_min_threshold; /* Original min.threshold, for reset in EOS */
/* whether we leak data, and at which end */ /* whether we leak data, and at which end */
gint leaky; gint leaky;
GMutex *qlock; /* lock for queue (vs object lock) */ GMutex *qlock; /* lock for queue (vs object lock) */
GCond *item_add; /* signals buffers now available for reading */ GCond *item_add; /* signals buffers now available for reading */
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 head_needs_discont, tail_needs_discont;
}; };
@ -114,11 +114,11 @@ struct _GstQueueClass {
/* signals - 'running' is called from both sides /* signals - 'running' is called from both sides
* which might make it sort of non-useful... */ * which might make it sort of non-useful... */
void (*underrun) (GstQueue *queue); void (*underrun) (GstQueue *queue);
void (*running) (GstQueue *queue); void (*running) (GstQueue *queue);
void (*overrun) (GstQueue *queue); void (*overrun) (GstQueue *queue);
void (*pushing) (GstQueue *queue); void (*pushing) (GstQueue *queue);
}; };
GType gst_queue_get_type (void); GType gst_queue_get_type (void);