Function read_data_continuous

libavformat/hls.c:1651–1764

}

static int read_data_continuous(void *opaque, uint8_t *buf, int buf_size)
{
    struct playlist *v = opaque;
    HLSContext *c = v->parent->priv_data;
    int ret;
    int just_opened = 0;
    int segment_retries = 0;
    struct segment *seg;

    if (c->http_persistent && v->input_read_done) {
        ret = reload_playlist(v, c);
        if (ret < 0)
            return ret;
    }

    v->input_read_done = 0;

restart:
    ret = reload_playlist(v, c);
    if (ret < 0)
        return ret;

    seg = current_segment(v);

    if (!v->input || (c->http_persistent && v->input_read_done)) {
        /* load/update Media Initialization Section, if any */
        ret = update_init_section(v, seg);
        if (ret)
            return ret;

        if (c->http_multiple == 1 && v->input_next_requested) {
            FFSWAP(AVIOContext *, v->input, v->input_next);
            v->cur_seg_offset = 0;
            v->input_next_requested = 0;
            ret = 0;
        } else {
            ret = open_input(c, v, seg, &v->input);
        }
        if (ret < 0) {
            if (ff_check_interrupt(c->interrupt_callback))
                return AVERROR_EXIT;
            av_log(v->parent, AV_LOG_WARNING, "Failed to open segment %"PRId64" of playlist %d\n",
                   v->cur_seq_no,
                   v->index);
            if (segment_retries >= c->seg_max_retry) {
                av_log(v->parent, AV_LOG_WARNING, "Segment %"PRId64" of playlist %d failed too many times, skipping\n",
                       v->cur_seq_no,
                       v->index);
                v->cur_seq_no++;
                segment_retries = 0;
            } else {
                segment_retries++;
            }
            goto restart;
        }
        segment_retries = 0;
        just_opened = 1;
    }