From: Wim Taymans Date: Wed, 20 Jun 2012 08:33:42 +0000 (+0200) Subject: update for task api change X-Git-Tag: 1.19.3~509^2~6949 X-Git-Url: http://review.tizen.org/git/?a=commitdiff_plain;h=30d3dfee36d40c6ab42dc457db26c52cd62fd338;p=platform%2Fupstream%2Fgstreamer.git update for task api change --- diff --git a/ext/dv/gstdvdemux.c b/ext/dv/gstdvdemux.c index 794a616..b567d7e 100644 --- a/ext/dv/gstdvdemux.c +++ b/ext/dv/gstdvdemux.c @@ -1046,7 +1046,7 @@ gst_dvdemux_handle_pull_seek (GstDVDemux * demux, GstPad * pad, /* and restart the task in case it got paused explicitely or by * the FLUSH_START event we pushed out. */ gst_pad_start_task (demux->sinkpad, (GstTaskFunction) gst_dvdemux_loop, - demux->sinkpad); + demux->sinkpad, NULL); /* and release the lock again so we can continue streaming */ GST_PAD_STREAM_UNLOCK (demux->sinkpad); @@ -1766,7 +1766,7 @@ gst_dvdemux_sink_activate_mode (GstPad * sinkpad, GstObject * parent, if (active) { demux->seek_handler = gst_dvdemux_handle_pull_seek; res = gst_pad_start_task (sinkpad, - (GstTaskFunction) gst_dvdemux_loop, sinkpad); + (GstTaskFunction) gst_dvdemux_loop, sinkpad, NULL); } else { demux->seek_handler = NULL; res = gst_pad_stop_task (sinkpad); diff --git a/gst/avi/gstavidemux.c b/gst/avi/gstavidemux.c index 7863a12..814475f 100644 --- a/gst/avi/gstavidemux.c +++ b/gst/avi/gstavidemux.c @@ -4177,7 +4177,7 @@ gst_avi_demux_handle_seek (GstAviDemux * avi, GstPad * pad, GstEvent * event) if (!avi->streaming) { gst_pad_start_task (avi->sinkpad, (GstTaskFunction) gst_avi_demux_loop, - avi->sinkpad); + avi->sinkpad, NULL); } /* reset the last flow and mark discont, seek is always DISCONT */ for (i = 0; i < avi->num_streams; i++) { @@ -5389,7 +5389,7 @@ gst_avi_demux_sink_activate_mode (GstPad * sinkpad, GstObject * parent, if (active) { avi->streaming = FALSE; res = gst_pad_start_task (sinkpad, (GstTaskFunction) gst_avi_demux_loop, - sinkpad); + sinkpad, NULL); } else { res = gst_pad_stop_task (sinkpad); } diff --git a/gst/debugutils/rndbuffersize.c b/gst/debugutils/rndbuffersize.c index e5c78c8..37a887b 100644 --- a/gst/debugutils/rndbuffersize.c +++ b/gst/debugutils/rndbuffersize.c @@ -261,7 +261,7 @@ gst_rnd_buffer_size_activate_mode (GstPad * pad, GstObject * parent, GST_INFO_OBJECT (self, "starting pull"); res = gst_pad_start_task (pad, (GstTaskFunction) gst_rnd_buffer_size_loop, - self); + self, NULL); self->need_newsegment = TRUE; } else { GST_INFO_OBJECT (self, "stopping pull"); @@ -323,7 +323,7 @@ gst_rnd_buffer_size_src_event (GstPad * pad, GstObject * parent, self->need_newsegment = TRUE; gst_pad_start_task (self->sinkpad, (GstTaskFunction) gst_rnd_buffer_size_loop, - self); + self, NULL); GST_PAD_STREAM_UNLOCK (self->sinkpad); return TRUE; diff --git a/gst/flv/gstflvdemux.c b/gst/flv/gstflvdemux.c index d22104a..29e8b5c 100644 --- a/gst/flv/gstflvdemux.c +++ b/gst/flv/gstflvdemux.c @@ -2828,7 +2828,7 @@ exit: gst_pad_pause_task (demux->sinkpad); } else { gst_pad_start_task (demux->sinkpad, - (GstTaskFunction) gst_flv_demux_loop, demux->sinkpad); + (GstTaskFunction) gst_flv_demux_loop, demux->sinkpad, NULL); } GST_PAD_STREAM_UNLOCK (demux->sinkpad); @@ -2893,7 +2893,7 @@ gst_flv_demux_sink_activate_mode (GstPad * sinkpad, GstObject * parent, if (active) { demux->random_access = TRUE; res = gst_pad_start_task (sinkpad, (GstTaskFunction) gst_flv_demux_loop, - sinkpad); + sinkpad, NULL); } else { demux->random_access = FALSE; res = gst_pad_stop_task (sinkpad); diff --git a/gst/imagefreeze/gstimagefreeze.c b/gst/imagefreeze/gstimagefreeze.c index 211df8d..b219be7 100644 --- a/gst/imagefreeze/gstimagefreeze.c +++ b/gst/imagefreeze/gstimagefreeze.c @@ -649,7 +649,7 @@ gst_image_freeze_src_event (GstPad * pad, GstObject * parent, GstEvent * event) if (self->buffer != NULL) gst_pad_start_task (self->srcpad, - (GstTaskFunction) gst_image_freeze_src_loop, self->srcpad); + (GstTaskFunction) gst_image_freeze_src_loop, self->srcpad, NULL); g_mutex_unlock (&self->lock); } @@ -685,7 +685,7 @@ gst_image_freeze_sink_chain (GstPad * pad, GstObject * parent, self->buffer = buffer; gst_pad_start_task (self->srcpad, (GstTaskFunction) gst_image_freeze_src_loop, - self->srcpad); + self->srcpad, NULL); g_mutex_unlock (&self->lock); return GST_FLOW_EOS; } diff --git a/gst/isomp4/gstqtmoovrecover.c b/gst/isomp4/gstqtmoovrecover.c index 194ea80..343678c 100644 --- a/gst/isomp4/gstqtmoovrecover.c +++ b/gst/isomp4/gstqtmoovrecover.c @@ -343,7 +343,7 @@ gst_qt_moov_recover_change_state (GstElement * element, switch (transition) { case GST_STATE_CHANGE_NULL_TO_READY: - qtmr->task = gst_task_new (gst_qt_moov_recover_run, qtmr); + qtmr->task = gst_task_new (gst_qt_moov_recover_run, qtmr, NULL); g_rec_mutex_init (&qtmr->task_mutex); gst_task_set_lock (qtmr->task, &qtmr->task_mutex); break; diff --git a/gst/isomp4/qtdemux.c b/gst/isomp4/qtdemux.c index ae3aa4c..4feadaf 100644 --- a/gst/isomp4/qtdemux.c +++ b/gst/isomp4/qtdemux.c @@ -1419,7 +1419,7 @@ gst_qtdemux_do_seek (GstQTDemux * qtdemux, GstPad * pad, GstEvent * event) qtdemux->streams[i]->last_ret = GST_FLOW_OK; gst_pad_start_task (qtdemux->sinkpad, (GstTaskFunction) gst_qtdemux_loop, - qtdemux->sinkpad); + qtdemux->sinkpad, NULL); GST_PAD_STREAM_UNLOCK (qtdemux->sinkpad); @@ -4490,7 +4490,7 @@ qtdemux_sink_activate_mode (GstPad * sinkpad, GstObject * parent, if (active) { demux->pullbased = TRUE; res = gst_pad_start_task (sinkpad, (GstTaskFunction) gst_qtdemux_loop, - sinkpad); + sinkpad, NULL); } else { res = gst_pad_stop_task (sinkpad); } diff --git a/gst/matroska/matroska-demux.c b/gst/matroska/matroska-demux.c index ad22407..84fb8db 100644 --- a/gst/matroska/matroska-demux.c +++ b/gst/matroska/matroska-demux.c @@ -2111,7 +2111,7 @@ exit: /* restart our task since it might have been stopped when we did the * flush. */ gst_pad_start_task (demux->common.sinkpad, - (GstTaskFunction) gst_matroska_demux_loop, demux->common.sinkpad); + (GstTaskFunction) gst_matroska_demux_loop, demux->common.sinkpad, NULL); /* streaming can continue now */ if (pad_locked) { @@ -4821,7 +4821,7 @@ gst_matroska_demux_sink_activate_mode (GstPad * sinkpad, GstObject * parent, if (active) { /* if we have a scheduler we can start the task */ gst_pad_start_task (sinkpad, (GstTaskFunction) gst_matroska_demux_loop, - sinkpad); + sinkpad, NULL); } else { gst_pad_stop_task (sinkpad); } diff --git a/gst/rtpmanager/gstrtpjitterbuffer.c b/gst/rtpmanager/gstrtpjitterbuffer.c index f57c040..93a76cf 100644 --- a/gst/rtpmanager/gstrtpjitterbuffer.c +++ b/gst/rtpmanager/gstrtpjitterbuffer.c @@ -904,7 +904,7 @@ gst_rtp_jitter_buffer_src_activate_mode (GstPad * pad, GstObject * parent, /* start pushing out buffers */ GST_DEBUG_OBJECT (jitterbuffer, "Starting task on srcpad"); result = gst_pad_start_task (jitterbuffer->priv->srcpad, - (GstTaskFunction) gst_rtp_jitter_buffer_loop, jitterbuffer); + (GstTaskFunction) gst_rtp_jitter_buffer_loop, jitterbuffer, NULL); } else { /* make sure all data processing stops ASAP */ gst_rtp_jitter_buffer_flush_start (jitterbuffer); diff --git a/gst/rtsp/gstrtspsrc.c b/gst/rtsp/gstrtspsrc.c index 297260c..70fb72d 100644 --- a/gst/rtsp/gstrtspsrc.c +++ b/gst/rtsp/gstrtspsrc.c @@ -6494,7 +6494,7 @@ gst_rtspsrc_start (GstRTSPSrc * src) src->pending_cmd = CMD_WAIT; if (src->task == NULL) { - src->task = gst_task_new ((GstTaskFunction) gst_rtspsrc_thread, src); + src->task = gst_task_new ((GstTaskFunction) gst_rtspsrc_thread, src, NULL); if (src->task == NULL) goto task_error; diff --git a/gst/wavparse/gstwavparse.c b/gst/wavparse/gstwavparse.c index 098222b..0e1d527 100644 --- a/gst/wavparse/gstwavparse.c +++ b/gst/wavparse/gstwavparse.c @@ -963,7 +963,7 @@ gst_wavparse_perform_seek (GstWavParse * wav, GstEvent * event) /* and start the streaming task again */ if (!wav->streaming) { gst_pad_start_task (wav->sinkpad, (GstTaskFunction) gst_wavparse_loop, - wav->sinkpad); + wav->sinkpad, NULL); } GST_PAD_STREAM_UNLOCK (wav->sinkpad); @@ -2608,7 +2608,7 @@ gst_wavparse_sink_activate_mode (GstPad * sinkpad, GstObject * parent, if (active) { /* if we have a scheduler we can start the task */ res = gst_pad_start_task (sinkpad, (GstTaskFunction) gst_wavparse_loop, - sinkpad); + sinkpad, NULL); } else { res = gst_pad_stop_task (sinkpad); }