update for task api change
authorWim Taymans <wim.taymans@collabora.co.uk>
Wed, 20 Jun 2012 08:34:48 +0000 (10:34 +0200)
committerWim Taymans <wim.taymans@collabora.co.uk>
Wed, 20 Jun 2012 08:40:42 +0000 (10:40 +0200)
23 files changed:
ext/gme/gstgme.c
ext/mimic/gstmimenc.c
ext/modplug/gstmodplug.cc
ext/mpeg2enc/gstmpeg2enc.cc
ext/mplex/gstmplex.cc
ext/musepack/gstmusepackdec.c
ext/sndfile/gstsfsink.c
ext/spc/gstspc.c
ext/timidity/gsttimidity.c
ext/timidity/gstwildmidi.c
gst/aiff/aiffparse.c
gst/asfmux/gstasfparse.c
gst/cdxaparse/gstcdxaparse.c
gst/freeze/gstfreeze.c
gst/hls/gsthlsdemux.c
gst/liveadder/liveadder.c
gst/mpegdemux/gstmpegdemux.c
gst/mpegtsdemux/mpegtsbase.c
gst/mxf/mxfdemux.c
gst/nsf/gstnsf.c
gst/nuvdemux/gstnuvdemux.c
gst/rawparse/gstrawparse.c
gst/tta/gstttaparse.c

index d787dbaf0299e98bf4cda44c8652360c647c21d6..b349df734ee8eb314bd39afccf057b11ea166d4b 100644 (file)
@@ -256,7 +256,7 @@ gst_gme_dec_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
         gme->seeking = TRUE;
 
         gst_pad_start_task (gme->srcpad, (GstTaskFunction) gst_gme_play,
-            gme->srcpad);
+            gme->srcpad, NULL);
 
         GST_PAD_STREAM_UNLOCK (gme->srcpad);
         result = TRUE;
@@ -461,7 +461,8 @@ gme_setup (GstGmeDec * gme)
   gst_segment_init (&seg, GST_FORMAT_TIME);
   gst_pad_push_event (gme->srcpad, gst_event_new_segment (&seg));
 
-  gst_pad_start_task (gme->srcpad, (GstTaskFunction) gst_gme_play, gme->srcpad);
+  gst_pad_start_task (gme->srcpad, (GstTaskFunction) gst_gme_play, gme->srcpad,
+      NULL);
 
   gme->initialized = TRUE;
   gme->seeking = FALSE;
index f4957ccb10abb7460eec1c14cbc185ea84092bb9..0a3a241fd092858544477a4f137ec13210edc9b2 100644 (file)
@@ -597,7 +597,8 @@ gst_mim_enc_change_state (GstElement * element, GstStateChange transition)
       }
       GST_OBJECT_UNLOCK (mimenc);
       if (paused_mode) {
-        if (!gst_pad_start_task (mimenc->srcpad, paused_mode_task, mimenc)) {
+        if (!gst_pad_start_task (mimenc->srcpad, paused_mode_task, mimenc,
+                NULL)) {
           ret = GST_STATE_CHANGE_FAILURE;
           GST_ERROR_OBJECT (mimenc, "Can not start task");
         }
index 645f4fd139cec24cc90437a07ce21ebbc18e7a9a..a98014207ec0b98cd5fd5e6dea011396fc1ba33f 100644 (file)
@@ -402,7 +402,7 @@ gst_modplug_do_seek (GstModPlug * modplug, GstEvent * event)
       gst_util_uint64_scale_int (cur, modplug->frequency, GST_SECOND);
 
   gst_pad_start_task (modplug->sinkpad,
-      (GstTaskFunction) gst_modplug_loop, modplug);
+      (GstTaskFunction) gst_modplug_loop, modplug, NULL);
 
   GST_PAD_STREAM_UNLOCK (modplug->sinkpad);
 
@@ -593,7 +593,7 @@ gst_modplug_sinkpad_activate_mode (GstPad * pad, GstObject * parent,
     case GST_PAD_MODE_PULL:
       if (active) {
         res = gst_pad_start_task (pad, (GstTaskFunction) gst_modplug_loop,
-            modplug);
+            modplug, NULL);
       } else {
         res = gst_pad_stop_task (pad);
       }
index ec86693cdf0f6bf9c12c96b0f0908baedd70be49..1482ae16843289d46252894e1085853dc334e266 100644 (file)
@@ -406,7 +406,7 @@ gst_mpeg2enc_setcaps (GstMpeg2enc * enc, GstPad * pad, GstCaps * caps)
 
   /* now that we have all the setup and buffers are expected incoming;
    * task can get going */
-  gst_pad_start_task (enc->srcpad, (GstTaskFunction) gst_mpeg2enc_loop, enc);
+  gst_pad_start_task (enc->srcpad, (GstTaskFunction) gst_mpeg2enc_loop, enc, NULL);
 
   return TRUE;
 
index d548f7832461abc3f6f2055b9d4d7e89c2a465bb..fc5c459bfe51ea170942e5efb2a35e00d809c8fa 100644 (file)
@@ -537,7 +537,7 @@ gst_mplex_start_task (GstMplex * mplex)
   if (G_UNLIKELY (mplex->srcresult == GST_FLOW_CUSTOM_SUCCESS)
       && mplex->job->video_tracks == mplex->num_vpads
       && mplex->job->audio_tracks == mplex->num_apads) {
-    gst_pad_start_task (mplex->srcpad, (GstTaskFunction) gst_mplex_loop, mplex);
+    gst_pad_start_task (mplex->srcpad, (GstTaskFunction) gst_mplex_loop, mplex, NULL);
     mplex->srcresult = GST_FLOW_OK;
   }
 }
index 73de6823414dd3714ace4b48bf96a8c4bd6e8bfe..10a0f0d8e43f54a097ba0312edcb4d6bc90fd402 100644 (file)
@@ -261,7 +261,7 @@ gst_musepackdec_handle_seek_event (GstMusepackDec * dec, GstEvent * event)
   GST_DEBUG_OBJECT (dec, "seek successful");
 
   gst_pad_start_task (dec->sinkpad,
-      (GstTaskFunction) gst_musepackdec_loop, dec->sinkpad);
+      (GstTaskFunction) gst_musepackdec_loop, dec->sinkpad, NULL);
 
   GST_PAD_STREAM_UNLOCK (dec->sinkpad);
 
@@ -493,7 +493,7 @@ gst_musepackdec_sink_activate_pull (GstPad * sinkpad, gboolean active)
 
   if (active) {
     result = gst_pad_start_task (sinkpad,
-        (GstTaskFunction) gst_musepackdec_loop, sinkpad);
+        (GstTaskFunction) gst_musepackdec_loop, sinkpad, NULL);
   } else {
     result = gst_pad_stop_task (sinkpad);
   }
index 56dc4b0069065b3c12be243c04c3fbb150251e92..06fb451b69d15fc12677be9b2ddf4bbc51064d4e 100644 (file)
@@ -459,7 +459,7 @@ gst_sf_sink_activate_pull (GstBaseSink * basesink, gboolean active)
   if (active) {
     /* start task */
     result = gst_pad_start_task (basesink->sinkpad,
-        (GstTaskFunction) gst_sf_sink_loop, basesink->sinkpad);
+        (GstTaskFunction) gst_sf_sink_loop, basesink->sinkpad, NULL);
   } else {
     /* step 2, make sure streaming finishes */
     result = gst_pad_stop_task (basesink->sinkpad);
index 4d76b242570c1cb91351950833d7917e57c1716c..e5950c576f4c31f783d99ce5074ebece7a89d541 100644 (file)
@@ -325,7 +325,7 @@ gst_spc_dec_src_event (GstPad * pad, GstEvent * event)
         spc->seeking = TRUE;
 
         gst_pad_start_task (spc->srcpad, (GstTaskFunction) spc_play,
-            spc->srcpad);
+            spc->srcpad, NULL);
 
         GST_PAD_STREAM_UNLOCK (spc->srcpad);
         result = TRUE;
@@ -534,7 +534,8 @@ spc_setup (GstSpcDec * spc)
   gst_pad_push_event (spc->srcpad, gst_event_new_new_segment (FALSE, 1.0,
           GST_FORMAT_TIME, 0, -1, 0));
 
-  gst_pad_start_task (spc->srcpad, (GstTaskFunction) spc_play, spc->srcpad);
+  gst_pad_start_task (spc->srcpad, (GstTaskFunction) spc_play, spc->srcpad,
+      NULL);
 
   /* We can't unreference this buffer because we might need to re-initialize
    * the emulator with the original data during a reverse seek
index 1857d53b757e4c5300135f1e6a80a0e2f5f91b76..89e592ecf70682a79907fc6796f08a381ace2ecc 100644 (file)
@@ -423,7 +423,7 @@ gst_timidity_src_event (GstPad * pad, GstEvent * event)
       timidity->o_seek = TRUE;
 
       gst_pad_start_task (timidity->sinkpad,
-          (GstTaskFunction) gst_timidity_loop, timidity->sinkpad);
+          (GstTaskFunction) gst_timidity_loop, timidity->sinkpad, NULL);
 
       GST_PAD_STREAM_UNLOCK (timidity->sinkpad);
       GST_DEBUG ("seek done");
@@ -451,7 +451,8 @@ static gboolean
 gst_timidity_activatepull (GstPad * pad, gboolean active)
 {
   if (active) {
-    return gst_pad_start_task (pad, (GstTaskFunction) gst_timidity_loop, pad);
+    return gst_pad_start_task (pad, (GstTaskFunction) gst_timidity_loop, pad,
+        NULL);
   } else {
     return gst_pad_stop_task (pad);
   }
index a37264c21d60a9cf028c0d263f278e98115754ed..260624594cd99a5cee0c1d8e7308173ff357f31d 100644 (file)
@@ -524,7 +524,7 @@ gst_wildmidi_do_seek (GstWildmidi * wildmidi, GstEvent * event)
       gst_wildmidi_get_new_segment_event (wildmidi, GST_FORMAT_TIME));
 
   gst_pad_start_task (wildmidi->sinkpad,
-      (GstTaskFunction) gst_wildmidi_loop, wildmidi->sinkpad);
+      (GstTaskFunction) gst_wildmidi_loop, wildmidi->sinkpad, NULL);
 
   wildmidi->discont = TRUE;
   GST_PAD_STREAM_UNLOCK (wildmidi->sinkpad);
@@ -567,7 +567,8 @@ static gboolean
 gst_wildmidi_activatepull (GstPad * pad, gboolean active)
 {
   if (active) {
-    return gst_pad_start_task (pad, (GstTaskFunction) gst_wildmidi_loop, pad);
+    return gst_pad_start_task (pad, (GstTaskFunction) gst_wildmidi_loop, pad,
+        NULL);
   } else {
     return gst_pad_stop_task (pad);
   }
@@ -777,7 +778,7 @@ gst_wildmidi_sink_event (GstPad * pad, GstEvent * event)
       wildmidi->state = GST_WILDMIDI_STATE_PARSE;
       /* now start the parsing task */
       gst_pad_start_task (wildmidi->sinkpad,
-          (GstTaskFunction) gst_wildmidi_loop, wildmidi->sinkpad);
+          (GstTaskFunction) gst_wildmidi_loop, wildmidi->sinkpad, NULL);
       /* don't forward the event */
       gst_event_unref (event);
       break;
index 4fe5f64e46d6237d9388d065c4d883440ae0b5f3..d6edef2fb771e6b38488ebb29c48ebca06e363a3 100644 (file)
@@ -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);
index 32265a6b60af4d15204acdb99a691751686ffb9b..0cf2671eeda5c7f09084be476e8c5b0efbcfdaa1 100644 (file)
@@ -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);
       }
index 88fa4550b9e68ac913f24a736bd4e5253909b4b6..2c82056df4389e93a284d0c4f86ee4f4d9b75054 100644 (file)
@@ -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;
index 9d50828be7c2f10003f3706403a562055c20cd94..f4022b86a652921cc62559ce91a5189d8cd57a50 100644 (file)
@@ -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);
   }
index 8e054b990df8ab2ad3b50aeccf9f10f00a75a5cd..68ba065e74dceb684d43d4eabf4b6eb2250522bd 100644 (file)
@@ -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);
 }
 
index e3c6278e5ec55c957b15cff165ce2488e82311a2..5cdced4d0d5143599b3f43172735a425721a5d75 100644 (file)
@@ -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);
index 787ac052ace2a249c3844747aab6fd3bbc407355..cfea9a328bfbf960f52af091856f730148d4a185 100644 (file)
@@ -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);
index 8887cf42a5fa86089d8fd16c2377df4c30592d5d..4083c8eeec4bc6df1784ad0762050bcc00151fb9 100644 (file)
@@ -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;
index e11a568a471ffb58cc6a861ee372e91b2ee0e33a..f782bb393fbd814fb57e7a40d482faa51e70f3ca 100644 (file)
@@ -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);
index 5a22cd99a9000ed6038092b355d54eee6c0f5609..3c155de3859d02b7310c6a4d79147250e4403463 100644 (file)
@@ -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;
 
index e3b8fd93dda5e74137ec46833b8b92efac0a77b9..b59b8e7043c62e06f8aa0dbb943aea33decd6369 100644 (file)
@@ -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);
   }
index 2db07a63051ebb7e7d9ad70e33727258c7e5fde3..dcff378f3a511a84e679c3d61f08a12338ec3faf 100644 (file)
@@ -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);
 
index 80f93b7b980b3eaefefd8624796c44d5684260a5..fe1f4f0a0d8c9081987a2b62b602dfa5c76aef8e 100644 (file)
@@ -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);
   }