update for task api change

13 files changed, 27 insertions, 21 deletions

diff --git a/gst/aiff/aiffparse.c b/gst/aiff/aiffparse.c
index 4fe5f64e4..d6edef2fb 100644
--- a/gst/aiff/aiffparse.c
+++ b/gst/aiff/aiffparse.c
@@ -480,7 +480,7 @@ gst_aiff_parse_perform_seek (GstAiffParse * aiff, GstEvent * event)
   aiff->segment_running = TRUE;
   if (!aiff->streaming) {
     gst_pad_start_task (aiff->sinkpad, (GstTaskFunction) gst_aiff_parse_loop,
-        aiff->sinkpad);
+        aiff->sinkpad, NULL);
   }
 
   GST_PAD_STREAM_UNLOCK (aiff->sinkpad);
@@ -1600,7 +1600,7 @@ gst_aiff_parse_sink_activate_pull (GstPad * sinkpad, gboolean active)
   if (active) {
     aiff->segment_running = TRUE;
     return gst_pad_start_task (sinkpad, (GstTaskFunction) gst_aiff_parse_loop,
-        sinkpad);
+        sinkpad, NULL);
   } else {
     aiff->segment_running = FALSE;
     return gst_pad_stop_task (sinkpad);
diff --git a/gst/asfmux/gstasfparse.c b/gst/asfmux/gstasfparse.c
index 32265a6b6..0cf2671ee 100644
--- a/gst/asfmux/gstasfparse.c
+++ b/gst/asfmux/gstasfparse.c
@@ -100,7 +100,8 @@ gst_asf_parse_sink_activate_mode (GstPad * pad, GstObject * parent,
     case GST_PAD_MODE_PULL:
       if (active) {
         res =
-            gst_pad_start_task (pad, (GstTaskFunction) gst_asf_parse_loop, pad);
+            gst_pad_start_task (pad, (GstTaskFunction) gst_asf_parse_loop, pad,
+            NULL);
       } else {
         res = gst_pad_stop_task (pad);
       }
diff --git a/gst/cdxaparse/gstcdxaparse.c b/gst/cdxaparse/gstcdxaparse.c
index 88fa4550b..2c82056df 100644
--- a/gst/cdxaparse/gstcdxaparse.c
+++ b/gst/cdxaparse/gstcdxaparse.c
@@ -192,7 +192,7 @@ gst_cdxa_parse_sink_activate_pull (GstPad * sinkpad, gboolean active)
   if (active) {
     /* if we have a scheduler we can start the task */
     gst_pad_start_task (sinkpad, (GstTaskFunction) gst_cdxa_parse_loop,
-        sinkpad);
+        sinkpad, NULL);
   } else {
     gst_pad_stop_task (sinkpad);
   }
@@ -466,7 +466,7 @@ gst_cdxa_parse_do_seek (GstCDXAParse * cdxa, GstEvent * event)
 
   /* and restart */
   gst_pad_start_task (cdxa->sinkpad,
-      (GstTaskFunction) gst_cdxa_parse_loop, cdxa->sinkpad);
+      (GstTaskFunction) gst_cdxa_parse_loop, cdxa->sinkpad, NULL);
 
   GST_PAD_STREAM_UNLOCK (cdxa->sinkpad);
   return TRUE;
diff --git a/gst/freeze/gstfreeze.c b/gst/freeze/gstfreeze.c
index 9d50828be..f4022b86a 100644
--- a/gst/freeze/gstfreeze.c
+++ b/gst/freeze/gstfreeze.c
@@ -316,7 +316,7 @@ gst_freeze_sink_activate_pull (GstPad * sinkpad, gboolean active)
   if (active) {
     /* if we have a scheduler we can start the task */
     result = gst_pad_start_task (sinkpad,
-        (GstTaskFunction) gst_freeze_loop, sinkpad);
+        (GstTaskFunction) gst_freeze_loop, sinkpad, NULL);
   } else {
     result = gst_pad_stop_task (sinkpad);
   }
diff --git a/gst/hls/gsthlsdemux.c b/gst/hls/gsthlsdemux.c
index 8e054b990..68ba065e7 100644
--- a/gst/hls/gsthlsdemux.c
+++ b/gst/hls/gsthlsdemux.c
@@ -234,14 +234,14 @@ gst_hls_demux_init (GstHLSDemux * demux)
   /* Updates task */
   g_rec_mutex_init (&demux->updates_lock);
   demux->updates_task =
-      gst_task_new ((GstTaskFunction) gst_hls_demux_updates_loop, demux);
+      gst_task_new ((GstTaskFunction) gst_hls_demux_updates_loop, demux, NULL);
   gst_task_set_lock (demux->updates_task, &demux->updates_lock);
   g_mutex_init (&demux->updates_timed_lock);
 
   /* Streaming task */
   g_rec_mutex_init (&demux->stream_lock);
   demux->stream_task =
-      gst_task_new ((GstTaskFunction) gst_hls_demux_stream_loop, demux);
+      gst_task_new ((GstTaskFunction) gst_hls_demux_stream_loop, demux, NULL);
   gst_task_set_lock (demux->stream_task, &demux->stream_lock);
 }
 
diff --git a/gst/liveadder/liveadder.c b/gst/liveadder/liveadder.c
index e3c6278e5..5cdced4d0 100644
--- a/gst/liveadder/liveadder.c
+++ b/gst/liveadder/liveadder.c
@@ -458,7 +458,7 @@ gst_live_adder_src_activate_push (GstPad * pad, gboolean active)
     /* start pushing out buffers */
     GST_DEBUG_OBJECT (adder, "Starting task on srcpad");
     gst_pad_start_task (adder->srcpad,
-        (GstTaskFunction) gst_live_adder_loop, adder);
+        (GstTaskFunction) gst_live_adder_loop, adder, NULL);
   } else {
     /* make sure all data processing stops ASAP */
     gst_live_adder_flush_start (adder);
diff --git a/gst/mpegdemux/gstmpegdemux.c b/gst/mpegdemux/gstmpegdemux.c
index 787ac052a..cfea9a328 100644
--- a/gst/mpegdemux/gstmpegdemux.c
+++ b/gst/mpegdemux/gstmpegdemux.c
@@ -1243,7 +1243,7 @@ gst_flups_demux_handle_seek_pull (GstFluPSDemux * demux, GstEvent * event)
   gst_flups_demux_mark_discont (demux, TRUE, TRUE);
 
   gst_pad_start_task (demux->sinkpad,
-      (GstTaskFunction) gst_flups_demux_loop, demux->sinkpad);
+      (GstTaskFunction) gst_flups_demux_loop, demux->sinkpad, NULL);
 
   GST_PAD_STREAM_UNLOCK (demux->sinkpad);
 
@@ -2920,7 +2920,7 @@ gst_flups_demux_sink_activate_pull (GstPad * sinkpad, GstObject * parent,
     demux->random_access = TRUE;
     gst_object_unref (demux);
     return gst_pad_start_task (sinkpad, (GstTaskFunction) gst_flups_demux_loop,
-        sinkpad);
+        sinkpad, NULL);
   } else {
     demux->random_access = FALSE;
     gst_object_unref (demux);
diff --git a/gst/mpegtsdemux/mpegtsbase.c b/gst/mpegtsdemux/mpegtsbase.c
index 8887cf42a..4083c8eee 100644
--- a/gst/mpegtsdemux/mpegtsbase.c
+++ b/gst/mpegtsdemux/mpegtsbase.c
@@ -1712,7 +1712,8 @@ mpegts_base_handle_seek_event (MpegTSBase * base, GstPad * pad,
   }
   //else
 done:
-  gst_pad_start_task (base->sinkpad, (GstTaskFunction) mpegts_base_loop, base);
+  gst_pad_start_task (base->sinkpad, (GstTaskFunction) mpegts_base_loop, base,
+      NULL);
 push_mode:
   GST_PAD_STREAM_UNLOCK (base->sinkpad);
   return ret == GST_FLOW_OK;
@@ -1766,7 +1767,8 @@ mpegts_base_sink_activate_mode (GstPad * pad, GstObject * parent,
         base->mode = BASE_MODE_SCANNING;
         base->packetizer->calculate_offset = TRUE;
         res =
-            gst_pad_start_task (pad, (GstTaskFunction) mpegts_base_loop, base);
+            gst_pad_start_task (pad, (GstTaskFunction) mpegts_base_loop, base,
+            NULL);
       } else
         res = gst_pad_stop_task (pad);
       break;
diff --git a/gst/mxf/mxfdemux.c b/gst/mxf/mxfdemux.c
index e11a568a4..f782bb393 100644
--- a/gst/mxf/mxfdemux.c
+++ b/gst/mxf/mxfdemux.c
@@ -3360,7 +3360,7 @@ gst_mxf_demux_seek_pull (GstMXFDemux * demux, GstEvent * event)
   demux->seqnum = seqnum;
 
   gst_pad_start_task (demux->sinkpad,
-      (GstTaskFunction) gst_mxf_demux_loop, demux->sinkpad);
+      (GstTaskFunction) gst_mxf_demux_loop, demux->sinkpad, NULL);
 
   GST_PAD_STREAM_UNLOCK (demux->sinkpad);
 
@@ -3380,7 +3380,7 @@ wrong_rate:
 unresolved_metadata:
   {
     gst_pad_start_task (demux->sinkpad,
-        (GstTaskFunction) gst_mxf_demux_loop, demux->sinkpad);
+        (GstTaskFunction) gst_mxf_demux_loop, demux->sinkpad, NULL);
     GST_PAD_STREAM_UNLOCK (demux->sinkpad);
     GST_WARNING_OBJECT (demux, "metadata can't be resolved");
     return FALSE;
@@ -3592,7 +3592,7 @@ gst_mxf_demux_sink_activate_pull (GstPad * sinkpad, gboolean active)
     demux->random_access = TRUE;
     gst_object_unref (demux);
     return gst_pad_start_task (sinkpad, (GstTaskFunction) gst_mxf_demux_loop,
-        sinkpad);
+        sinkpad, NULL);
   } else {
     demux->random_access = FALSE;
     gst_object_unref (demux);
diff --git a/gst/nsf/gstnsf.c b/gst/nsf/gstnsf.c
index 5a22cd99a..3c155de38 100644
--- a/gst/nsf/gstnsf.c
+++ b/gst/nsf/gstnsf.c
@@ -397,7 +397,7 @@ start_play_tune (GstNsfDec * nsfdec)
       gst_event_new_new_segment (FALSE, 1.0, GST_FORMAT_TIME, 0, -1, 0));
 
   res = gst_pad_start_task (nsfdec->srcpad,
-      (GstTaskFunction) play_loop, nsfdec->srcpad);
+      (GstTaskFunction) play_loop, nsfdec->srcpad, NULL);
 
   return res;
 
diff --git a/gst/nuvdemux/gstnuvdemux.c b/gst/nuvdemux/gstnuvdemux.c
index e3b8fd93d..b59b8e704 100644
--- a/gst/nuvdemux/gstnuvdemux.c
+++ b/gst/nuvdemux/gstnuvdemux.c
@@ -824,7 +824,8 @@ gst_nuv_demux_sink_activate_pull (GstPad * sinkpad, gboolean active)
   GstNuvDemux *nuv = GST_NUV_DEMUX (gst_pad_get_parent (sinkpad));
 
   if (active) {
-    gst_pad_start_task (sinkpad, (GstTaskFunction) gst_nuv_demux_loop, sinkpad);
+    gst_pad_start_task (sinkpad, (GstTaskFunction) gst_nuv_demux_loop, sinkpad,
+        NULL);
   } else {
     gst_pad_stop_task (sinkpad);
   }
diff --git a/gst/rawparse/gstrawparse.c b/gst/rawparse/gstrawparse.c
index 2db07a630..dcff378f3 100644
--- a/gst/rawparse/gstrawparse.c
+++ b/gst/rawparse/gstrawparse.c
@@ -864,7 +864,8 @@ gst_raw_parse_handle_seek_pull (GstRawParse * rp, GstEvent * event)
   rp->discont = TRUE;
 
   GST_LOG_OBJECT (rp, "start streaming");
-  gst_pad_start_task (rp->sinkpad, (GstTaskFunction) gst_raw_parse_loop, rp);
+  gst_pad_start_task (rp->sinkpad, (GstTaskFunction) gst_raw_parse_loop, rp,
+      NULL);
 
   GST_PAD_STREAM_UNLOCK (rp->sinkpad);
 
diff --git a/gst/tta/gstttaparse.c b/gst/tta/gstttaparse.c
index 80f93b7b9..fe1f4f0a0 100644
--- a/gst/tta/gstttaparse.c
+++ b/gst/tta/gstttaparse.c
@@ -215,7 +215,7 @@ gst_tta_parse_src_event (GstPad * pad, GstEvent * event)
                 ttaparse->num_frames * FRAME_TIME * GST_SECOND, 0));
 
         gst_pad_start_task (ttaparse->sinkpad,
-            (GstTaskFunction) gst_tta_parse_loop, ttaparse);
+            (GstTaskFunction) gst_tta_parse_loop, ttaparse, NULL);
 
         GST_PAD_STREAM_UNLOCK (ttaparse->sinkpad);
 
@@ -312,7 +312,8 @@ gst_tta_parse_activate_pull (GstPad * pad, gboolean active)
   GstTtaParse *ttaparse = GST_TTA_PARSE (GST_OBJECT_PARENT (pad));
 
   if (active) {
-    gst_pad_start_task (pad, (GstTaskFunction) gst_tta_parse_loop, ttaparse);
+    gst_pad_start_task (pad, (GstTaskFunction) gst_tta_parse_loop, ttaparse,
+        NULL);
   } else {
     gst_pad_stop_task (pad);
   }