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

gst/gstbus.c: Get the context to wake up only once.

Browse source 
Original commit message from CVS:
* gst/gstbus.c: (gst_bus_class_init), (gst_bus_init),
(gst_bus_post):
Get the context to wake up only once.
This commit is contained in:
Wim Taymans 2005-11-04 11:43:10 +00:00
parent b2f47e379a
commit ea9dd6099a
2 changed files with 15 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
ChangeLog
View file

@ -1,3 +1,9 @@
2005-11-04 Wim Taymans <wim@fluendo.com>
* gst/gstbus.c: (gst_bus_class_init), (gst_bus_init),
(gst_bus_post):
Get the context to wake up only once.
2005-11-03 Wim Taymans <wim@fluendo.com> 2005-11-03 Wim Taymans <wim@fluendo.com>
* check/states/sinks.c: (GST_START_TEST): * check/states/sinks.c: (GST_START_TEST):

15
gst/gstbus.c
View file

@ -97,6 +97,9 @@ static void gst_bus_get_property (GObject * object, guint prop_id,
static GstObjectClass *parent_class = NULL; static GstObjectClass *parent_class = NULL;
static guint gst_bus_signals[LAST_SIGNAL] = { 0 }; static guint gst_bus_signals[LAST_SIGNAL] = { 0 };
/* the context we wakeup when we posted a message on the bus */
static GMainContext *main_context;
GType GType
gst_bus_get_type (void) gst_bus_get_type (void)
{ {
@ -194,6 +197,8 @@ gst_bus_class_init (GstBusClass * klass)
G_SIGNAL_RUN_LAST | G_SIGNAL_DETAILED, G_SIGNAL_RUN_LAST | G_SIGNAL_DETAILED,
G_STRUCT_OFFSET (GstBusClass, message), NULL, NULL, G_STRUCT_OFFSET (GstBusClass, message), NULL, NULL,
marshal_VOID__MINIOBJECT, G_TYPE_NONE, 1, GST_TYPE_MESSAGE); marshal_VOID__MINIOBJECT, G_TYPE_NONE, 1, GST_TYPE_MESSAGE);
main_context = g_main_context_default ();
} }
static void static void
@ -203,8 +208,6 @@ gst_bus_init (GstBus * bus)
bus->queue_lock = g_mutex_new (); bus->queue_lock = g_mutex_new ();
GST_DEBUG_OBJECT (bus, "created"); GST_DEBUG_OBJECT (bus, "created");
return;
} }
static void static void
@ -332,8 +335,8 @@ gst_bus_post (GstBus * bus, GstMessage * message)
g_mutex_unlock (bus->queue_lock); g_mutex_unlock (bus->queue_lock);
GST_DEBUG_OBJECT (bus, "[msg %p] pushed on async queue", message); GST_DEBUG_OBJECT (bus, "[msg %p] pushed on async queue", message);
/* FIXME cannot assume the source is only in the default context */ /* FIXME cannot assume sources are only in the default context */
g_main_context_wakeup (NULL); g_main_context_wakeup (main_context);
break; break;
case GST_BUS_ASYNC: case GST_BUS_ASYNC:
@ -356,8 +359,8 @@ gst_bus_post (GstBus * bus, GstMessage * message)
g_queue_push_tail (bus->queue, message); g_queue_push_tail (bus->queue, message);
g_mutex_unlock (bus->queue_lock); g_mutex_unlock (bus->queue_lock);
/* FIXME cannot assume the source is only in the default context */ /* FIXME cannot assume sources are only in the default context */
g_main_context_wakeup (NULL); g_main_context_wakeup (main_context);
/* now block till the message is freed */ /* now block till the message is freed */
g_cond_wait (cond, lock); g_cond_wait (cond, lock);