liveadder: don't use deprecated GLib threading API
authorTim-Philipp Müller <tim@centricular.net>
Sat, 9 Feb 2013 19:53:51 +0000 (19:53 +0000)
committerTim-Philipp Müller <tim@centricular.net>
Mon, 11 Feb 2013 12:01:19 +0000 (12:01 +0000)
gst/liveadder/liveadder.c
gst/liveadder/liveadder.h

index 080d471ab0137f96504dc87d264717d92626bdaf..335c10c8d919010ef94c087e8f3067f9a8033732 100644 (file)
@@ -44,7 +44,6 @@
 
 #include "liveadder.h"
 
-#include <gst/glib-compat-private.h>
 #include <gst/audio/audio.h>
 
 #include <string.h>
@@ -206,7 +205,7 @@ gst_live_adder_init (GstLiveAdder * adder)
 
   adder->padcount = 0;
   adder->func = NULL;
-  adder->not_empty_cond = g_cond_new ();
+  g_cond_init (&adder->not_empty_cond);
 
   adder->next_timestamp = GST_CLOCK_TIME_NONE;
 
@@ -221,7 +220,7 @@ gst_live_adder_finalize (GObject * object)
 {
   GstLiveAdder *adder = GST_LIVE_ADDER (object);
 
-  g_cond_free (adder->not_empty_cond);
+  g_cond_clear (&adder->not_empty_cond);
 
   g_queue_foreach (adder->buffers, (GFunc) gst_mini_object_unref, NULL);
   while (g_queue_pop_head (adder->buffers)) {
@@ -467,7 +466,7 @@ gst_live_adder_flush_start (GstLiveAdder * adder)
   if (adder->clock_id)
     gst_clock_id_unschedule (adder->clock_id);
 
-  g_cond_broadcast (adder->not_empty_cond);
+  g_cond_broadcast (&adder->not_empty_cond);
   GST_OBJECT_UNLOCK (adder);
 }
 
@@ -571,7 +570,7 @@ gst_live_adder_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
       if (ret && !padprivate->eos) {
         GST_DEBUG_OBJECT (adder, "queuing EOS");
         padprivate->eos = TRUE;
-        g_cond_broadcast (adder->not_empty_cond);
+        g_cond_broadcast (&adder->not_empty_cond);
       } else if (padprivate->eos) {
         GST_DEBUG_OBJECT (adder, "dropping EOS, we are already EOS");
       } else {
@@ -1126,7 +1125,7 @@ gst_live_live_adder_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
     skip += mix_duration;
   }
 
-  g_cond_broadcast (adder->not_empty_cond);
+  g_cond_broadcast (&adder->not_empty_cond);
 
   if (skip == GST_BUFFER_DURATION (buffer)) {
     gst_buffer_unref (buffer);
@@ -1216,7 +1215,7 @@ again:
       break;
     if (check_eos_locked (adder))
       goto eos;
-    g_cond_wait (adder->not_empty_cond, GST_OBJECT_GET_LOCK (adder));
+    g_cond_wait (&adder->not_empty_cond, GST_OBJECT_GET_LOCK (adder));
   }
 
   buffer_timestamp = GST_BUFFER_TIMESTAMP (g_queue_peek_head (adder->buffers));
index efb2169a6b5cf4774931ed7c2d3a03ae3fe6cd55..3755edf4d60a9d12bfd1c32ff646c3a8e3e173ab 100644 (file)
@@ -62,7 +62,7 @@ struct _GstLiveAdder
 
   /* the queue is ordered head to tail */
   GQueue *buffers;
-  GCond *not_empty_cond;
+  GCond not_empty_cond;
 
   GstClockTime next_timestamp;