【已解决】Hi3798M esplay

本帖最后由 yang1372073 于 2017-1-19 09:02 编辑

HI3798M 本地播放h265 ES 文件没有异常
但是Hi3798M接网络流实时播放，延时会短时间内累计，会从几百ms增加至5min左右，
1-文件播放
while (!g_StopThread)
    {
        if (g_bVidPlay)
        {
            if (HI_FALSE != g_bReadFrameSize)
            {
                Ret = HI_UNF_AVPLAY_GetBuf(hAvplay, HI_UNF_AVPLAY_BUF_ID_ES_VID, 0x100000, &StreamBuf, 0);
            }
            else
            {
                Ret = HI_UNF_AVPLAY_GetBuf(hAvplay, HI_UNF_AVPLAY_BUF_ID_ES_VID, 0x4000, &StreamBuf, 0);
            }

            if (HI_SUCCESS == Ret)
            {
                bVidBufAvail = HI_TRUE;

                if (HI_FALSE != g_bReadFrameSize)
                {
                    Readlen = fread(&FrameSize, 1, 4, g_pVidEsFile);
                    if (Readlen == 4)
                    {}
                    else
                    {
                        FrameSize = 0x4000;
                    }
                }
                else
                {
                    FrameSize = 0x4000;
                }

                Readlen = fread(StreamBuf.pu8Data, sizeof(HI_S8), FrameSize, g_pVidEsFile);

                if (Readlen > 0)
                {
                    Ret = HI_UNF_AVPLAY_PutBuf(hAvplay, HI_UNF_AVPLAY_BUF_ID_ES_VID, Readlen, 0);
                    if (Ret != HI_SUCCESS)
                    {
                        sample_printf("call HI_UNF_AVPLAY_PutBuf failed.\n");
                    }

                    FrameSize = 0;
                }
                else if (Readlen == 0)
                {
                    if (HI_TRUE == g_PlayOnce)
                    {
                        HI_BOOL bIsEmpty = HI_FALSE;
                        HI_UNF_AVPLAY_FLUSH_STREAM_OPT_S stFlushOpt;

                        sample_printf("Esplay flush stream.\n");
                        HI_UNF_AVPLAY_FlushStream(hAvplay, &stFlushOpt);
                        do {
                            Ret = HI_UNF_AVPLAY_IsBuffEmpty(hAvplay, &bIsEmpty);
                            if (Ret != HI_SUCCESS)
                            {
                                sample_printf("call HI_UNF_AVPLAY_IsBuffEmpty failed.\n");
                                break;
                            }
                        }while(bIsEmpty != HI_TRUE);
                        sleep(5);
                        sample_printf("Finish, esplay exit!\n");
                        exit(0);
                    }
                    else
                    {
                        sample_printf("read vid file end and rewind!\n");
                        rewind(g_pVidEsFile);
                    }
                }
                else
                {
                    perror("read vid file error\n");
                }
            }
            else
            {
                bVidBufAvail = HI_FALSE;
            }
        }

        if (g_bAudPlay)
        {
            Ret = HI_UNF_AVPLAY_GetBuf(hAvplay, HI_UNF_AVPLAY_BUF_ID_ES_AUD, 0x1000, &StreamBuf, 0);
            if (HI_SUCCESS == Ret)
            {
                bAudBufAvail = HI_TRUE;
                Readlen = fread(StreamBuf.pu8Data, sizeof(HI_S8), 0x1000, g_pAudEsFile);
                if (Readlen > 0)
                {
                    counter++;
                    Ret = HI_UNF_AVPLAY_PutBuf(hAvplay, HI_UNF_AVPLAY_BUF_ID_ES_AUD, Readlen, 0);
                    if (Ret != HI_SUCCESS)
                    {
                        sample_printf("call HI_UNF_AVPLAY_PutBuf failed.\n");
                    }
                }
                else if (Readlen == 0)
                {
                    sample_printf("read aud file end and rewind!\n");
                    rewind(g_pAudEsFile);
                    if (g_AudEsFileOffest)
                    {
                        fseek(g_pAudEsFile, g_AudEsFileOffest, SEEK_SET);
                    }
                }
                else
                {
                    perror("read aud file error\n");
                }
            }
            else if (Ret != HI_SUCCESS)
            {
                bAudBufAvail = HI_FALSE;
            }
        }

        /* wait for buffer */
        if ((HI_FALSE == bAudBufAvail) && (HI_FALSE == bVidBufAvail))
        {
            usleep(1000 * 10);
        }
    }
2-实时播放
   while (!g_StopThread)
    {
#ifdef TIME_PRINT
        gettimeofday(&startTime,NULL);
#endif
        ret_len = airrx_read(tsbuf, 188);
        Readlen = TsDemux(tsbuf, ret_len, ts_header, pat_header, pmt_header, ts_pes, bitstream, &bitstream_type);
        if(Readlen <= 0)
            continue;

        if (g_bVidPlay && ((bitstream_type==H264)||(bitstream_type==H265)))  //video
        {
            memcpy(video_buf, *bitstream, sizeof(unsigned char)*Readlen);
            video_buf += Readlen;
            i += Readlen;
            if(i <= 0x80)
                continue;

            Ret = HI_UNF_AVPLAY_GetBuf(hAvplay, HI_UNF_AVPLAY_BUF_ID_ES_VID, i, &StreamBuf, 0);

            if (HI_SUCCESS == Ret)
            {
                bVidBufAvail = HI_TRUE;              
                video_buf = video_buf - i;
                memcpy(StreamBuf.pu8Data, video_buf, sizeof(unsigned char)*i);

                if(0)
                {
                    static FILE *f;
                    static int flag;
                    if (!flag)
                    {
                        f = fopen("video.h265","wb");
                        flag = 1;
                    }

                    fwrite(StreamBuf.pu8Data, 1, i,f);
                }
                if (i > 0)
                {
                    Ret = HI_UNF_AVPLAY_PutBuf(hAvplay, HI_UNF_AVPLAY_BUF_ID_ES_VID, i, -1);
                    if (Ret != HI_SUCCESS)
                    {
                        sample_printf("call HI_UNF_AVPLAY_PutBuf failed.\n");
                    }
#ifdef TIME_PRINT                    
                    gettimeofday(&endTime, NULL);  
                    Timeuse = 1000000*(endTime.tv_sec - startTime.tv_sec) + (endTime.tv_usec - startTime.tv_usec);  
                    printf("Timeuse = %f\n", Timeuse);
#endif
                    i = 0;
                }
                else if (i == 0)
                {

                }
                else
                {
                    perror("read vid file error\n");
                }
            }
            else
            {
                bVidBufAvail = HI_FALSE;
            }
        }

        if (g_bAudPlay && (bitstream_type==AAC))  //audio
        {
            memcpy(audio_buf, *bitstream, sizeof(unsigned char)*Readlen);
            audio_buf += Readlen;
            j += Readlen;
            if(j <= 0x20)
                continue;

            Ret = HI_UNF_AVPLAY_GetBuf(hAvplay, HI_UNF_AVPLAY_BUF_ID_ES_AUD, j, &StreamBuf, 0);
            if (HI_SUCCESS == Ret)
            {
                bAudBufAvail = HI_TRUE;
                audio_buf = audio_buf - j;
                memcpy(StreamBuf.pu8Data, audio_buf, sizeof(unsigned char)*j);

                if (j > 0)
                {
                    Ret = HI_UNF_AVPLAY_PutBuf(hAvplay, HI_UNF_AVPLAY_BUF_ID_ES_AUD, j, -1);
                    if (Ret != HI_SUCCESS)
                    {
                        sample_printf("call HI_UNF_AVPLAY_PutBuf failed.\n");
                    }

                    j = 0;
                }
                else if (j == 0)
                {
                    sample_printf("read aud file end and rewind!\n");
                }
                else
                {
                    perror("read aud file error\n");
                }
            }
            else if (Ret != HI_SUCCESS)
            {
                bAudBufAvail = HI_FALSE;
            }
        }

        /* wait for buffer */
        if ((HI_FALSE == bAudBufAvail) && (HI_FALSE == bVidBufAvail))
        {
            usleep(1000 * 10);
        }
    }