summary | shortlog | log | commit | commitdiff | tree
raw | patch | inline | side by side (parent: 8167fcd)
raw | patch | inline | side by side (parent: 8167fcd)
author | Wim Taymans <wim.taymans@gmail.com> | |
Sat, 8 Oct 2005 14:57:09 +0000 (14:57 +0000) | ||
committer | Wim Taymans <wim.taymans@gmail.com> | |
Sat, 8 Oct 2005 14:57:09 +0000 (14:57 +0000) |
Original commit message from CVS:
* gst/base/gstbasesink.c: (gst_base_sink_handle_object),
(gst_base_sink_handle_buffer):
Better log message.
* gst/gstbus.h:
* gst/gstelement.h:
More docs.
* gst/gstqueue.c: (gst_queue_class_init), (gst_queue_init),
(gst_queue_set_property), (gst_queue_get_property):
* gst/gstqueue.h:
Remove old unused properties.
* gst/base/gstbasesink.c: (gst_base_sink_handle_object),
(gst_base_sink_handle_buffer):
Better log message.
* gst/gstbus.h:
* gst/gstelement.h:
More docs.
* gst/gstqueue.c: (gst_queue_class_init), (gst_queue_init),
(gst_queue_set_property), (gst_queue_get_property):
* gst/gstqueue.h:
Remove old unused properties.
diff --git a/ChangeLog b/ChangeLog
index c7aef813dbf1112f20e414e3931d1ee855b09b18..400bdfcc0e95269eacb808b907ccf2789f49706c 100644 (file)
--- a/ChangeLog
+++ b/ChangeLog
+2005-10-08 Wim Taymans <wim@fluendo.com>
+
+ * gst/base/gstbasesink.c: (gst_base_sink_handle_object),
+ (gst_base_sink_handle_buffer):
+ Better log message.
+
+ * gst/gstbus.h:
+ * gst/gstelement.h:
+ More docs.
+
+ * gst/gstqueue.c: (gst_queue_class_init), (gst_queue_init),
+ (gst_queue_set_property), (gst_queue_get_property):
+ * gst/gstqueue.h:
+ Remove old unused properties.
+
2005-10-08 Stefan Kost <ensonic@users.sf.net>
* docs/gst/gstreamer-sections.txt:
* gst/gstmessage.c:
diff --git a/gst/base/gstbasesink.c b/gst/base/gstbasesink.c
index 93a445eb3a39564839b9d8297335bc80748b6eb0..4d57ec2f805d00ca5c5c0c76cc0a73075ea7aeed 100644 (file)
--- a/gst/base/gstbasesink.c
+++ b/gst/base/gstbasesink.c
status = gst_base_sink_do_sync (basesink, buf);
switch (status) {
case GST_CLOCK_EARLY:
- GST_DEBUG_OBJECT (basesink, "late frame !");
+ GST_DEBUG_OBJECT (basesink, "buffer too late!");
/* fallthrough for now */
case GST_CLOCK_OK:
{
diff --git a/gst/gstbus.h b/gst/gstbus.h
index 9bbb719d01cd6a5b18cf0b73fb0006f7c96d9f9e..c571bc59ea938aa1f06df1b688e5652872e35b36 100644 (file)
--- a/gst/gstbus.h
+++ b/gst/gstbus.h
#define GST_BUS_GET_CLASS(bus) (G_TYPE_INSTANCE_GET_CLASS ((bus), GST_TYPE_BUS, GstBusClass))
#define GST_BUS_CAST(bus) ((GstBus*)(bus))
+/**
+ * GstBusFlags:
+ * @GST_BUS_FLUSHING: The bus is currently dropping all messages
+ * @GST_BUS_FLAG_LAST: offset to define more flags
+ *
+ * The standard flags that a bus may have.
+ */
typedef enum {
GST_BUS_FLUSHING = GST_OBJECT_FLAG_LAST,
GST_BUS_FLAG_LAST = GST_OBJECT_FLAG_LAST + 1
} GstBusFlags;
+/**
+ * GstBusSyncReply:
+ * @GST_BUS_DROP: drop the message
+ * @GST_BUS_PASS: pass the message to the async queue
+ * @GST_BUS_ASYNC: pass message to async queue, continue if message is handled
+ *
+ * The result values for a GstBusSyncHandler.
+ */
typedef enum
{
- GST_BUS_DROP = 0, /* drop message */
- GST_BUS_PASS = 1, /* pass message to async queue */
- GST_BUS_ASYNC = 2, /* pass message to async queue, continue if message is handled */
+ GST_BUS_DROP = 0,
+ GST_BUS_PASS = 1,
+ GST_BUS_ASYNC = 2,
} GstBusSyncReply;
/**
diff --git a/gst/gstelement.h b/gst/gstelement.h
index 97492a8c2c6ae953c36375f821d9e34bde049b61..066955705518b40b26bd6bb0574d9d30cecd98fd 100644 (file)
--- a/gst/gstelement.h
+++ b/gst/gstelement.h
* @GST_STATE_CHANGE_SUCCESS : the state change succeeded
* @GST_STATE_CHANGE_ASYNC : the state change will happen asynchronously
* @GST_STATE_CHANGE_NO_PREROLL: the state change cannot be prerolled
+ *
+ * the possible return values from a state change function.
*/
typedef enum {
GST_STATE_CHANGE_FAILURE = 0,
diff --git a/gst/gstqueue.c b/gst/gstqueue.c
index 656d280778390b31d931c2eb9290e2df954d3cb5..5b6902a250fc390133ef32f3a9074cc5abb0d542 100644 (file)
--- a/gst/gstqueue.c
+++ b/gst/gstqueue.c
ARG_MIN_THRESHOLD_BYTES,
ARG_MIN_THRESHOLD_TIME,
ARG_LEAKY,
- ARG_MAY_DEADLOCK,
- ARG_BLOCK_TIMEOUT
- /* FILL ME */
+ /* FILL ME */
};
#define GST_QUEUE_MUTEX_LOCK(q) G_STMT_START { \
g_param_spec_enum ("leaky", "Leaky",
"Where the queue leaks, if at all",
GST_TYPE_QUEUE_LEAKY, GST_QUEUE_NO_LEAK, G_PARAM_READWRITE));
- g_object_class_install_property (gobject_class, ARG_MAY_DEADLOCK,
- g_param_spec_boolean ("may_deadlock", "May Deadlock",
- "The queue may deadlock if it's full and not PLAYING",
- TRUE, G_PARAM_READWRITE));
- g_object_class_install_property (gobject_class, ARG_BLOCK_TIMEOUT,
- g_param_spec_uint64 ("block_timeout", "Timeout for Block",
- "Nanoseconds until blocked queue times out and returns filler event. "
- "Value of -1 disables timeout",
- 0, G_MAXUINT64, -1, G_PARAM_READWRITE));
/* set several parent class virtual functions */
gobject_class->finalize = GST_DEBUG_FUNCPTR (gst_queue_finalize);
queue->min_threshold.time = 0; /* no threshold */
queue->leaky = GST_QUEUE_NO_LEAK;
- queue->may_deadlock = TRUE;
- queue->block_timeout = GST_CLOCK_TIME_NONE;
queue->srcresult = GST_FLOW_WRONG_STATE;
queue->qlock = g_mutex_new ();
case ARG_LEAKY:
queue->leaky = g_value_get_enum (value);
break;
- case ARG_MAY_DEADLOCK:
- queue->may_deadlock = g_value_get_boolean (value);
- break;
- case ARG_BLOCK_TIMEOUT:
- queue->block_timeout = g_value_get_uint64 (value);
- break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
case ARG_LEAKY:
g_value_set_enum (value, queue->leaky);
break;
- case ARG_MAY_DEADLOCK:
- g_value_set_boolean (value, queue->may_deadlock);
- break;
- case ARG_BLOCK_TIMEOUT:
- g_value_set_uint64 (value, queue->block_timeout);
- break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
diff --git a/gst/gstqueue.h b/gst/gstqueue.h
index aec09468fdb301c20a956ceb7835e8901a34501a..f0f1165d064b32b2bf5e6506b729a08d8cbedda1 100644 (file)
--- a/gst/gstqueue.h
+++ b/gst/gstqueue.h
/* whether we leak data, and at which end */
gint leaky;
- /* number of nanoseconds until a blocked queue 'times out'
- * to receive data and returns a filler event. -1 = disable */
- guint64 block_timeout;
-
- /* it the queue should fail on possible deadlocks */
- gboolean may_deadlock;
-
GMutex *qlock; /* lock for queue (vs object lock) */
GCond *item_add; /* signals buffers now available for reading */
GCond *item_del; /* signals space now available for writing */
index 93a445eb3a39564839b9d8297335bc80748b6eb0..4d57ec2f805d00ca5c5c0c76cc0a73075ea7aeed 100644 (file)
status = gst_base_sink_do_sync (basesink, buf);
switch (status) {
case GST_CLOCK_EARLY:
- GST_DEBUG_OBJECT (basesink, "late frame !");
+ GST_DEBUG_OBJECT (basesink, "buffer too late!");
/* fallthrough for now */
case GST_CLOCK_OK:
{
index 656d280778390b31d931c2eb9290e2df954d3cb5..5b6902a250fc390133ef32f3a9074cc5abb0d542 100644 (file)
ARG_MIN_THRESHOLD_BYTES,
ARG_MIN_THRESHOLD_TIME,
ARG_LEAKY,
- ARG_MAY_DEADLOCK,
- ARG_BLOCK_TIMEOUT
- /* FILL ME */
+ /* FILL ME */
};
#define GST_QUEUE_MUTEX_LOCK(q) G_STMT_START { \
g_param_spec_enum ("leaky", "Leaky",
"Where the queue leaks, if at all",
GST_TYPE_QUEUE_LEAKY, GST_QUEUE_NO_LEAK, G_PARAM_READWRITE));
- g_object_class_install_property (gobject_class, ARG_MAY_DEADLOCK,
- g_param_spec_boolean ("may_deadlock", "May Deadlock",
- "The queue may deadlock if it's full and not PLAYING",
- TRUE, G_PARAM_READWRITE));
- g_object_class_install_property (gobject_class, ARG_BLOCK_TIMEOUT,
- g_param_spec_uint64 ("block_timeout", "Timeout for Block",
- "Nanoseconds until blocked queue times out and returns filler event. "
- "Value of -1 disables timeout",
- 0, G_MAXUINT64, -1, G_PARAM_READWRITE));
/* set several parent class virtual functions */
gobject_class->finalize = GST_DEBUG_FUNCPTR (gst_queue_finalize);
queue->min_threshold.time = 0; /* no threshold */
queue->leaky = GST_QUEUE_NO_LEAK;
- queue->may_deadlock = TRUE;
- queue->block_timeout = GST_CLOCK_TIME_NONE;
queue->srcresult = GST_FLOW_WRONG_STATE;
queue->qlock = g_mutex_new ();
case ARG_LEAKY:
queue->leaky = g_value_get_enum (value);
break;
- case ARG_MAY_DEADLOCK:
- queue->may_deadlock = g_value_get_boolean (value);
- break;
- case ARG_BLOCK_TIMEOUT:
- queue->block_timeout = g_value_get_uint64 (value);
- break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
case ARG_LEAKY:
g_value_set_enum (value, queue->leaky);
break;
- case ARG_MAY_DEADLOCK:
- g_value_set_boolean (value, queue->may_deadlock);
- break;
- case ARG_BLOCK_TIMEOUT:
- g_value_set_uint64 (value, queue->block_timeout);
- break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
index aec09468fdb301c20a956ceb7835e8901a34501a..f0f1165d064b32b2bf5e6506b729a08d8cbedda1 100644 (file)
/* whether we leak data, and at which end */
gint leaky;
- /* number of nanoseconds until a blocked queue 'times out'
- * to receive data and returns a filler event. -1 = disable */
- guint64 block_timeout;
-
- /* it the queue should fail on possible deadlocks */
- gboolean may_deadlock;
-
GMutex *qlock; /* lock for queue (vs object lock) */
GCond *item_add; /* signals buffers now available for reading */
GCond *item_del; /* signals space now available for writing */