Method read_thread

src/server/ffplay/stream_handler.cpp:562–1009

this thread gets the stream from the disk or the network */

/* this thread gets the stream from the disk or the network */
int StreamHandler::read_thread(void *arg) {
#ifdef PROFILING_SH
	if (!debugfile.is_open()) {
		debugfile.open("profiling_read_thread.txt");
	}
#endif

    VideoState *is = (VideoState*) arg;
	AVFormatContext* ic = is->ic;
	
    int err, i, ret;
    int st_index[AVMEDIA_TYPE_NB];
    AVPacket pkt1, *pkt = &pkt1;
    int64_t stream_start_time;
    int pkt_in_play_range = 0;
    AVDictionaryEntry *t;
    SDL_mutex *wait_mutex = SDL_CreateMutex();
    int scan_all_pmts_set = 0;
    int64_t pkt_ts;

    if (!wait_mutex) {
        av_log(NULL, AV_LOG_FATAL, "SDL_CreateMutex(): %s\n", SDL_GetError());
        ret = AVERROR(ENOMEM);
        goto fail;
    }

    memset(st_index, -1, sizeof(st_index));
    is->last_video_stream = is->video_stream = -1;
    is->last_audio_stream = is->audio_stream = -1;
    is->last_subtitle_stream = is->subtitle_stream = -1;
    is->eof = 0;

    if (ic == 0) {
		ic = avformat_alloc_context();
		if (!ic) {
			av_log(NULL, AV_LOG_FATAL, "Could not allocate context.\n");
			ret = AVERROR(ENOMEM);
			goto fail;
		}
		
		ic->interrupt_callback.callback = decode_interrupt_cb;
		ic->interrupt_callback.opaque = is;
		is->ic = ic;
	}
	
    if (!av_dict_get(format_opts, "scan_all_pmts", NULL, AV_DICT_MATCH_CASE)) {
        av_dict_set(&format_opts, "scan_all_pmts", "1", AV_DICT_DONT_OVERWRITE);
        scan_all_pmts_set = 1;
    }
	
	// Open the input file or stream.
    err = avformat_open_input(&ic, is->filename, is->iformat, &format_opts);
    if (err < 0) {
        print_error(is->filename, err);
        ret = -1;
        goto fail;
    }