Commit 8ce8dcc8 authored by Jean-Paul Saman's avatar Jean-Paul Saman

stream_filter/httplive.c: solve gap in segment sequence numbers.

After rewriting to use stream_* API gaps in segment sequence numbers
where detected. Solving this issue fixes live playback which was broken
since the rewrite to use the stream_* API.
parent 3ffd6e0f
...@@ -136,7 +136,7 @@ static int Control(stream_t *, int i_query, va_list); ...@@ -136,7 +136,7 @@ static int Control(stream_t *, int i_query, va_list);
static ssize_t read_M3U8(stream_t *s, vlc_url_t *url, uint8_t **buffer); static ssize_t read_M3U8(stream_t *s, vlc_url_t *url, uint8_t **buffer);
static ssize_t ReadM3U8(stream_t *s, uint8_t **buffer); static ssize_t ReadM3U8(stream_t *s, uint8_t **buffer);
static char *ReadLine(uint8_t *buffer, uint8_t **remain, size_t len); static char *ReadLine(uint8_t *buffer, uint8_t **pos, size_t len);
static int hls_Download(stream_t *s, segment_t *segment); static int hls_Download(stream_t *s, segment_t *segment);
...@@ -359,6 +359,7 @@ static int ChooseSegment(stream_t *s, int current) ...@@ -359,6 +359,7 @@ static int ChooseSegment(stream_t *s, int current)
*/ */
int wanted = 0; int wanted = 0;
int duration = 0; int duration = 0;
int sequence = 0;
int count = vlc_array_count(hls->segments); int count = vlc_array_count(hls->segments);
int i = p_sys->b_live ? count - 1 : 0; int i = p_sys->b_live ? count - 1 : 0;
...@@ -378,6 +379,7 @@ static int ChooseSegment(stream_t *s, int current) ...@@ -378,6 +379,7 @@ static int ChooseSegment(stream_t *s, int current)
{ {
/* Start point found */ /* Start point found */
wanted = p_sys->b_live ? i : 0; wanted = p_sys->b_live ? i : 0;
sequence = segment->sequence;
break; break;
} }
...@@ -387,7 +389,7 @@ static int ChooseSegment(stream_t *s, int current) ...@@ -387,7 +389,7 @@ static int ChooseSegment(stream_t *s, int current)
i++; i++;
} }
msg_Info(s, "Choose segment %d/%d", wanted, count); msg_Info(s, "Choose segment %d/%d (sequence=%d)", wanted, count, sequence);
return wanted; return wanted;
} }
...@@ -612,7 +614,8 @@ static int parse_MediaSequence(stream_t *s, hls_stream_t *hls, char *p_read) ...@@ -612,7 +614,8 @@ static int parse_MediaSequence(stream_t *s, hls_stream_t *hls, char *p_read)
} }
if (hls->sequence > 0) if (hls->sequence > 0)
msg_Err(s, "EXT-X-MEDIA-SEQUENCE already present in playlist"); msg_Err(s, "EXT-X-MEDIA-SEQUENCE already present in playlist (new=%d, old=%d)",
sequence, hls->sequence);
hls->sequence = sequence; hls->sequence = sequence;
return VLC_SUCCESS; return VLC_SUCCESS;
...@@ -746,6 +749,7 @@ static int parse_M3U8(stream_t *s, vlc_array_t *streams, uint8_t *buffer, ssize_ ...@@ -746,6 +749,7 @@ static int parse_M3U8(stream_t *s, vlc_array_t *streams, uint8_t *buffer, ssize_
char *line = ReadLine(p_begin, &p_read, p_end - p_begin); char *line = ReadLine(p_begin, &p_read, p_end - p_begin);
if (line == NULL) if (line == NULL)
return VLC_ENOMEM; return VLC_ENOMEM;
p_begin = p_read;
if (strncmp(line, "#EXTM3U", 7) != 0) if (strncmp(line, "#EXTM3U", 7) != 0)
{ {
...@@ -782,27 +786,21 @@ static int parse_M3U8(stream_t *s, vlc_array_t *streams, uint8_t *buffer, ssize_ ...@@ -782,27 +786,21 @@ static int parse_M3U8(stream_t *s, vlc_array_t *streams, uint8_t *buffer, ssize_
/* Is it a meta index file ? */ /* Is it a meta index file ? */
bool b_meta = (strstr((const char *)buffer, "#EXT-X-STREAM-INF") == NULL) ? false : true; bool b_meta = (strstr((const char *)buffer, "#EXT-X-STREAM-INF") == NULL) ? false : true;
int err = VLC_SUCCESS;
if (b_meta) if (b_meta)
{
msg_Info(s, "Meta playlist"); msg_Info(s, "Meta playlist");
else
msg_Info(s, "%s Playlist HLS protocol version: %d", p_sys->b_live ? "Live": "VOD", version);
/* */ /* M3U8 Meta Index file */
int err = VLC_SUCCESS; do {
do
{
/* Next line */ /* Next line */
p_begin = p_read;
line = ReadLine(p_begin, &p_read, p_end - p_begin); line = ReadLine(p_begin, &p_read, p_end - p_begin);
if (line == NULL) if (line == NULL)
break; break;
/* */
p_begin = p_read; p_begin = p_read;
/* M3U8 Meta Index file */ /* */
if (b_meta)
{
if (strncmp(line, "#EXT-X-STREAM-INF", 17) == 0) if (strncmp(line, "#EXT-X-STREAM-INF", 17) == 0)
{ {
p_sys->b_meta = true; p_sys->b_meta = true;
...@@ -834,38 +832,59 @@ static int parse_M3U8(stream_t *s, vlc_array_t *streams, uint8_t *buffer, ssize_ ...@@ -834,38 +832,59 @@ static int parse_M3U8(stream_t *s, vlc_array_t *streams, uint8_t *buffer, ssize_
hls->size = hls_GetStreamSize(hls); /* Stream size (approximate) */ hls->size = hls_GetStreamSize(hls); /* Stream size (approximate) */
} }
} }
p_begin = p_read;
} }
free(line);
line = NULL;
if (p_begin >= p_end)
break;
} while ((err == VLC_SUCCESS) && vlc_object_alive(s));
} }
else else
{ {
hls_stream_t *hls = hls_GetLast(streams); msg_Info(s, "%s Playlist HLS protocol version: %d", p_sys->b_live ? "Live": "VOD", version);
if (hls == NULL)
hls_stream_t *hls = NULL;
if (p_sys->b_meta)
hls = hls_GetLast(streams);
else
{ {
/* No Meta playlist used */ /* No Meta playlist used */
hls = hls_New(streams, 0, -1, NULL); hls = hls_New(streams, 0, -1, NULL);
if (hls == NULL) if (hls)
{ {
msg_Err(s, "No HLS structure created");
err = VLC_ENOMEM;
break;
}
/* Get TARGET-DURATION first */ /* Get TARGET-DURATION first */
p = (uint8_t *)strstr((const char *)buffer, "#EXT-X-TARGETDURATION:"); p = (uint8_t *)strstr((const char *)buffer, "#EXT-X-TARGETDURATION:");
if (p) if (p)
{ {
uint8_t *p_rest = NULL; uint8_t *p_rest = NULL;
char *psz_duration = ReadLine(p, &p_rest, p_end - p); char *psz_duration = ReadLine(p, &p_rest, p_end - p);
if (psz_duration) if (psz_duration == NULL)
{ return VLC_EGENERIC;
err = parse_TargetDuration(s, hls, psz_duration); err = parse_TargetDuration(s, hls, psz_duration);
free(psz_duration); free(psz_duration);
p = NULL; p = NULL;
} }
}
/* Store version */
hls->version = version; hls->version = version;
} }
else return VLC_ENOMEM;
}
assert(hls);
/* */
do
{
/* Next line */
line = ReadLine(p_begin, &p_read, p_end - p_begin);
if (line == NULL)
break;
p_begin = p_read;
if (strncmp(line, "#EXTINF", 7) == 0) if (strncmp(line, "#EXTINF", 7) == 0)
{ {
...@@ -895,7 +914,6 @@ static int parse_M3U8(stream_t *s, vlc_array_t *streams, uint8_t *buffer, ssize_ ...@@ -895,7 +914,6 @@ static int parse_M3U8(stream_t *s, vlc_array_t *streams, uint8_t *buffer, ssize_
err = parse_Version(s, hls, line); err = parse_Version(s, hls, line);
else if (strncmp(line, "#EXT-X-ENDLIST", 14) == 0) else if (strncmp(line, "#EXT-X-ENDLIST", 14) == 0)
err = parse_EndList(s, hls); err = parse_EndList(s, hls);
}
free(line); free(line);
line = NULL; line = NULL;
...@@ -906,6 +924,7 @@ static int parse_M3U8(stream_t *s, vlc_array_t *streams, uint8_t *buffer, ssize_ ...@@ -906,6 +924,7 @@ static int parse_M3U8(stream_t *s, vlc_array_t *streams, uint8_t *buffer, ssize_
} while ((err == VLC_SUCCESS) && vlc_object_alive(s)); } while ((err == VLC_SUCCESS) && vlc_object_alive(s));
free(line); free(line);
}
return err; return err;
} }
...@@ -949,11 +968,18 @@ static int hls_UpdatePlaylist(stream_t *s, hls_stream_t *hls_new, hls_stream_t * ...@@ -949,11 +968,18 @@ static int hls_UpdatePlaylist(stream_t *s, hls_stream_t *hls_new, hls_stream_t *
(p->duration != segment->duration) || (p->duration != segment->duration) ||
(strcmp(p->url.psz_path, segment->url.psz_path) != 0)) (strcmp(p->url.psz_path, segment->url.psz_path) != 0))
{ {
msg_Err(s, "existing segment found with different content"); msg_Err(s, "existing segment found with different content - resetting");
msg_Err(s, "- sequence: new=%d, old=%d", p->sequence, segment->sequence); msg_Err(s, "- sequence: new=%d, old=%d", p->sequence, segment->sequence);
msg_Err(s, "- duration: new=%d, old=%d", p->duration, segment->duration); msg_Err(s, "- duration: new=%d, old=%d", p->duration, segment->duration);
msg_Err(s, "- file: new=%s", p->url.psz_path); msg_Err(s, "- file: new=%s", p->url.psz_path);
msg_Err(s, " old=%s", segment->url.psz_path); msg_Err(s, " old=%s", segment->url.psz_path);
/* Resetting content */
segment->sequence = p->sequence;
segment->duration = p->duration;
vlc_UrlClean(&segment->url);
vlc_UrlParse(&segment->url, p->url.psz_buffer, 0);
segment_Free(p);
} }
} }
else else
...@@ -1398,6 +1424,7 @@ static ssize_t read_M3U8(stream_t *s, vlc_url_t *url, uint8_t **buffer) ...@@ -1398,6 +1424,7 @@ static ssize_t read_M3U8(stream_t *s, vlc_url_t *url, uint8_t **buffer)
} while (vlc_object_alive(s)); } while (vlc_object_alive(s));
stream_Delete(p_m3u8); stream_Delete(p_m3u8);
(*buffer)[curlen-1] = '\0';
return size; return size;
} }
...@@ -1432,7 +1459,7 @@ static ssize_t ReadM3U8(stream_t *s, uint8_t **buffer) ...@@ -1432,7 +1459,7 @@ static ssize_t ReadM3U8(stream_t *s, uint8_t **buffer)
return size; return size;
} }
static char *ReadLine(uint8_t *buffer, uint8_t **remain, size_t len) static char *ReadLine(uint8_t *buffer, uint8_t **pos, size_t len)
{ {
assert(buffer); assert(buffer);
...@@ -1443,17 +1470,22 @@ static char *ReadLine(uint8_t *buffer, uint8_t **remain, size_t len) ...@@ -1443,17 +1470,22 @@ static char *ReadLine(uint8_t *buffer, uint8_t **remain, size_t len)
while (p < end) while (p < end)
{ {
if (*p == '\n') if ((*p == '\n') || (*p == '\0'))
break; break;
p++; p++;
} }
/* copy line excluding \n */ /* copy line excluding \n or \0 */
line = strndup((char *)begin, p - begin); line = strndup((char *)begin, p - begin);
if (*p == '\0')
*pos = end;
else
{
/* next pass start after \n */ /* next pass start after \n */
p++; p++;
*remain = p; *pos = p;
}
return line; return line;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment