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;
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;
}
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");
}
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);
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);
}
/* 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;
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;
}
}
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);
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);
}
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);
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;
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
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");
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);
}
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);
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);
}
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;
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);
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);
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);
}
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);
}
/* 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;
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);
}
/* 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);
}
/* 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);
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);
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);
}
//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;
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;
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);
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;
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);
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;
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);
}
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);
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);
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);
}