free_fragment(&pls->init_section);
av_freep(&pls->init_sec_buf);
av_freep(&pls->pb.buffer);
- if (pls->input)
- ff_format_io_close(pls->parent, &pls->input);
+ ff_format_io_close(pls->parent, &pls->input);
if (pls->ctx) {
pls->ctx->pb = NULL;
avformat_close_input(&pls->ctx);
return 0;
}
-static int resolve_content_path(AVFormatContext *s, const char *url, int *max_url_size, xmlNodePtr *baseurl_nodes, int n_baseurl_nodes) {
-
+static int resolve_content_path(AVFormatContext *s, const char *url, int *max_url_size, xmlNodePtr *baseurl_nodes, int n_baseurl_nodes)
+{
char *tmp_str = NULL;
char *path = NULL;
char *mpdName = NULL;
char *root_url = NULL;
char *text = NULL;
char *tmp = NULL;
-
int isRootHttp = 0;
char token ='/';
int start = 0;
continue;
}
text = xmlNodeGetContent(baseurl_nodes[i]);
- if (text) {
+ if (text && !av_strstart(text, "/", NULL)) {
memset(tmp_str, 0, strlen(tmp_str));
if (!ishttp(text) && isRootHttp) {
av_strlcpy(tmp_str, root_url, size + 1);
}
start = (text[0] == token);
+ if (start && av_stristr(tmp_str, text)) {
+ char *p = tmp_str;
+ if (!av_strncasecmp(tmp_str, "http://", 7)) {
+ p += 7;
+ } else if (!av_strncasecmp(tmp_str, "https://", 8)) {
+ p += 8;
+ }
+ p = strchr(p, '/');
+ memset(p + 1, 0, strlen(p));
+ }
av_strlcat(tmp_str, text + start, tmp_max_url_size);
xmlNodeSetContent(baseurl_nodes[i], tmp_str);
updated = 1;
ret = AVERROR(ENOMEM);
goto end;
}
+ rep->parent = s;
representation_segmenttemplate_node = find_child_node_by_name(representation_node, "SegmentTemplate");
representation_baseurl_node = find_child_node_by_name(representation_node, "BaseURL");
representation_segmentlist_node = find_child_node_by_name(representation_node, "SegmentList");
xmlFree(timescale_val);
}
if (startnumber_val) {
- rep->first_seq_no = (int64_t) strtoll(startnumber_val, NULL, 10);
+ rep->start_number = rep->first_seq_no = (int64_t) strtoll(startnumber_val, NULL, 10);
av_log(s, AV_LOG_TRACE, "rep->first_seq_no = [%"PRId64"]\n", rep->first_seq_no);
xmlFree(startnumber_val);
}
duration_val = get_val_from_nodes_tab(segmentlists_tab, 3, "duration");
timescale_val = get_val_from_nodes_tab(segmentlists_tab, 3, "timescale");
+ startnumber_val = get_val_from_nodes_tab(segmentlists_tab, 3, "startNumber");
if (duration_val) {
rep->fragment_duration = (int64_t) strtoll(duration_val, NULL, 10);
av_log(s, AV_LOG_TRACE, "rep->fragment_duration = [%"PRId64"]\n", rep->fragment_duration);
av_log(s, AV_LOG_TRACE, "rep->fragment_timescale = [%"PRId64"]\n", rep->fragment_timescale);
xmlFree(timescale_val);
}
+ if (startnumber_val) {
+ rep->start_number = rep->first_seq_no = (int64_t) strtoll(startnumber_val, NULL, 10);
+ av_log(s, AV_LOG_TRACE, "rep->first_seq_no = [%"PRId64"]\n", rep->first_seq_no);
+ xmlFree(startnumber_val);
+ }
+
fragmenturl_node = xmlFirstElementChild(representation_segmentlist_node);
while (fragmenturl_node) {
ret = parse_manifest_segmenturlnode(s, rep, fragmenturl_node,
}
node = xmlNextElementSibling(node);
xmlFree(val);
+ val = NULL;
}
return 0;
}
} else {
LIBXML_TEST_VERSION
- doc = xmlReadMemory(buffer, filesize, c->base_url, NULL, 0);
+ doc = xmlReadMemory(buffer, filesize, c->base_url, NULL, 0);
root_element = xmlDocGetRootElement(doc);
node = root_element;
static int refresh_manifest(AVFormatContext *s)
{
-
int ret = 0, i;
DASHContext *c = s->priv_data;
-
// save current context
int n_videos = c->n_videos;
struct representation **videos = c->videos;
goto fail;
pls->ctx->flags = AVFMT_FLAG_CUSTOM_IO;
- pls->ctx->probesize = 1024 * 4;
- pls->ctx->max_analyze_duration = 4 * AV_TIME_BASE;
+ pls->ctx->probesize = s->probesize > 0 ? s->probesize : 1024 * 4;
+ pls->ctx->max_analyze_duration = s->max_analyze_duration > 0 ? s->max_analyze_duration : 4 * AV_TIME_BASE;
ret = av_probe_input_buffer(&pls->pb, &in_fmt, "", NULL, 0, 0);
if (ret < 0) {
av_log(s, AV_LOG_ERROR, "Error when loading first fragment, playlist %d\n", (int)pls->rep_idx);
pls->ctx->streams[i]->r_frame_rate = pls->framerate;
}
#endif
-
ret = avformat_find_stream_info(pls->ctx, NULL);
if (ret < 0)
goto fail;
static int dash_read_header(AVFormatContext *s)
{
DASHContext *c = s->priv_data;
+ struct representation *rep;
int ret = 0;
int stream_index = 0;
int i;
/* Open the demuxer for video and audio components if available */
for (i = 0; i < c->n_videos; i++) {
- struct representation *cur_video = c->videos[i];
+ rep = c->videos[i];
if (i > 0 && c->is_init_section_common_video) {
- ret = copy_init_section(cur_video,c->videos[0]);
+ ret = copy_init_section(rep, c->videos[0]);
if (ret < 0)
goto fail;
}
- ret = open_demux_for_component(s, cur_video);
+ ret = open_demux_for_component(s, rep);
if (ret)
goto fail;
- cur_video->stream_index = stream_index;
+ rep->stream_index = stream_index;
++stream_index;
}
c->is_init_section_common_audio = is_common_init_section_exist(c->audios, c->n_audios);
for (i = 0; i < c->n_audios; i++) {
- struct representation *cur_audio = c->audios[i];
+ rep = c->audios[i];
if (i > 0 && c->is_init_section_common_audio) {
- ret = copy_init_section(cur_audio,c->audios[0]);
+ ret = copy_init_section(rep, c->audios[0]);
if (ret < 0)
goto fail;
}
- ret = open_demux_for_component(s, cur_audio);
+ ret = open_demux_for_component(s, rep);
if (ret)
goto fail;
- cur_audio->stream_index = stream_index;
+ rep->stream_index = stream_index;
++stream_index;
}
c->is_init_section_common_audio = is_common_init_section_exist(c->subtitles, c->n_subtitles);
for (i = 0; i < c->n_subtitles; i++) {
- struct representation *cur_subtitle = c->subtitles[i];
+ rep = c->subtitles[i];
if (i > 0 && c->is_init_section_common_audio) {
- ret = copy_init_section(cur_subtitle,c->subtitles[0]);
+ ret = copy_init_section(rep, c->subtitles[0]);
if (ret < 0)
goto fail;
}
- ret = open_demux_for_component(s, cur_subtitle);
+ ret = open_demux_for_component(s, rep);
if (ret)
goto fail;
- cur_subtitle->stream_index = stream_index;
+ rep->stream_index = stream_index;
++stream_index;
}
-
if (!stream_index) {
ret = AVERROR_INVALIDDATA;
goto fail;
}
for (i = 0; i < c->n_videos; i++) {
- struct representation *pls = c->videos[i];
-
- av_program_add_stream_index(s, 0, pls->stream_index);
- pls->assoc_stream = s->streams[pls->stream_index];
- if (pls->bandwidth > 0)
- av_dict_set_int(&pls->assoc_stream->metadata, "variant_bitrate", pls->bandwidth, 0);
- if (pls->id[0])
- av_dict_set(&pls->assoc_stream->metadata, "id", pls->id, 0);
+ rep = c->videos[i];
+ av_program_add_stream_index(s, 0, rep->stream_index);
+ rep->assoc_stream = s->streams[rep->stream_index];
+ if (rep->bandwidth > 0)
+ av_dict_set_int(&rep->assoc_stream->metadata, "variant_bitrate", rep->bandwidth, 0);
+ if (rep->id[0])
+ av_dict_set(&rep->assoc_stream->metadata, "id", rep->id, 0);
}
for (i = 0; i < c->n_audios; i++) {
- struct representation *pls = c->audios[i];
-
- av_program_add_stream_index(s, 0, pls->stream_index);
- pls->assoc_stream = s->streams[pls->stream_index];
- if (pls->bandwidth > 0)
- av_dict_set_int(&pls->assoc_stream->metadata, "variant_bitrate", pls->bandwidth, 0);
- if (pls->id[0])
- av_dict_set(&pls->assoc_stream->metadata, "id", pls->id, 0);
+ rep = c->audios[i];
+ av_program_add_stream_index(s, 0, rep->stream_index);
+ rep->assoc_stream = s->streams[rep->stream_index];
+ if (rep->bandwidth > 0)
+ av_dict_set_int(&rep->assoc_stream->metadata, "variant_bitrate", rep->bandwidth, 0);
+ if (rep->id[0])
+ av_dict_set(&rep->assoc_stream->metadata, "id", rep->id, 0);
}
for (i = 0; i < c->n_subtitles; i++) {
- struct representation *pls = c->subtitles[i];
- av_program_add_stream_index(s, 0, pls->stream_index);
- pls->assoc_stream = s->streams[pls->stream_index];
- if (pls->id[0])
- av_dict_set(&pls->assoc_stream->metadata, "id", pls->id, 0);
+ rep = c->subtitles[i];
+ av_program_add_stream_index(s, 0, rep->stream_index);
+ rep->assoc_stream = s->streams[rep->stream_index];
+ if (rep->id[0])
+ av_dict_set(&rep->assoc_stream->metadata, "id", rep->id, 0);
}
-
}
return 0;
for (i = 0; i < n; i++) {
struct representation *pls = p[i];
-
int needed = !pls->assoc_stream || pls->assoc_stream->discard < AVDISCARD_ALL;
+
if (needed && !pls->ctx) {
pls->cur_seg_offset = 0;
pls->init_sec_buf_read_offset = 0;
av_log(s, AV_LOG_INFO, "Now receiving stream_index %d\n", pls->stream_index);
} else if (!needed && pls->ctx) {
close_demux_for_component(pls);
- if (pls->input)
- ff_format_io_close(pls->parent, &pls->input);
+ ff_format_io_close(pls->parent, &pls->input);
av_log(s, AV_LOG_INFO, "No longer receiving stream_index %d\n", pls->stream_index);
}
}
int ret = 0, i;
int64_t mints = 0;
struct representation *cur = NULL;
+ struct representation *rep = NULL;
recheck_discard_flags(s, c->videos, c->n_videos);
recheck_discard_flags(s, c->audios, c->n_audios);
recheck_discard_flags(s, c->subtitles, c->n_subtitles);
for (i = 0; i < c->n_videos; i++) {
- struct representation *pls = c->videos[i];
- if (!pls->ctx)
+ rep = c->videos[i];
+ if (!rep->ctx)
continue;
- if (!cur || pls->cur_timestamp < mints) {
- cur = pls;
- mints = pls->cur_timestamp;
+ if (!cur || rep->cur_timestamp < mints) {
+ cur = rep;
+ mints = rep->cur_timestamp;
}
}
for (i = 0; i < c->n_audios; i++) {
- struct representation *pls = c->audios[i];
- if (!pls->ctx)
+ rep = c->audios[i];
+ if (!rep->ctx)
continue;
- if (!cur || pls->cur_timestamp < mints) {
- cur = pls;
- mints = pls->cur_timestamp;
+ if (!cur || rep->cur_timestamp < mints) {
+ cur = rep;
+ mints = rep->cur_timestamp;
}
}
for (i = 0; i < c->n_subtitles; i++) {
- struct representation *pls = c->subtitles[i];
- if (!pls->ctx)
+ rep = c->subtitles[i];
+ if (!rep->ctx)
continue;
- if (!cur || pls->cur_timestamp < mints) {
- cur = pls;
- mints = pls->cur_timestamp;
+ if (!cur || rep->cur_timestamp < mints) {
+ cur = rep;
+ mints = rep->cur_timestamp;
}
}
if (cur->is_restart_needed) {
cur->cur_seg_offset = 0;
cur->init_sec_buf_read_offset = 0;
- if (cur->input)
- ff_format_io_close(cur->parent, &cur->input);
+ ff_format_io_close(cur->parent, &cur->input);
ret = reopen_demux_for_component(s, cur);
cur->is_restart_needed = 0;
}
DASHContext *c = s->priv_data;
free_audio_list(c);
free_video_list(c);
-
av_dict_free(&c->avio_opts);
av_freep(&c->base_url);
return 0;
return av_seek_frame(pls->ctx, -1, seek_pos_msec * 1000, flags);
}
- if (pls->input)
- ff_format_io_close(pls->parent, &pls->input);
+ ff_format_io_close(pls->parent, &pls->input);
// find the nearest fragment
if (pls->n_timelines > 0 && pls->fragment_timescale > 0) {
projects / ffmpeg / blobdiff