ijkplayer 马赛克 丢帧处理

大致思路是所有引起的包异常 都需要 设置标志位 frame_err 为1

libavcodec/avcodec.h

增加 extern int frame_err;


+#ifndef _TEST_H
+#define _TEST_H
+ extern int frame_err;   
+extern int decode_err;
+#endif

libavcodec/error_resilience.c

av_log(s->avctx, AV_LOG_INFO, "concealing %d DC, %d AC, %d MV errors in %c frame\n",
后面加 
frame_err=1;

libavcodec/h264_cavlc.c

     if(zeros_left<0){
-        av_log(h->avctx, AV_LOG_ERROR, "negative number of zero coeffs at %d %d\n", sl->mb_x, sl->mb_y);
+        av_log(h->avctx, AV_LOG_ERROR, "frame_err=1; negative number of zero coeffs at %d %d\n", sl->mb_x, sl->mb_y);
+       frame_err=1;
         return -1;
     }


@@ -1110,8 +1113,9 @@ decode_intra_mb:
             if (sl->qscale < 0) sl->qscale += max_qp + 1;
             else                sl->qscale -= max_qp+1;
             if (((unsigned)sl->qscale) > max_qp){
-                av_log(h->avctx, AV_LOG_ERROR, "dquant out of range (%d) at %d %d\n", dquant, sl->mb_x, sl->mb_y);
-                return -1;
+                av_log(h->avctx, AV_LOG_ERROR, "frame_err=1; dquant out of range (%d) at %d %d\n", dquant, sl->mb_x, sl->mb_y);
+frame_err=1;                
+return -1;
             }
         }

libavcodec/h264_parse.c

@@ -199,7 +199,8 @@ int ff_h264_check_intra_pred_mode(void *logctx, int top_samples_available,
         mode = left[mode];
         if (mode < 0) {
             av_log(logctx, AV_LOG_ERROR,
-                   "left block unavailable for requested intra mode\n");
+                   "frame_err left block unavailable for requested intra mode\n");
+            frame_err = 1;
             return AVERROR_INVALIDDATA;
         }

libavcodec/h264_slice.c

+int decode_err=0;
 static const uint8_t field_scan[16+1] = {
     0 + 0 * 4, 0 + 1 * 4, 1 + 0 * 4, 0 + 2 * 4,
     0 + 3 * 4, 1 + 1 * 4, 1 + 2 * 4, 1 + 3 * 4,
@@ -1502,8 +1502,9 @@ static int h264_field_start(H264Context *h, const H264SliceContext *sl,
     while (h->poc.frame_num != h->poc.prev_frame_num && !h->first_field &&
            h->poc.frame_num != (h->poc.prev_frame_num + 1) % (1 << sps->log2_max_frame_num)) {
         H264Picture *prev = h->short_ref_count ? h->short_ref[0] : NULL;
-        av_log(h->avctx, AV_LOG_DEBUG, "Frame num gap %d %d\n",
+        av_log(h->avctx, AV_LOG_DEBUG, "frameerr Frame num gap %d %d\n",
                h->poc.frame_num, h->poc.prev_frame_num);
+        frame_err=1;
         if (!sps->gaps_in_frame_num_allowed_flag)
             for(i=0; i<FF_ARRAY_ELEMS(h->last_pocs); i++)
                 h->last_pocs[i] = INT_MIN;
@@ -1726,8 +1727,10 @@ static int h264_slice_header_parse(const H264Context *h, H264SliceContext *sl,
     sl->frame_num = get_bits(&sl->gb, sps->log2_max_frame_num);
     if (!first_slice) {
         if (h->poc.frame_num != sl->frame_num) {
-            av_log(h->avctx, AV_LOG_ERROR, "Frame num change from %d to %d\n",
+            av_log(h->avctx, AV_LOG_ERROR, "frame_err Frame num change from %d to %d\n",
                    h->poc.frame_num, sl->frame_num);
+            frame_err=1;
+             decode_err=1;
             return AVERROR_INVALIDDATA;
         }
     }
@@ -2603,11 +2606,13 @@ static int decode_slice(struct AVCodecContext *avctx, void *arg)
                 av_log(h->avctx, AV_LOG_DEBUG, "bytestream overread %"PTRDIFF_SPECIFIER"\n", sl->cabac.bytestream_end - sl->cabac.bytestream);
             if (ret < 0 || sl->cabac.bytestream > sl->cabac.bytestream_end + 4) {
                 av_log(h->avctx, AV_LOG_ERROR,
-                       "error while decoding MB %d %d, bytestream %"PTRDIFF_SPECIFIER"\n",
+                       "errframe error while decoding MB %d %d, bytestream %"PTRDIFF_SPECIFIER"\n",
                        sl->mb_x, sl->mb_y,
                        sl->cabac.bytestream_end - sl->cabac.bytestream);
                 er_add_slice(sl, sl->resync_mb_x, sl->resync_mb_y, sl->mb_x,
                              sl->mb_y, ER_MB_ERROR);
+ frame_err = 1;
+
                 return AVERROR_INVALIDDATA;
             }
 
@@ -2662,7 +2667,9 @@ static int decode_slice(struct AVCodecContext *avctx, void *arg)
 
             if (ret < 0) {
                 av_log(h->avctx, AV_LOG_ERROR,
-                       "error while decoding MB %d %d\n", sl->mb_x, sl->mb_y);
+                       " errframe decode_err error while decoding MB %d %d\n", sl->mb_x, sl->mb_y);
+                  frame_err = 1;
+                  decode_err = 1;
                 er_add_slice(sl, sl->resync_mb_x, sl->resync_mb_y, sl->mb_x,
                              sl->mb_y, ER_MB_ERROR);
                 return ret;

libavcodec/svq3.c

@@ -1565,7 +1565,8 @@ static int svq3_decode_frame(AVCodecContext *avctx, void *data,
                 mb_type += 4;
             if (mb_type > 33 || svq3_decode_mb(s, mb_type)) {
                 av_log(s->avctx, AV_LOG_ERROR,
-                       "error while decoding MB %d %d\n", s->mb_x, s->mb_y);
+                       "frameerr error while decoding MB %d %d\n", s->mb_x, s->mb_y);
+                frame_err=1;
                 return -1;
             }

最后 在 ffplay.c处理丢帧操作
修改 static int read_thread(void *arg)方法

 // 每次读取一个pkt，都去判断处理
        // TODO:优化，不用每次都调用
        //if (is->max_cached_duration > 0) {
         //   control_queue_duration(ffp, is);
        //}
        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);
            if(!frame_err){
               packet_queue_put(&is->videoq, pkt);
              //av_log(NULL, AV_LOG_ERROR, "packet_queue_put frame_err \n");   
            }else {//release the packet when frame error during total GOP
               av_packet_unref(pkt);
            }
            //frame_err=0;
        } else if (pkt->stream_index == is->subtitle_stream && pkt_in_play_range) {
            packet_queue_put(&is->subtitleq, pkt);
        } else {
            av_packet_unref(pkt);
        }

        ffp_statistic_l(ffp);

      pkt->flags = 0;


        ret = av_read_frame(ic, pkt);

if(pkt->stream_index == AVMEDIA_TYPE_VIDEO&& (pkt->flags & AV_PKT_FLAG_KEY)){
             av_log(ffp, AV_LOG_INFO, " it's i frame \n");
           frame_err=0;//这里复位
           decode_err=0;
   }

libavformat/rtpdec.c

     if (!has_next_packet(s))
-        av_log(s->ic, AV_LOG_WARNING,
-               "RTP: missed %d packets\n", s->queue->seq - s->seq - 1);
-
+      {  av_log(s->ic, AV_LOG_WARNING,
+               "frame_err RTP: missed %d packets\n", s->queue->seq - s->seq - 1);
+       frame_err=1;
+}

统计下所有的修改地方为以下位置

root@alpha-facekaoqin-3:/service/software/ijkplayer/android/contrib/ffmpeg-arm64# find ./ -name "*.c"   -exec grep -C 2  'frame_err' {} \; -print
    if (!has_next_packet(s))
      {  av_log(s->ic, AV_LOG_WARNING,
               "frame_err RTP: missed %d packets\n", s->queue->seq - s->seq - 1);
    frame_err=1;
}
    /* Parse the first packet in the queue, and dequeue it */
./libavformat/rtpdec.c
                av_log(s->avctx, AV_LOG_ERROR,
                       "frameerr error while decoding MB %d %d\n", s->mb_x, s->mb_y);
                frame_err=1;
                return -1;
            }
./libavcodec/svq3.c
    if(total_coeff > (unsigned)max_coeff) {
        av_log(h->avctx, AV_LOG_ERROR, "corrupted macroblock %d %d (total_coeff=%d)\n", sl->mb_x, sl->mb_y, total_coeff);
        frame_err=1;
        return -1;
    }
--
                        if(prefix > 25+3){
                            av_log(h->avctx, AV_LOG_ERROR, "Invalid level prefix\n");
                            frame_err=1;
                            return AVERROR_INVALIDDATA;
                        }
--

    if(zeros_left<0){
        av_log(h->avctx, AV_LOG_ERROR, "frame_err=1; negative number of zero coeffs at %d %d\n", sl->mb_x, sl->mb_y);
       frame_err=1;
        return -1;
    }
--
            else                sl->qscale -= max_qp+1;
            if (((unsigned)sl->qscale) > max_qp){
                av_log(h->avctx, AV_LOG_ERROR, "frame_err=1; dquant out of range (%d) at %d %d\n", dquant, sl->mb_x, sl->mb_y);
frame_err=1;                
return -1;
            }
./libavcodec/h264_cavlc.c
        av_log(h->avctx, AV_LOG_DEBUG, "frameerr Frame num gap %d %d\n",
               h->poc.frame_num, h->poc.prev_frame_num);
        frame_err=1;
        if (!sps->gaps_in_frame_num_allowed_flag)
            for(i=0; i<FF_ARRAY_ELEMS(h->last_pocs); i++)
--
    if (!first_slice) {
        if (h->poc.frame_num != sl->frame_num) {
            av_log(h->avctx, AV_LOG_ERROR, "frame_err Frame num change from %d to %d\n",
                   h->poc.frame_num, sl->frame_num);
            frame_err=1;
             decode_err=1;
            return AVERROR_INVALIDDATA;
--
                er_add_slice(sl, sl->resync_mb_x, sl->resync_mb_y, sl->mb_x,
                             sl->mb_y, ER_MB_ERROR);
 frame_err = 1;

                return AVERROR_INVALIDDATA;
--
                av_log(h->avctx, AV_LOG_ERROR,
                       " errframe decode_err error while decoding MB %d %d\n", sl->mb_x, sl->mb_y);
                  frame_err = 1;
                  decode_err = 1;
                er_add_slice(sl, sl->resync_mb_x, sl->resync_mb_y, sl->mb_x,
./libavcodec/h264_slice.c
            mv_error++;
    }
    av_log(s->avctx, AV_LOG_INFO, "frame_err concealing %d DC, %d AC, %d MV errors in %c frame\n",
           dc_error, ac_error, mv_error, av_get_picture_type_char(s->cur_pic.f->pict_type));
    frame_err=1;
    is_intra_likely = is_intra_more_likely(s);

./libavcodec/error_resilience.c
#include "h264_parse.h"
#include "h264_ps.h"
int frame_err=0;
int ff_h264_pred_weight_table(GetBitContext *gb, const SPS *sps,
                              const int *ref_count, int slice_type_nos,
--
        if (mode < 0) {
            av_log(logctx, AV_LOG_ERROR,
                   "frame_err left block unavailable for requested intra mode\n");
            frame_err = 1;
            return AVERROR_INVALIDDATA;
        }
./libavcodec/h264_parse.c
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 216,843评论 6赞 502
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 92,538评论 3赞 392
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 163,187评论 0赞 353
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 58,264评论 1赞 292
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 67,289评论 6赞 390
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 51,231评论 1赞 299
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 40,116评论 3赞 418
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 38,945评论 0赞 275
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 45,367评论 1赞 313
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,581评论 2赞 333
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,754评论 1赞 348
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 35,458评论 5赞 344
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 41,068评论 3赞 327
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,692评论 0赞 22
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,842评论 1赞 269
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 47,797评论 2赞 369
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 44,654评论 2赞 354