Function qsv_process_data

libavcodec/qsvdec.c:992–1066

}

static int qsv_process_data(AVCodecContext *avctx, QSVContext *q,
                            AVFrame *frame, int *got_frame, const AVPacket *pkt)
{
    int ret;
    mfxVideoParam param = { 0 };
    enum AVPixelFormat pix_fmt = AV_PIX_FMT_NV12;

    if (!pkt->size)
        return qsv_decode(avctx, q, frame, got_frame, pkt);

    /* TODO: flush delayed frames on reinit */

    // sw_pix_fmt, coded_width/height should be set for ff_get_format(),
    // assume sw_pix_fmt is NV12 and coded_width/height to be 1280x720,
    // the assumption may be not correct but will be updated after header decoded if not true.
    if (q->orig_pix_fmt != AV_PIX_FMT_NONE)
        pix_fmt = q->orig_pix_fmt;
    if (!avctx->coded_width)
        avctx->coded_width = 1280;
    if (!avctx->coded_height)
        avctx->coded_height = 720;

    /* decode zero-size pkt to flush the buffered pkt before reinit */
    if (q->reinit_flag) {
        AVPacket zero_pkt = {0};
        ret = qsv_decode(avctx, q, frame, got_frame, &zero_pkt);
        if (ret < 0 || *got_frame)
            return ret;
    }

    if (q->reinit_flag || !q->session || !q->initialized) {
        mfxFrameAllocRequest request;
        memset(&request, 0, sizeof(request));

        q->reinit_flag = 0;
        ret = qsv_decode_header(avctx, q, pkt, pix_fmt, &param);
        if (ret < 0) {
            if (ret == AVERROR(EAGAIN))
                av_log(avctx, AV_LOG_VERBOSE, "More data is required to decode header\n");
            else
                av_log(avctx, AV_LOG_ERROR, "Error decoding header\n");
            goto reinit_fail;
        }
        param.IOPattern = q->iopattern;

        q->orig_pix_fmt = avctx->pix_fmt = pix_fmt = ff_qsv_map_fourcc(param.mfx.FrameInfo.FourCC);

        avctx->coded_width  = param.mfx.FrameInfo.Width;
        avctx->coded_height = param.mfx.FrameInfo.Height;

        ret = MFXVideoDECODE_QueryIOSurf(q->session, &param, &request);
        if (ret < 0)
            return ff_qsv_print_error(avctx, ret, "Error querying IO surface");

        q->suggest_pool_size = request.NumFrameSuggested;

        ret = qsv_decode_preinit(avctx, q, pix_fmt, &param);
        if (ret < 0)