mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-06-07 07:58:51 +00:00
Code Issues 1 Projects Releases Wiki Activity

Remove dummy signals, add full signal.

Browse source 
Original commit message from CVS:
Remove dummy signals, add full signal.
This commit is contained in:
Colin Walters 2003-04-17 09:19:34 +00:00
parent 45521ec77a
commit 900066617c
4 changed files with 20 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
gst/gstqueue.c
View file

@ -1,6 +1,7 @@
/* GStreamer /* GStreamer
* Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu> * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
* 2000 Wim Taymans <wtay@chello.be> * 2000 Wim Taymans <wtay@chello.be>
* 2003 Colin Walters <cwalters@gnome.org>
* *
* gstqueue.c: * gstqueue.c:
* *
@ -51,8 +52,7 @@ GstElementDetails gst_queue_details = {
/* Queue signals and args */ /* Queue signals and args */
enum { enum {
LOW_WATERMARK, FULL,
HIGH_WATERMARK,
LAST_SIGNAL LAST_SIGNAL
}; };
@ -111,7 +111,7 @@ queue_leaky_get_type(void) {
} }
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/* static guint gst_queue_signals[LAST_SIGNAL] = { 0 }; */ static guint gst_queue_signals[LAST_SIGNAL] = { 0 };
GType GType
gst_queue_get_type(void) gst_queue_get_type(void)
@ -147,6 +147,10 @@ gst_queue_class_init (GstQueueClass *klass)
parent_class = g_type_class_ref (GST_TYPE_ELEMENT); parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
gst_queue_signals[FULL] =
g_signal_new ("full", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstQueueClass, full), NULL, NULL,
g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0);
g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LEAKY, g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LEAKY,
g_param_spec_enum ("leaky", "Leaky", "Where the queue leaks, if at all.", g_param_spec_enum ("leaky", "Leaky", "Where the queue leaks, if at all.",
GST_TYPE_QUEUE_LEAKY, GST_QUEUE_NO_LEAK, G_PARAM_READWRITE)); GST_TYPE_QUEUE_LEAKY, GST_QUEUE_NO_LEAK, G_PARAM_READWRITE));
@ -348,6 +352,8 @@ restart:
GST_DEBUG_ELEMENT (GST_CAT_DATAFLOW, queue, "adding buffer %p of size %d",buf,GST_BUFFER_SIZE(buf)); GST_DEBUG_ELEMENT (GST_CAT_DATAFLOW, queue, "adding buffer %p of size %d",buf,GST_BUFFER_SIZE(buf));
if (queue->level_buffers == queue->size_buffers) { if (queue->level_buffers == queue->size_buffers) {
g_signal_emit (G_OBJECT (queue), gst_queue_signals[FULL], 0);
/* if this is a leaky queue... */ /* if this is a leaky queue... */
if (queue->leaky) { if (queue->leaky) {
/* FIXME don't want to leak events! */ /* FIXME don't want to leak events! */

3
gst/gstqueue.h
View file

@ -89,8 +89,7 @@ struct _GstQueueClass {
GstElementClass parent_class; GstElementClass parent_class;
/* signal callbacks */ /* signal callbacks */
void (*low_watermark) (GstQueue *queue, gint level); void (*full) (GstQueue *queue);
void (*high_watermark) (GstQueue *queue, gint level);
}; };
GType gst_queue_get_type (void); GType gst_queue_get_type (void);

12
plugins/elements/gstqueue.c
View file

@ -1,6 +1,7 @@
/* GStreamer /* GStreamer
* Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu> * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
* 2000 Wim Taymans <wtay@chello.be> * 2000 Wim Taymans <wtay@chello.be>
* 2003 Colin Walters <cwalters@gnome.org>
* *
* gstqueue.c: * gstqueue.c:
* *
@ -51,8 +52,7 @@ GstElementDetails gst_queue_details = {
/* Queue signals and args */ /* Queue signals and args */
enum { enum {
LOW_WATERMARK, FULL,
HIGH_WATERMARK,
LAST_SIGNAL LAST_SIGNAL
}; };
@ -111,7 +111,7 @@ queue_leaky_get_type(void) {
} }
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/* static guint gst_queue_signals[LAST_SIGNAL] = { 0 }; */ static guint gst_queue_signals[LAST_SIGNAL] = { 0 };
GType GType
gst_queue_get_type(void) gst_queue_get_type(void)
@ -147,6 +147,10 @@ gst_queue_class_init (GstQueueClass *klass)
parent_class = g_type_class_ref (GST_TYPE_ELEMENT); parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
gst_queue_signals[FULL] =
g_signal_new ("full", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstQueueClass, full), NULL, NULL,
g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0);
g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LEAKY, g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LEAKY,
g_param_spec_enum ("leaky", "Leaky", "Where the queue leaks, if at all.", g_param_spec_enum ("leaky", "Leaky", "Where the queue leaks, if at all.",
GST_TYPE_QUEUE_LEAKY, GST_QUEUE_NO_LEAK, G_PARAM_READWRITE)); GST_TYPE_QUEUE_LEAKY, GST_QUEUE_NO_LEAK, G_PARAM_READWRITE));
@ -348,6 +352,8 @@ restart:
GST_DEBUG_ELEMENT (GST_CAT_DATAFLOW, queue, "adding buffer %p of size %d",buf,GST_BUFFER_SIZE(buf)); GST_DEBUG_ELEMENT (GST_CAT_DATAFLOW, queue, "adding buffer %p of size %d",buf,GST_BUFFER_SIZE(buf));
if (queue->level_buffers == queue->size_buffers) { if (queue->level_buffers == queue->size_buffers) {
g_signal_emit (G_OBJECT (queue), gst_queue_signals[FULL], 0);
/* if this is a leaky queue... */ /* if this is a leaky queue... */
if (queue->leaky) { if (queue->leaky) {
/* FIXME don't want to leak events! */ /* FIXME don't want to leak events! */

3
plugins/elements/gstqueue.h
View file

@ -89,8 +89,7 @@ struct _GstQueueClass {
GstElementClass parent_class; GstElementClass parent_class;
/* signal callbacks */ /* signal callbacks */
void (*low_watermark) (GstQueue *queue, gint level); void (*full) (GstQueue *queue);
void (*high_watermark) (GstQueue *queue, gint level);
}; };
GType gst_queue_get_type (void); GType gst_queue_get_type (void);