From: Jaroslav Kysela <perex@perex.cz>
Date: Sat, 31 Jan 2015 15:53:07 +0000 (+0100)
Subject: dvr: use direct error flag handling
X-Git-Tag: v4.1~403
X-Git-Url: http://git.ipfire.org/gitweb.cgi?a=commitdiff_plain;h=e2f9483dbea13db6d7ee14dcf2d8a3dbc88a5127;p=thirdparty%2Ftvheadend.git

dvr: use direct error flag handling
---

diff --git a/src/dvr/dvr_rec.c b/src/dvr/dvr_rec.c
index 16c5ca539..bd1ac5421 100644
--- a/src/dvr/dvr_rec.c
+++ b/src/dvr/dvr_rec.c
@@ -501,17 +501,22 @@ dvr_thread(void *aux)
 
     if ((ts = de->de_s) != NULL && started) {
       pktbuf_t *pb = NULL;
-      if (sm->sm_type == SMT_PACKET)
+      if (sm->sm_type == SMT_PACKET) {
         pb = ((th_pkt_t*)sm->sm_data)->pkt_payload;
-      else if (sm->sm_type == SMT_MPEGTS)
+        if (((th_pkt_t*)sm->sm_data)->pkt_err) {
+          de->de_data_errors++;
+          idnode_notify_simple(&de->de_id);
+        }
+      }
+      else if (sm->sm_type == SMT_MPEGTS) {
         pb = sm->sm_data;
-      if (pb) {
-        atomic_add(&ts->ths_bytes_out, pktbuf_len(pb));
-        if (ts->ths_total_err != de->de_data_errors) {
-          de->de_data_errors = ts->ths_total_err;
+        if (pb->pb_err) {
+          de->de_data_errors += pb->pb_err;
           idnode_notify_simple(&de->de_id);
         }
       }
+      if (pb)
+        atomic_add(&ts->ths_bytes_out, pktbuf_len(pb));
     }
 
     TAILQ_REMOVE(&sq->sq_queue, sm, sm_link);