xref: /OK3568_Linux_fs/external/rockit/mpi/example/mod/test_mpi_vdec.cpp (revision 4882a59341e53eb6f0b4789bf948001014eff981)

/*
 * Copyright 2018 Rockchip Electronics Co. LTD
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */

#include <cstdio>
#include <cerrno>
#include <cstring>
#include <cstdlib>
#include <unistd.h>
#include <pthread.h>
#include <sys/stat.h>
#include <sys/poll.h>
#include <sys/types.h>
#include "rk_debug.h"
#include "rk_mpi_vdec.h"
#include "rk_mpi_sys.h"
#include "rk_mpi_mb.h"
#include "rk_mpi_cal.h"
#include "rk_mpi_vo.h"
#include "test_comm_argparse.h"
#include "test_comm_utils.h"

#define MAX_STREAM_CNT               8
#define MAX_TIME_OUT_MS              20

#ifndef VDEC_INT64_MIN
#define VDEC_INT64_MIN               (-0x7fffffffffffffffLL-1)
#endif

#ifndef VDEC_INT64_MAX
#define VDEC_INT64_MAX               INT64_C(9223372036854775807)
#endif

typedef struct _rkMpiVDECCtx {
    const char *srcFileUri;
    const char *dstFilePath;
    RK_U32 u32SrcWidth;
    RK_U32 u32SrcHeight;
    RK_S32 s32LoopCount;
    RK_U32 u32ChnIndex;
    RK_U32 u32ChNum;
    RK_U32 u32InputMode;
    RK_CODEC_ID_E enCodecId;
    RK_U32 u32CompressMode;
    RK_U32 u32FrameBufferCnt;
    pthread_t pVdecThread;
    pthread_t pGetPicThread;
    RK_U32 u32StreamIndex;
    void  *pExtraData;
    RK_U32 u32ExtraDataSize;
    RK_U32 u32ReadSize;
    RK_BOOL threadExit;
    RK_S32 s32ChnFd;
    RK_BOOL bEnableMbPool;
    MB_POOL s32Pool;
    RK_S32 s32OutputPixFmt;
    RK_BOOL bEnableDei;
    RK_BOOL bEnableColmv;
} TEST_VDEC_CTX_S;

static void dump_frame_to_file(VIDEO_FRAME_INFO_S *pstFrame, FILE *fp) {
    RK_U32 i;
    RK_U32 width    = 0;
    RK_U32 height   = 0;
    RK_U32 h_stride = 0;
    RK_U32 v_stride = 0;
    RK_U8 *base_y = RK_NULL;
    RK_U8 *base_c = RK_NULL;
    RK_U8 *base = RK_NULL;

    if (NULL == fp)
        return;

    base = (RK_U8 *)RK_MPI_MB_Handle2VirAddr(pstFrame->stVFrame.pMbBlk);
    RK_MPI_SYS_MmzFlushCache(pstFrame->stVFrame.pMbBlk, RK_TRUE);
    width = pstFrame->stVFrame.u32Width;
    height = pstFrame->stVFrame.u32Height;

    switch (pstFrame->stVFrame.enPixelFormat) {
        case RK_FMT_YUV420SP_VU :
        case RK_FMT_YUV420SP : {
            h_stride = pstFrame->stVFrame.u32VirWidth;
            v_stride = pstFrame->stVFrame.u32VirHeight;

            base_y = base;
            base_c = base + h_stride * v_stride;

            for (i = 0; i < height; i++, base_y += h_stride) {
                fwrite(base_y, 1, width, fp);
            }
            for (i = 0; i < height / 2; i++, base_c += h_stride) {
                fwrite(base_c, 1, width, fp);
            }
        } break;

        case RK_FMT_YUV420SP_10BIT : {
            h_stride = pstFrame->stVFrame.u32VirWidth * 10 / 8;
            v_stride = pstFrame->stVFrame.u32VirHeight;

            base_y = base;
            base_c = base + h_stride * v_stride;

            for (i = 0; i < height; i++, base_y += h_stride) {
                fwrite(base_y, 1, width, fp);
            }
            for (i = 0; i < height / 2; i++, base_c += h_stride) {
                fwrite(base_c, 1, width, fp);
            }
        } break;

        case RK_FMT_RGB565:
        case RK_FMT_BGR565: {
            h_stride = pstFrame->stVFrame.u32VirWidth * 2;
            v_stride = pstFrame->stVFrame.u32VirHeight;
            base_y = base;

            for (i = 0; i < height; i++, base_y += h_stride)
                fwrite(base_y, 1, width * 2, fp);
        } break;
        case RK_FMT_RGB888:
        case RK_FMT_BGR888: {
            h_stride = pstFrame->stVFrame.u32VirWidth * 3;
            v_stride = pstFrame->stVFrame.u32VirHeight;
            base_y = base;

            for (i = 0; i < height; i++, base_y += h_stride)
                fwrite(base_y, 1, width * 3, fp);
        } break;
        default : {
            RK_LOGE("not supported format %d\n", pstFrame->stVFrame.enPixelFormat);
        } break;
    }
}

static RK_S32 check_options(const TEST_VDEC_CTX_S *ctx) {
    if (ctx->srcFileUri == RK_NULL) {
        goto __FAILED;
    }

    if (ctx->u32InputMode == VIDEO_MODE_STREAM) {
        if (ctx->enCodecId <= RK_VIDEO_ID_Unused ||
            ctx->u32SrcWidth <= 0 ||
            ctx->u32SrcHeight <= 0) {
            goto __FAILED;
        }
    }
    return RK_SUCCESS;

__FAILED:
    return RK_FAILURE;
}


RK_S32 mpi_vdec_poll_event(RK_S32 timeoutMsec, RK_S32 fd) {
    RK_S32 num_fds = 1;
    struct pollfd pollFds[num_fds];
    RK_S32 ret = 0;

    RK_ASSERT(fd > 0);
    memset(pollFds, 0, sizeof(pollFds));
    pollFds[0].fd = fd;
    pollFds[0].events = (POLLPRI | POLLIN | POLLERR | POLLNVAL | POLLHUP);

    ret = poll(pollFds, num_fds, timeoutMsec);
    if (ret > 0 && (pollFds[0].revents & (POLLERR | POLLNVAL | POLLHUP))) {
        RK_LOGE("fd:%d polled error", fd);
        return -1;
    }

    return ret;
}

RK_S32 mpi_create_vdec(TEST_VDEC_CTX_S *ctx, RK_S32 s32Ch, VIDEO_MODE_E enMode) {
    RK_S32 s32Ret = RK_SUCCESS;
    VDEC_CHN_ATTR_S stAttr;
    VDEC_CHN_PARAM_S stVdecParam;
    MB_POOL_CONFIG_S stMbPoolCfg;
    VDEC_PIC_BUF_ATTR_S stVdecPicBufAttr;
    MB_PIC_CAL_S stMbPicCalResult;
    VDEC_MOD_PARAM_S stModParam;

    memset(&stAttr, 0, sizeof(VDEC_CHN_ATTR_S));
    memset(&stVdecParam, 0, sizeof(VDEC_CHN_PARAM_S));
    memset(&stModParam, 0, sizeof(VDEC_MOD_PARAM_S));

    if (ctx->bEnableMbPool) {
        stModParam.enVdecMBSource = MB_SOURCE_USER;
        s32Ret = RK_MPI_VDEC_SetModParam(&stModParam);
        if (s32Ret != RK_SUCCESS) {
            RK_LOGE("vdec %d SetModParam failed! errcode %x", ctx->u32ChnIndex, s32Ret);
            return s32Ret;
        }
    }

    stAttr.enMode = enMode;
    stAttr.enType = ctx->enCodecId;
    stAttr.u32PicWidth = ctx->u32SrcWidth;
    stAttr.u32PicHeight = ctx->u32SrcHeight;
    stAttr.u32FrameBufCnt = ctx->u32FrameBufferCnt;
    stAttr.u32StreamBufCnt = MAX_STREAM_CNT;

    if (!ctx->bEnableColmv) {
        stAttr.stVdecVideoAttr.bTemporalMvpEnable = RK_FALSE;
    }

    s32Ret = RK_MPI_VDEC_CreateChn(ctx->u32ChnIndex, &stAttr);
    if (s32Ret != RK_SUCCESS) {
        RK_LOGE("create %d vdec failed! ", ctx->u32ChnIndex);
        return s32Ret;
    }

    if (ctx->enCodecId == RK_VIDEO_ID_MJPEG) {
        stVdecParam.stVdecPictureParam.enPixelFormat = (PIXEL_FORMAT_E)ctx->s32OutputPixFmt;
    } else {
        stVdecParam.stVdecVideoParam.enCompressMode = (COMPRESS_MODE_E)ctx->u32CompressMode;
    }
    if (ctx->bEnableDei) {
        stVdecParam.stVdecVideoParam.bDeiEn = ctx->bEnableDei;
    }
    // it is only effective to disable MV when decoding sequence output
    if (!ctx->bEnableColmv) {
        stVdecParam.stVdecVideoParam.enOutputOrder = VIDEO_OUTPUT_ORDER_DEC;
    }

    s32Ret = RK_MPI_VDEC_SetChnParam(ctx->u32ChnIndex, &stVdecParam);
    if (s32Ret != RK_SUCCESS) {
        RK_LOGE("set chn %d param failed %x! ", ctx->u32ChnIndex, s32Ret);
        return s32Ret;
    }

    ctx->s32ChnFd = RK_MPI_VDEC_GetFd(ctx->u32ChnIndex);
    if (ctx->s32ChnFd <= 0) {
        RK_LOGE("get fd chn %d failed %d", ctx->u32ChnIndex, ctx->s32ChnFd);
        return s32Ret;
    }

    if (ctx->bEnableMbPool) {
        memset(&stMbPoolCfg, 0, sizeof(MB_POOL_CONFIG_S));

        stVdecPicBufAttr.enCodecType = ctx->enCodecId;
        stVdecPicBufAttr.stPicBufAttr.u32Width = ctx->u32SrcWidth;
        stVdecPicBufAttr.stPicBufAttr.u32Height = ctx->u32SrcHeight;
        stVdecPicBufAttr.stPicBufAttr.enPixelFormat = (PIXEL_FORMAT_E)ctx->s32OutputPixFmt;
        stVdecPicBufAttr.stPicBufAttr.enCompMode = (COMPRESS_MODE_E)ctx->u32CompressMode;
        s32Ret = RK_MPI_CAL_VDEC_GetPicBufferSize(&stVdecPicBufAttr, &stMbPicCalResult);
        if (s32Ret != RK_SUCCESS) {
            RK_LOGE("get picture buffer size failed. err 0x%x", s32Ret);
            return s32Ret;
        }

        stMbPoolCfg.u64MBSize = stMbPicCalResult.u32MBSize;;
        stMbPoolCfg.u32MBCnt  = 10;
        stMbPoolCfg.enRemapMode = MB_REMAP_MODE_CACHED;
        stMbPoolCfg.bPreAlloc = RK_TRUE;
        ctx->s32Pool = RK_MPI_MB_CreatePool(&stMbPoolCfg);
        if (ctx->s32Pool == MB_INVALID_POOLID) {
            RK_LOGE("create pool failed!");
            return s32Ret;
        }
        s32Ret = RK_MPI_VDEC_AttachMbPool(ctx->u32ChnIndex, ctx->s32Pool);
        if (s32Ret != RK_SUCCESS) {
            RK_LOGE("attatc vdec mb pool %d failed! ", ctx->u32ChnIndex);
            return s32Ret;
        }
    }

    s32Ret = RK_MPI_VDEC_StartRecvStream(ctx->u32ChnIndex);
    if (s32Ret != RK_SUCCESS) {
        RK_LOGE("start recv chn %d failed %x! ", ctx->u32ChnIndex, s32Ret);
        return s32Ret;
    }

    return RK_SUCCESS;
}

RK_S32 mpi_destory_vdec(TEST_VDEC_CTX_S *ctx, RK_S32 s32Ch) {
    RK_MPI_VDEC_StopRecvStream(s32Ch);

    if (ctx->s32ChnFd > 0) {
        RK_MPI_VDEC_CloseFd(s32Ch);
    }

    if (ctx->bEnableMbPool) {
        RK_MPI_VDEC_DetachMbPool(s32Ch);
        RK_MPI_VDEC_DestroyChn(s32Ch);
        RK_MPI_MB_DestroyPool(ctx->s32Pool);
    } else {
        RK_MPI_VDEC_DestroyChn(s32Ch);
    }

    return RK_SUCCESS;
}

RK_S32 mpi_create_stream_mode(TEST_VDEC_CTX_S *ctx, RK_S32 s32Ch) {
    VIDEO_MODE_E enMode;

    if (ctx->enCodecId == RK_VIDEO_ID_MJPEG || ctx->enCodecId == RK_VIDEO_ID_JPEG) {
        ctx->u32ReadSize = ctx->u32SrcWidth * ctx->u32SrcHeight;
        enMode = VIDEO_MODE_FRAME;
    } else {
        enMode = VIDEO_MODE_STREAM;
    }

    return mpi_create_vdec(ctx, s32Ch, enMode);
}

RK_S32 mpi_create_frame_mode(TEST_VDEC_CTX_S *ctx, RK_S32 s32Ch) {
    RK_S32 s32Ret = RK_SUCCESS;

    s32Ret = mpi_create_vdec(ctx, s32Ch, VIDEO_MODE_FRAME);
    if (s32Ret != RK_SUCCESS) {
        goto __FAILED;
    }

    return s32Ret;
__FAILED:

    return RK_FAILURE;
}

void* mpi_get_pic(void *pArgs) {
    TEST_VDEC_CTX_S *ctx = reinterpret_cast<TEST_VDEC_CTX_S *>(pArgs);
    FILE *fp = RK_NULL;
    VIDEO_FRAME_INFO_S sFrame;
    RK_S32 s32Ret;
    char name[256] = {0};
    RK_S32 s32FrameCount = 0;

    memset(&sFrame, 0, sizeof(VIDEO_FRAME_INFO_S));

    if (ctx->dstFilePath != RK_NULL) {
        mkdir(ctx->dstFilePath, 0777);
        snprintf(name, sizeof(name), "%stest_%d.bin", ctx->dstFilePath, ctx->u32ChnIndex);

        fp = fopen(name, "wb");
        if (fp == RK_NULL) {
            RK_LOGE("can't open output file %s\n", name);
            return NULL;
        }
    }

    while (!ctx->threadExit) {
        if (ctx->s32ChnFd > 0) {
            s32Ret = mpi_vdec_poll_event(-1, ctx->s32ChnFd);
            if (s32Ret < 0) {
                if (ctx->threadExit)
                    break;

                usleep(1000llu);
                continue;
            }
        }

        s32Ret = RK_MPI_VDEC_GetFrame(ctx->u32ChnIndex, &sFrame, MAX_TIME_OUT_MS);
        if (s32Ret >= 0) {
            s32FrameCount++;
            RK_LOGI("get chn %d frame %d", ctx->u32ChnIndex, s32FrameCount);
            if ((sFrame.stVFrame.u32FrameFlag & FRAME_FLAG_SNAP_END) == FRAME_FLAG_SNAP_END) {
                RK_MPI_VDEC_ReleaseFrame(ctx->u32ChnIndex, &sFrame);
                RK_LOGI("chn %d reach eos frame.", ctx->u32ChnIndex);
                break;
            }

            dump_frame_to_file(&sFrame, fp);
            RK_MPI_VDEC_ReleaseFrame(ctx->u32ChnIndex, &sFrame);
        } else {
            if (ctx->threadExit)
                break;

            usleep(1000llu);
        }
    }

    if (fp)
        fclose(fp);
    RK_LOGI("%s out", __FUNCTION__);
    return RK_NULL;
}


static RK_S32 mpi_vdec_free(void *opaque) {
    if (opaque)
        free(opaque);
    return 0;
}

static void* mpi_send_stream(void *pArgs) {
    TEST_VDEC_CTX_S *ctx = reinterpret_cast<TEST_VDEC_CTX_S *>(pArgs);
    RK_S32 s32Size = 0;
    RK_S32 s32Ret = 0;
    RK_U8 *data = RK_NULL;
    FILE *fp = RK_NULL;
    MB_BLK buffer = RK_NULL;
    MB_EXT_CONFIG_S pstMbExtConfig;
    VDEC_CHN_STATUS_S staus;
    VDEC_CHN_ATTR_S stAttr;
    VDEC_CHN_PARAM_S stVdecParam;
    VDEC_STREAM_S stStream;
    RK_S32 s32PacketCount = 0;
    RK_S32 s32ReachEOS = 0;

    memset(&stStream, 0, sizeof(VDEC_STREAM_S));

    fp = fopen(ctx->srcFileUri, "r");
    if (fp == RK_NULL) {
        RK_LOGE("open file %s failed", ctx->srcFileUri);
        return RK_NULL;
    }

    while (!ctx->threadExit) {
        data = reinterpret_cast<RK_U8 *>(calloc(ctx->u32ReadSize, sizeof(RK_U8)));
        memset(data, 0, ctx->u32ReadSize);
        s32Size = fread(data, 1, ctx->u32ReadSize, fp);
        if (s32Size <= 0) {
            if (ctx->s32LoopCount--) {
                mpi_vdec_free(data);
                s32ReachEOS = 0;
                fseek(fp, 0, SEEK_SET);
                RK_LOGI("ctx->s32LoopCount = %d",ctx->s32LoopCount);
                if (ctx->u32ChnIndex) {
                    for (int i = 0; i < ctx->u32ChNum; i++) {
                        VO_CHN_ATTR_S stChnAttr;
                        RK_MPI_VO_GetChnAttr(0, i, &stChnAttr);
                        if (ctx->s32LoopCount % 2)
                            stChnAttr.u32Priority = ctx->u32ChNum - i;
                        else
                            stChnAttr.u32Priority = i;
                        RK_MPI_VO_SetChnAttr(0, i, &stChnAttr);
                    }
                }
                continue;
            } else
               s32ReachEOS = 1;
        }

        memset(&pstMbExtConfig, 0, sizeof(MB_EXT_CONFIG_S));
        pstMbExtConfig.pFreeCB = mpi_vdec_free;
        pstMbExtConfig.pOpaque = data;
        pstMbExtConfig.pu8VirAddr = data;
        pstMbExtConfig.u64Size = s32Size;

        RK_MPI_SYS_CreateMB(&buffer, &pstMbExtConfig);

        stStream.u64PTS = 0;
        stStream.pMbBlk = buffer;
        stStream.u32Len = s32Size;
        stStream.bEndOfStream = s32ReachEOS ? RK_TRUE : RK_FALSE;
        stStream.bEndOfFrame = s32ReachEOS ? RK_TRUE : RK_FALSE;
        stStream.bBypassMbBlk = RK_TRUE;
__RETRY:
        s32Ret = RK_MPI_VDEC_SendStream(ctx->u32ChnIndex, &stStream, MAX_TIME_OUT_MS);
        if (s32Ret < 0) {
            if (ctx->threadExit) {
                mpi_vdec_free(data);
                RK_MPI_MB_ReleaseMB(stStream.pMbBlk);
                break;
            }
            usleep(1000llu);
            goto  __RETRY;
        } else {
            s32PacketCount++;
            RK_MPI_MB_ReleaseMB(stStream.pMbBlk);
            //RK_LOGI("send chn %d packet %d", ctx->u32ChnIndex, s32PacketCount);
        }
        if (s32ReachEOS) {
            RK_LOGI("chn %d input reach EOS", ctx->u32ChnIndex);
            break;
        }
    }

    if (fp)
        fclose(fp);

    RK_LOGI("%s out\n", __FUNCTION__);
    return RK_NULL;
}

static RK_S32 create_vo(RK_U32 ChCnt) {
    /* Enable VO */
    VO_PUB_ATTR_S VoPubAttr;
    VO_VIDEO_LAYER_ATTR_S stLayerAttr;
    RK_S32 s32Ret = RK_SUCCESS;
    VO_CHN_ATTR_S stChnAttr;
    VO_LAYER VoLayer = 0;
    VO_DEV VoDev = 0;

    RK_MPI_VO_DisableLayer(VoLayer);
    RK_MPI_VO_DisableLayer(4);
    RK_MPI_VO_DisableLayer(5);
    RK_MPI_VO_DisableLayer(6);
    RK_MPI_VO_DisableLayer(7);
    RK_MPI_VO_Disable(VoDev);

    memset(&VoPubAttr, 0, sizeof(VO_PUB_ATTR_S));
    memset(&stLayerAttr, 0, sizeof(VO_VIDEO_LAYER_ATTR_S));

    stLayerAttr.enPixFormat = RK_FMT_RGB888;
    stLayerAttr.stDispRect.s32X = 0;
    stLayerAttr.stDispRect.s32Y = 0;
    stLayerAttr.u32DispFrmRt = 30;
    stLayerAttr.stDispRect.u32Width = 1920;
    stLayerAttr.stDispRect.u32Height = 1080;
    stLayerAttr.stImageSize.u32Width = 1920;
    stLayerAttr.stImageSize.u32Height = 1080;

    s32Ret = RK_MPI_VO_GetPubAttr(VoDev, &VoPubAttr);
    if (s32Ret != RK_SUCCESS) {
        return s32Ret;
    }

    VoPubAttr.enIntfType = VO_INTF_HDMI;
    VoPubAttr.enIntfSync = VO_OUTPUT_DEFAULT;

    s32Ret = RK_MPI_VO_SetPubAttr(VoDev, &VoPubAttr);
    if (s32Ret != RK_SUCCESS) {
        return s32Ret;
    }
    s32Ret = RK_MPI_VO_Enable(VoDev);
    if (s32Ret != RK_SUCCESS) {
        return s32Ret;
    }

    s32Ret = RK_MPI_VO_BindLayer(VoLayer, VoDev, VO_LAYER_MODE_VIDEO);
    if (s32Ret != RK_SUCCESS) {
        RK_LOGE("RK_MPI_VO_BindLayer failed,s32Ret:%d\n", s32Ret);
        return RK_FAILURE;
    }

    s32Ret = RK_MPI_VO_SetLayerAttr(VoLayer, &stLayerAttr);
    if (s32Ret != RK_SUCCESS) {
        RK_LOGE("RK_MPI_VO_SetLayerAttr failed,s32Ret:%d\n", s32Ret);
        return RK_FAILURE;
    }

    s32Ret = RK_MPI_VO_EnableLayer(VoLayer);
    if (s32Ret != RK_SUCCESS) {
        RK_LOGE("RK_MPI_VO_EnableLayer failed,s32Ret:%d\n", s32Ret);
        return RK_FAILURE;
    }

    for (int i = 0; i < ChCnt; i++) {
        stChnAttr.stRect.u32Width = stLayerAttr.stImageSize.u32Width / ChCnt;
        stChnAttr.stRect.u32Height = stLayerAttr.stImageSize.u32Height / ChCnt;
        stChnAttr.stRect.s32X = i * stChnAttr.stRect.u32Width / 2;
        stChnAttr.stRect.s32Y = i * stChnAttr.stRect.u32Height / 2;
        stChnAttr.u32Priority = i;
        stChnAttr.u32FgAlpha = 128;
        stChnAttr.u32BgAlpha = 0;

        s32Ret = RK_MPI_VO_SetChnAttr(VoLayer, i, &stChnAttr);
        if (s32Ret != RK_SUCCESS) {
            RK_LOGE("set chn Attr failed,s32Ret:%d\n", s32Ret);
            return RK_FAILURE;
        }
    }

    return s32Ret;
}


RK_S32 unit_test_mpi_vdec(TEST_VDEC_CTX_S *ctx) {
    MPP_CHN_S stSrcChn, stDestChn;
    RK_S32 s32Ret = RK_FAILURE;
    RK_U32 u32Ch = 0;
    TEST_VDEC_CTX_S vdecCtx[VDEC_MAX_CHN_NUM];
    pthread_t vdecThread[VDEC_MAX_CHN_NUM];
    pthread_t getPicThread[VDEC_MAX_CHN_NUM];

    for (u32Ch = 0; u32Ch < ctx->u32ChNum; u32Ch++) {
        if (ctx->u32ChNum > 1) {
            ctx->u32ChnIndex = u32Ch;
        }
        memcpy(&(vdecCtx[u32Ch]), ctx, sizeof(TEST_VDEC_CTX_S));

        // Does not support JPEG stream framing, read the size of one picture at a time
        // and send it to the decoder.
        if (ctx->u32InputMode == VIDEO_MODE_STREAM || ctx->enCodecId == RK_VIDEO_ID_MJPEG ||
            ctx->enCodecId == RK_VIDEO_ID_JPEG) {
            mpi_create_stream_mode(&vdecCtx[u32Ch], u32Ch);
            pthread_create(&vdecThread[u32Ch], 0, mpi_send_stream, reinterpret_cast<void *>(&vdecCtx[u32Ch]));
        } else  {
            return -1;
        }

         //pthread_create(&getPicThread[u32Ch], 0, mpi_get_pic, reinterpret_cast<void *>(&vdecCtx[u32Ch]));
    }

    s32Ret = create_vo(ctx->u32ChNum);
    if (s32Ret != RK_SUCCESS) {
        RK_LOGE("create vo ch failed");
        return -1;
    }
    // bind vi to vo
    for (int i = 0; i < ctx->u32ChNum; i++) {
        stSrcChn.enModId    = RK_ID_VDEC;
        stSrcChn.s32DevId   = 0;
        stSrcChn.s32ChnId   = i;

        stDestChn.enModId   = RK_ID_VO;
        stDestChn.s32DevId  = 0;
        stDestChn.s32ChnId  = i;

        s32Ret = RK_MPI_SYS_Bind(&stSrcChn, &stDestChn);
        if (s32Ret != RK_SUCCESS) {
            RK_LOGE("vi band vo fail:%x", s32Ret);
            return -1;
        }

        // enable vo
        s32Ret = RK_MPI_VO_EnableChn(0, i);
        if (s32Ret != RK_SUCCESS) {
            RK_LOGE("Enalbe vo chn failed, s32Ret = %d\n", s32Ret);
            return -1;
        }
    }

    for (u32Ch = 0; u32Ch < ctx->u32ChNum; u32Ch++) {
        pthread_join(vdecThread[u32Ch], RK_NULL);
        pthread_join(getPicThread[u32Ch], RK_NULL);

        vdecCtx[u32Ch].threadExit = RK_TRUE;
        if (ctx->u32ChNum > 1) {
            mpi_destory_vdec(&vdecCtx[u32Ch], u32Ch);
        } else {
            mpi_destory_vdec(&vdecCtx[u32Ch], ctx->u32ChnIndex);
        }
    }

    return RK_SUCCESS;
}

static void mpi_vdec_test_show_options(const TEST_VDEC_CTX_S *ctx) {
    RK_PRINT("cmd parse result:\n");
    RK_PRINT("input file name        : %s\n", ctx->srcFileUri);
    RK_PRINT("output path            : %s\n", ctx->dstFilePath);
    RK_PRINT("input width            : %d\n", ctx->u32SrcWidth);
    RK_PRINT("input height           : %d\n", ctx->u32SrcHeight);
    RK_PRINT("input codecId          : %d\n", ctx->enCodecId);
    RK_PRINT("loop count             : %d\n", ctx->s32LoopCount);
    RK_PRINT("channel index          : %d\n", ctx->u32ChnIndex);
    RK_PRINT("channel number         : %d\n", ctx->u32ChNum);
    RK_PRINT("output compress mode   : %d\n", ctx->u32CompressMode);
    RK_PRINT("input mode             : %d\n", ctx->u32InputMode);
    RK_PRINT("enable mb pool         : %d\n", ctx->bEnableMbPool);
    RK_PRINT("output pix format      : %d\n", ctx->s32OutputPixFmt);
    RK_PRINT("enable deinterlace     : %d\n", ctx->bEnableDei);
    RK_PRINT("enable colmv           : %d\n", ctx->bEnableColmv);
    return;
}

static const char *const usages[] = {
    "./rk_mpi_vdec_test [-i SRC_PATH] [-o OUTPUT_PATH]...",
    NULL,
};

int main(int argc, const char **argv) {
    TEST_VDEC_CTX_S ctx;
    memset(&ctx, 0, sizeof(TEST_VDEC_CTX_S));

    ctx.u32InputMode = VIDEO_MODE_STREAM;
    ctx.s32LoopCount = 1;
    ctx.u32CompressMode = COMPRESS_MODE_NONE;  // Suggest::COMPRESS_AFBC_16x16;
    ctx.u32FrameBufferCnt = 8;
    ctx.u32ReadSize = 1024;
    ctx.u32ChNum = 1;
    ctx.bEnableColmv = RK_TRUE;
    ctx.s32OutputPixFmt = (RK_S32)RK_FMT_YUV420SP;
    ctx.u32SrcWidth = 1920;
    ctx.u32SrcHeight = 1080;
    ctx.enCodecId = RK_VIDEO_ID_AVC;

    struct argparse_option options[] = {
        OPT_HELP(),
        OPT_GROUP("basic options:"),
        OPT_STRING('i', "input", &(ctx.srcFileUri),
                   "input file name. <required>", NULL, 0, 0),
        OPT_STRING('o', "output", &(ctx.dstFilePath),
                   "the directory of decoder output", NULL, 0, 0),
        OPT_INTEGER('C', "codec", &(ctx.enCodecId),
                   "input stream codec(8:h264, 9:mjpeg, 12:h265,...) <required on StreamMode>", NULL, 0, 0),
        OPT_INTEGER('n', "loop_count", &(ctx.s32LoopCount),
                    "loop running count. default(1)", NULL, 0, 0),
        OPT_INTEGER('w', "width", &(ctx.u32SrcWidth),
                    "input source width <required on StreamMode>", NULL, 0, 0),
        OPT_INTEGER('h', "height", &(ctx.u32SrcHeight),
                    "input source height <required on StreamMode>", NULL, 0, 0),
        OPT_INTEGER('\0', "channel_index", &(ctx.u32ChnIndex),
                    "vdec channel index. default(0).", NULL, 0, 0),
        OPT_INTEGER('c', "channel_count", &(ctx.u32ChNum),
                    "vdec channel count. default(1).", NULL, 0, 0),
        OPT_INTEGER('\0', "dec_mode", &(ctx.u32InputMode),
                    "vdec decode mode. range(0:StreamMode, 1:FrameMode). default(0)", NULL, 0, 0),
        OPT_INTEGER('\0', "dec_buf_cnt", &(ctx.u32FrameBufferCnt),
                    "vdec decode output buffer count, default(8)", NULL, 0, 0),
        OPT_INTEGER('\0', "compress_mode", &(ctx.u32CompressMode),
                    "vdec compress mode, default(0); 0: NONE, 1: AFBC_16X16", NULL, 0, 0),
        OPT_INTEGER('\0', "en_mbpool", &(ctx.bEnableMbPool),
                    "enable mb pool, default(0).", NULL, 0, 0),
        OPT_INTEGER('\0', "pixfmt", &(ctx.s32OutputPixFmt),
                    "jpeg output pixel format, default(0); 0: YUV420SP", NULL, 0, 0),
        OPT_INTEGER('\0', "en_dei", &(ctx.bEnableDei),
                    "enable deinterlace, default(0);", NULL, 0, 0),
        OPT_INTEGER('\0', "en_colmv", &(ctx.bEnableColmv),
                    "enable colmv, default(1);", NULL, 0, 0),
        OPT_END(),
    };

    struct argparse argparse;
    argparse_init(&argparse, options, usages, 0);
    argparse_describe(&argparse, "\nselect a test case to run.",
                                 "\nuse --help for details.");

    argc = argparse_parse(&argparse, argc, argv);
    mpi_vdec_test_show_options(&ctx);

    if (check_options(&ctx)) {
        RK_LOGE("illegal input parameters");
        argparse_usage(&argparse);
        goto __FAILED;
    }

    if (RK_MPI_SYS_Init() != RK_SUCCESS) {
        goto __FAILED;
    }

    while (ctx.s32LoopCount > 0) {
        if (unit_test_mpi_vdec(&ctx) < 0) {
            goto __FAILED;
        }
        ctx.s32LoopCount--;
    }

    if (RK_MPI_SYS_Exit() != RK_SUCCESS) {
        goto __FAILED;
    }

    RK_LOGE("test running success!");
    return RK_SUCCESS;
__FAILED:
    RK_LOGE("test running failed! %d count running done not yet.", ctx.s32LoopCount);
    return RK_FAILURE;
}