PeerStreamer

    AVPacket pkt;

    int stream_offset;

    int start_seq_no;

    int n_segments;

    struct segment **segments;

};

typedef struct AppleHTTPContext {

    int n_variants;

    struct variant **variants;

    int cur_seq_no;

        goto fail;

    }

        free_segment_list(var);

    while (!in->eof_reached) {

        read_chomp_line(in, line, sizeof(line));

        if (av_strstart(line, "#EXT-X-STREAM-INF:", &ptr)) {

                               &info);

            bandwidth = atoi(info.bandwidth);

        } else if (av_strstart(line, "#EXT-X-TARGETDURATION:", &ptr)) {

        } else if (av_strstart(line, "#EXT-X-MEDIA-SEQUENCE:", &ptr)) {

            if (!var) {

                var = new_variant(c, 0, url, NULL);

            }

            var->start_seq_no = atoi(ptr);

        } else if (av_strstart(line, "#EXT-X-ENDLIST", &ptr)) {

        } else if (av_strstart(line, "#EXTINF:", &ptr)) {

            is_segment = 1;

            duration   = atoi(ptr);

    /* If this isn't a live stream, calculate the total duration of the

     * stream. */

        int64_t duration = 0;

        for (i = 0; i < c->variants[0]->n_segments; i++)

            duration += c->variants[0]->segments[i]->duration;

    c->cur_seq_no = c->max_start_seq;

    /* If this is a live stream with more than 3 segments, start at the

     * third last segment. */

        c->cur_seq_no = c->min_end_seq - 2;

    return 0;

        return 0;

    }

    if (c->cur_seq_no - var->start_seq_no >= var->n_segments)

    ret = avio_open(&var->pb,

                    var->segments[c->cur_seq_no - var->start_seq_no]->url,

                    URL_RDONLY);

        } else if (!var->pb && var->needed) {

            if (first)

                av_log(s, AV_LOG_DEBUG, "Opening variant stream %d\n", i);

                if ((ret = parse_playlist(c, var->url, var, NULL)) < 0)

                    return ret;

            ret = open_variant(c, var, first);

    first = 0;

    c->cur_seq_no++;

reload:

        /* If this is a live stream and target_duration has elapsed since

         * the last playlist reload, reload the variant playlists now. */

        int64_t now = av_gettime();

            c->max_start_seq = 0;

            c->min_end_seq   = INT_MAX;

            for (i = 0; i < c->n_variants; i++) {

        goto start;

    /* We've reached the end of the playlists - return eof if this is a

     * non-live stream, wait until the next playlist reload if it is live. */

        return AVERROR_EOF;

        if (url_interrupt_cb())

            return AVERROR_EXIT;

        usleep(100*1000);

    int i;

    struct variant *var = c->variants[0];

        return AVERROR(ENOSYS);

    /* Reset the variants */