ijkplayer 读线程

ijkplayer初始化流程中的结尾提到,stream_open()会创建读线程和视频渲染线程,下面是stream_open()的主要代码

static VideoState *stream_open(FFPlayer *ffp, const char *filename, AVInputFormat *iformat)
{
    ...
    /* start video display */
    if (frame_queue_init(&is->pictq, &is->videoq, ffp->pictq_size, 1) < 0)
        goto fail;
    if (frame_queue_init(&is->subpq, &is->subtitleq, SUBPICTURE_QUEUE_SIZE, 0) < 0)
        goto fail;
    if (frame_queue_init(&is->sampq, &is->audioq, SAMPLE_QUEUE_SIZE, 1) < 0)
        goto fail;

    if (packet_queue_init(&is->videoq) < 0 ||
        packet_queue_init(&is->audioq) < 0 ||
        packet_queue_init(&is->subtitleq) < 0)
        goto fail;
    ...
    is->video_refresh_tid = SDL_CreateThreadEx(&is->_video_refresh_tid, video_refresh_thread, ffp, "ff_vout");
     ...
    is->read_tid = SDL_CreateThreadEx(&is->_read_tid, read_thread, ffp, "ff_read");
    ...
}

可以看出ff_ffplayer.c/stream_open()函数主要干了四件事:

  1. 调用frame_queue_init()创建两个队列pictq、sampq (其实是三个,还有subq,但是ijk好像没有启用字幕所以以后我们都只考虑没有字幕的情况),这两个队列分别用于存储解码后的视音频包

  2. 调用packet_queue_ini()和上一步类似,创建两个队列videoq、audioq,分别用于存储解封装但为解码的视音频包

  3. SDL_CreateThreadEx(..., video_refresh_thread, ...)创建视频渲染线程

4. SDL_CreateThreadEx(..., read_thread, ...)创建读线程

下面主要将读线程里的操作,读线程的主要代码如下

/* this thread gets the stream from the disk or the network */
static int read_thread(void *arg)
{
    ...
    ic = avformat_alloc_context();
    ...
    err = avformat_open_input(&ic, is->filename, is->iformat, &ffp->format_opts);
   ...
    err = avformat_find_stream_info(ic, opts);
    ...
    /* open the streams */
    if (st_index[AVMEDIA_TYPE_AUDIO] >= 0) {
        stream_component_open(ffp, st_index[AVMEDIA_TYPE_AUDIO]);
    }

    ret = -1;
    if (st_index[AVMEDIA_TYPE_VIDEO] >= 0) {
        ret = stream_component_open(ffp, st_index[AVMEDIA_TYPE_VIDEO]);
    }
    if (is->show_mode == SHOW_MODE_NONE)
        is->show_mode = ret >= 0 ? SHOW_MODE_VIDEO : SHOW_MODE_RDFT;

    if (st_index[AVMEDIA_TYPE_SUBTITLE] >= 0) {
        stream_component_open(ffp, st_index[AVMEDIA_TYPE_SUBTITLE]);
    }
    ...
    ffp->prepared = true;
    ffp_notify_msg1(ffp, FFP_MSG_PREPARED);
    ...
    for (;;) {
        ...
        ret = av_read_frame(ic, pkt);
        ...
        if (pkt->stream_index == is->audio_stream && pkt_in_play_range) {
            packet_queue_put(&is->audioq, pkt);
        } else if (pkt->stream_index == is->video_stream && pkt_in_play_range
                   && !(is->video_st && (is->video_st->disposition & AV_DISPOSITION_ATTACHED_PIC))) {
            packet_queue_put(&is->videoq, pkt);
        } else if (pkt->stream_index == is->subtitle_stream && pkt_in_play_range) {
            packet_queue_put(&is->subtitleq, pkt);
        } else {
            av_packet_unref(pkt);
        }
        ...
    }
    ...
}

读线程又做了如下六件事:
1). avformat_alloc_context(),创建AVFormatContext结构体,用来保存输入输出格式等信息
2). avformat_open_input(),打开文件,主要是探测协议类型,如果是网络文件则创建网络链接等
3). avformat_find_stream_info(),探测媒体类型,可得到当前文件的封装格式,音视频编码参数等信息
4). stream_component_open(),这步做的事情比较多稍后重点描述
5). av_read_frame(),从网络或者硬盘读包
6). packet_queue_put(),将音视频数据分别送入相应的queue中(也就是前面说的videoq、audioq)

接下来着重描述一下stream_component_open()

/* open a given stream. Return 0 if OK */
static int stream_component_open(FFPlayer *ffp, int stream_index)
{
    ...
    codec = avcodec_find_decoder(avctx->codec_id);
    switch (avctx->codec_type) {
        case AVMEDIA_TYPE_AUDIO   : is->last_audio_stream    = stream_index; forced_codec_name = ffp->audio_codec_name; break;
        case AVMEDIA_TYPE_SUBTITLE: is->last_subtitle_stream = stream_index; forced_codec_name = ffp->subtitle_codec_name; break;
        case AVMEDIA_TYPE_VIDEO   : is->last_video_stream    = stream_index; forced_codec_name = ffp->video_codec_name; break;
        default: break;
    }
    ...
    if ((ret = avcodec_open2(avctx, codec, &opts)) < 0) {
        goto fail;
    }
    ...
    switch (avctx->codec_type) {
    case AVMEDIA_TYPE_AUDIO:
        ...
        /* prepare audio output */
        if ((ret = audio_open(ffp, channel_layout, nb_channels, sample_rate, &is->audio_tgt)) < 0)
            goto fail;
        ...
        decoder_init(&is->auddec, avctx, &is->audioq, is->continue_read_thread);
        ...
        if ((ret = decoder_start(&is->auddec, audio_thread, ffp, "ff_audio_dec")) < 0)
            goto out;
        SDL_AoutPauseAudio(ffp->aout, 0);
        break;
    case AVMEDIA_TYPE_VIDEO:
        ...
        decoder_init(&is->viddec, avctx, &is->videoq, is->continue_read_thread);
        ffp->node_vdec = ffpipeline_open_video_decoder(ffp->pipeline, ffp);
        ...
        if ((ret = decoder_start(&is->viddec, video_thread, ffp, "ff_video_dec")) < 0)
            goto out;
        ...
        break;
    ...
    default:
        break;
    }
    goto out;
fail:
    avcodec_free_context(&avctx);
out:
    av_dict_free(&opts);

    return ret;
}

该函数主要有以下步骤:
a. 调用avcodec_find_decoder()函数查找ffmepg里的解码器,解码器的注册在ijkplayer初始化流程中的avcodec_register_all()完成
b. 调用avcodec_open2()函数用于初始化一个视音频编解码器的AVCodecContext
c. 进入switch,分视频流和音频流的情况

  • case AVMEDIA_TYPE_AUDIO:
    a). 调用audio_open()函数,该函数里面的调用路径为SDL_AoutOpenAudio() ->> aout->open_audio(),这个open_audio()在初始化的时候赋值了,地方就在ff_ffpipeline_android.c/ func_open_audio_output(),这个函数选好输出音频的工具后就会给open_audio赋值,最后调用ijksdl_aout_android_audiotrack.c/aout_open_audio_n()(如果用的是audiotrack),aout_open_audio_n()函数里又会调用SDL_CreateThreadEx(..., aout_thread, aout, ...)创建音频输出线程
    b). 接着调用了decoder_init()函数,里面有d->queue = queue这一步是将ffplayer的audioq赋值给解码器中的queue队列,用于解码使用
    c). 最后调用decode_start()函数,里面执行SDL_CreateThreadEx()创建音频解码线程
  • case AVMEDIA_TYPE_VIDEO:
    不同于音频,这里没有类似audio_open()函数,因为视频输出线程在本节前面提到的stream_open()里创建
    a). 调用decoder_init()函数,和音频一样,d->queue = queue,将ffplayer的videoq赋值给解码器中的queue队列,用于解码使用
    b). 调用ffpipeline_open_video_decoder()函数,里面会调用pipeline->func_open_video_decoder(),这里的func_open_video_decoder()在ijk初始化时赋值,赋值地方和前面讲的ff_ffpipeline_android.c/ func_open_audio_output()的赋值地方一样,都在ijkplayer_android.c/ffpipeline_create_from_android()函数里,pipeline->func_open_video_decoder()类似于func_open_audio_output()是用来选择使用硬解还是软解
    c). 和音频一样,调用decode_start()函数,里面执行SDL_CreateThreadEx()创建视频解码线程

到这里读线程的逻辑就结束了,里面的一些seek(滑动操作),pause等操作没有细说,可以自己更深入的看

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 206,968评论 6 482
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 88,601评论 2 382
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 153,220评论 0 344
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 55,416评论 1 279
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 64,425评论 5 374
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,144评论 1 285
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,432评论 3 401
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,088评论 0 261
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 43,586评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,028评论 2 325
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,137评论 1 334
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,783评论 4 324
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,343评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,333评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,559评论 1 262
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,595评论 2 355
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,901评论 2 345

推荐阅读更多精彩内容