#define DEFAULT_PCM_OUT_SAMPLERATE 44100
#define DEFAULT_PCM_OUT_CHANNEL 2
+#define MQ_UNLINKED_CACHE_TIME (500 * GST_MSECOND)
+
/*---------------------------------------------------------------------------
| LOCAL CONSTANT DEFINITIONS: |
---------------------------------------------------------------------------*/
}
static GstPadProbeReturn
-__mmplayer_gst_selector_blocked(GstPad *pad, GstPadProbeInfo *info, gpointer data)
+__mmplayer_gst_combiner_blocked(GstPad *pad, GstPadProbeInfo *info, gpointer data)
{
LOGD("pad(%s:%s) is blocked", GST_DEBUG_PAD_NAME(pad));
return GST_PAD_PROBE_OK;
}
static GstPadProbeReturn
-__mmplayer_gst_selector_event_probe(GstPad *pad, GstPadProbeInfo *info, gpointer data)
+__mmplayer_gst_combiner_event_probe(GstPad *pad, GstPadProbeInfo *info, gpointer data)
{
GstPadProbeReturn ret = GST_PAD_PROBE_OK;
GstEvent *event = GST_PAD_PROBE_INFO_DATA(info);
return ret;
MMPLAYER_GST_GET_CAPS_INFO_FROM_PAD(pad, caps, str, name, caps_ret);
- if (!caps_ret)
+ if (!caps_ret) {
+ GstStream *stream = NULL;
+
+ if (GST_EVENT_TYPE(event) != GST_EVENT_STREAM_START)
+ goto ERROR;
+
+ gst_event_parse_stream (event, &stream);
+ if (stream == NULL) {
+ LOGW ("Got a STREAM_START event without a GstStream");
+ goto ERROR;
+ }
+
+ name = gst_stream_type_get_name(gst_stream_get_stream_type(stream));
+ gst_object_unref (stream);
+ }
+
+ if (!name)
goto ERROR;
if (strstr(name, "audio")) {
}
static GstElement *
-__mmplayer_gst_make_concat(mmplayer_t *player, main_element_id_e elem_idx)
+__mmplayer_gst_make_concat(mmplayer_t *player, main_element_id_e elem_idx, mmplayer_track_type_e stream_type)
{
GstElement *pipeline = NULL;
- GstElement *concat = NULL;
+ g_autoptr(GstElement) concat = NULL;
+ g_autoptr(GstPad) srcpad = NULL;
MMPLAYER_FENTER();
MMPLAYER_RETURN_VAL_IF_FAIL(player && player->pipeline && player->pipeline->mainbin, NULL);
return NULL;
}
+ srcpad = gst_element_get_static_pad(concat, "src");
+
+ LOGD("blocking %s:%s", GST_DEBUG_PAD_NAME(srcpad));
+ player->track[stream_type].block_id = gst_pad_add_probe(srcpad, GST_PAD_PROBE_TYPE_BLOCK_DOWNSTREAM,
+ __mmplayer_gst_combiner_blocked, NULL, NULL);
+ player->track[stream_type].event_probe_id = gst_pad_add_probe(srcpad, GST_PAD_PROBE_TYPE_EVENT_BOTH|GST_PAD_PROBE_TYPE_EVENT_FLUSH,
+ __mmplayer_gst_combiner_event_probe, player, NULL);
+
+
gst_element_set_state(concat, GST_STATE_PAUSED);
pipeline = player->pipeline->mainbin[MMPLAYER_M_PIPE].gst;
if (!gst_bin_add(GST_BIN(pipeline), concat)) {
LOGE("failed to add concat to pipeline");
gst_element_set_state(concat, GST_STATE_NULL);
- gst_object_unref(GST_OBJECT(concat));
return NULL;
}
player->pipeline->mainbin[elem_idx].gst = concat;
MMPLAYER_FLEAVE();
- return concat;
+ return g_steal_pointer(&concat);
}
static GstElement *
LOGD("blocking %s:%s", GST_DEBUG_PAD_NAME(srcpad));
player->track[stream_type].block_id = gst_pad_add_probe(srcpad, GST_PAD_PROBE_TYPE_BLOCK_DOWNSTREAM,
- __mmplayer_gst_selector_blocked, NULL, NULL);
+ __mmplayer_gst_combiner_blocked, NULL, NULL);
player->track[stream_type].event_probe_id = gst_pad_add_probe(srcpad, GST_PAD_PROBE_TYPE_EVENT_BOTH|GST_PAD_PROBE_TYPE_EVENT_FLUSH,
- __mmplayer_gst_selector_event_probe, player, NULL);
+ __mmplayer_gst_combiner_event_probe, player, NULL);
gst_element_set_state(selector, GST_STATE_PAUSED);
if (MMPLAYER_USE_DECODEBIN(player))
combiner = __mmplayer_gst_make_selector(player, elem_idx, stream_type);
else
- combiner = __mmplayer_gst_make_concat(player, elem_idx);
+ combiner = __mmplayer_gst_make_concat(player, elem_idx, stream_type);
if (!combiner)
goto ERROR;
MMPLAYER_RETURN_IF_FAIL(player && tf && caps);
- MMPLAYER_LOG_GST_CAPS_TYPE(caps);
MMPLAYER_FREEIF(player->type_caps_str);
player->type_caps_str = gst_caps_to_string(caps);
- if (player->type_caps_str)
- LOGD("[handle: %p] media type %s found, probability %d%% / %d",
- player, player->type_caps_str, probability, gst_caps_get_size(caps));
+ LOGD("[handle: %p] media type %s found, probability %d%% / %d",
+ player, player->type_caps_str, probability, gst_caps_get_size(caps));
if ((!MMPLAYER_IS_RTSP_STREAMING(player)) &&
(g_strrstr(player->type_caps_str, "audio/x-raw-int"))) {
return FALSE;
}
+ if (!MMPLAYER_USE_DECODEBIN(player)) {
+ if (player->pipeline->mainbin[MMPLAYER_M_AUTOPLUG].gst)
+ g_object_set(G_OBJECT(player->pipeline->mainbin[MMPLAYER_M_AUTOPLUG].gst),
+ "uri", profile.uri, NULL);
+ }
+
SECURE_LOGD("next playback uri: %s", uri);
return TRUE;
}
}
num_of_uri = g_list_length(player->uri_info.uri_list);
+ if (!MMPLAYER_USE_DECODEBIN(player))
+ player->gapless.running = TRUE;
LOGD("repeat count = %d, num_of_list = %d", count, num_of_uri);
LOGD("there is no next uri and no repeat");
goto ERROR;
}
+
+ if (!MMPLAYER_USE_DECODEBIN(player)) {
+ if (player->pipeline->mainbin[MMPLAYER_M_AUTOPLUG].gst)
+ g_object_set(G_OBJECT(player->pipeline->mainbin[MMPLAYER_M_AUTOPLUG].gst),
+ "uri", player->profile.uri, NULL);
+ }
+
LOGD("looping cnt %d", count);
} else {
/* gapless playback path */
gint stype = 0;
gint width = 0;
GstStructure *str = NULL;
- mm_attrs_get_int_by_name(player->attrs, "display_surface_type", &stype);
- /* don't make video because of not required */
- if ((stype == MM_DISPLAY_SURFACE_NULL) &&
- (!player->set_mode.video_export)) {
- LOGD("no need video decoding, expose pad");
- result = GST_AUTOPLUG_SELECT_EXPOSE;
- goto DONE;
+ /* parsebin in adaptivedemux get error if there is no parser */
+ if ((!g_strrstr(GST_ELEMENT_NAME(bin), "parsebin")) ||
+ ((!MMPLAYER_IS_HTTP_LIVE_STREAMING(player)) && (!MMPLAYER_IS_DASH_STREAMING(player)))) {
+ mm_attrs_get_int_by_name(player->attrs, "display_surface_type", &stype);
+
+ /* don't make video because of not required */
+ if ((stype == MM_DISPLAY_SURFACE_NULL) &&
+ (!player->set_mode.video_export)) {
+ LOGD("no need video decoding, expose pad");
+ result = GST_AUTOPLUG_SELECT_EXPOSE;
+ goto DONE;
+ }
}
/* get w/h for omx state-tune */
if (!__mmplayer_verify_gapless_play_path(player)) {
LOGD("decoding is finished.");
- MMPLAYER_CMD_UNLOCK(player);
- return;
+ if (MMPLAYER_USE_DECODEBIN(player)) {
+ MMPLAYER_CMD_UNLOCK(player);
+ return;
+ }
}
- _mmplayer_set_reconfigure_state(player, TRUE);
- MMPLAYER_CMD_UNLOCK(player);
-
- MMPLAYER_POST_MSG(player, MM_MESSAGE_FLUSH_BUFFER, NULL);
- __mmplayer_deactivate_old_path(player);
+ if (MMPLAYER_USE_DECODEBIN(player)) {
+ _mmplayer_set_reconfigure_state(player, TRUE);
+ MMPLAYER_CMD_UNLOCK(player);
+ MMPLAYER_POST_MSG(player, MM_MESSAGE_FLUSH_BUFFER, NULL);
+ __mmplayer_deactivate_old_path(player);
+ } else {
+ player->gapless.update_segment[MM_PLAYER_TRACK_TYPE_AUDIO] = FALSE;
+ player->gapless.update_segment[MM_PLAYER_TRACK_TYPE_VIDEO] = FALSE;
+ MMPLAYER_CMD_UNLOCK(player);
+ }
MMPLAYER_FLEAVE();
}
player->streamer->buffering_req.prebuffer_time);
g_object_set(player->pipeline->mainbin[MMPLAYER_M_ADAPTIVE_DEMUX].gst,
- "max-bandwidth", player->adaptive_info.limit.bandwidth,
+ "max-bitrate", player->adaptive_info.limit.bandwidth,
"max-video-width", player->adaptive_info.limit.width,
"max-video-height", player->adaptive_info.limit.height,
"low-watermark-time", (guint64)(player->streamer->buffering_req.prebuffer_time * GST_MSECOND),
}
} else if ((player->pipeline->mainbin[MMPLAYER_M_DEMUX].gst) &&
(g_strrstr(GST_ELEMENT_NAME(element), "multiqueue"))) {
+
LOGD("plugged element is multiqueue. take it %s", GST_ELEMENT_NAME(element));
+ /* set mq unlinked cache size to avoid not-linked error */
+ gboolean sync_by_running_time = FALSE;
+ g_object_get(G_OBJECT(element), "sync-by-running-time", &sync_by_running_time, NULL);
+ if (sync_by_running_time)
+ g_object_set(G_OBJECT(element), "unlinked-cache-time", MQ_UNLINKED_CACHE_TIME, NULL);
+
player->pipeline->mainbin[MMPLAYER_M_DEMUXED_S_BUFFER].id = MMPLAYER_M_DEMUXED_S_BUFFER;
player->pipeline->mainbin[MMPLAYER_M_DEMUXED_S_BUFFER].gst = element;
player = (mmplayer_t *)hplayer;
MMPLAYER_RETURN_VAL_IF_FAIL(player, MM_ERROR_PLAYER_NOT_INITIALIZED);
+ MMPLAYER_RETURN_VAL_IF_FAIL(type < MM_PLAYER_TRACK_TYPE_MAX, MM_ERROR_PLAYER_NOT_INITIALIZED);
if (!player->pipeline) {
LOGE("Track %d pre setting -> %d", type, index);
if (player->pipeline && player->pipeline->mainbin && player->pipeline->mainbin[MMPLAYER_M_ADAPTIVE_DEMUX].gst) {
LOGD("update max limit of %s", GST_ELEMENT_NAME(player->pipeline->mainbin[MMPLAYER_M_ADAPTIVE_DEMUX].gst));
g_object_set(player->pipeline->mainbin[MMPLAYER_M_ADAPTIVE_DEMUX].gst,
- "max-bandwidth", bandwidth, "max-video-width", width, "max-video-height", height, NULL);
+ "max-bitrate", bandwidth, "max-video-width", width, "max-video-height", height, NULL);
/* FIXME: seek to current position for applying new variant limitation */
}
projects / platform / core / multimedia / libmm-player.git / blobdiff