commit ab5a2261118c0e745d48dfedfee96bda30604c28
author pengfei.liu <pengfei.liu@amlogic.com> Fri Feb 14 17:33:40 2020 +0800
committer pengfei.liu <pengfei.liu@amlogic.com> Sat Feb 22 00:52:25 2020 +0800
tree 4ce17987ef83a3aa17c4957c2e275c6fcb9f3b6b
parent 3b1a820b0287054e4b629663086d9155ffac359e

dvr: implement clear pullvod record [1/1]

PD#SWPL-18817

Problem:
New feature

Solution:
implement clear pullvod record and
add PCR time index

Verify:
Android Q + AC214

Change-Id: Ib16a7990bd901d82132e72ac18792763e4226ba3
Signed-off-by: pengfei.liu <pengfei.liu@amlogic.com>

src/segment.c

diff --git a/src/segment.c b/src/segment.c
index 8503472..9bf4c12 100644
--- a/src/segment.c
+++ b/src/segment.c
@@ -19,6 +19,7 @@
   FILE            *dat_fp;                            /**< Information file fd*/
   uint64_t        first_pts;                          /**< First pts value, use for write mode*/
   uint64_t        last_pts;                           /**< Last pts value, use for write mode*/
+  uint64_t        cur_time;                           /**< Current time save in index file */
 } Segment_Context_t;
 
 /**\brief Segment file type*/
@@ -187,20 +188,24 @@
   DVR_RETURN_IF_FALSE(p_ctx->index_fp);
 
   if (p_ctx->first_pts == ULLONG_MAX) {
+    DVR_DEBUG(1, "%s first pcr:%llu", __func__, pts);
     p_ctx->first_pts = pts;
   }
   memset(buf, 0, sizeof(buf));
   if (p_ctx->last_pts == ULLONG_MAX) {
     /*Last pts is init value*/
     sprintf(buf, "{time=%llu, offset=%lld}\n", pts - p_ctx->first_pts, offset);
+    p_ctx->cur_time = pts - p_ctx->first_pts;
   } else {
     /*Last pts has valid value*/
     if (pts - p_ctx->last_pts > MAX_PTS_THRESHOLD) {
       /*Current pts has a transition*/
-      sprintf(buf, "{time=%llu, offset=%lld}\n", p_ctx->last_pts - p_ctx->first_pts, offset);
+      DVR_DEBUG(1, "Current pts has a transition, [%llu, %llu, %llu]",
+          p_ctx->first_pts, p_ctx->last_pts, pts);
     } else {
       /*This is a normal pts, record it*/
-      sprintf(buf, "{time=%llu, offset=%lld}\n", pts - p_ctx->first_pts, offset);
+      p_ctx->cur_time += (pts - p_ctx->last_pts);
+      sprintf(buf, "{time=%llu, offset=%lld}\n", p_ctx->cur_time, offset);
     }
   }
 
@@ -309,7 +314,7 @@
     }
 
     memset(buf, 0, sizeof(buf));
-    DVR_DEBUG(1, "time=%llu, offset=%lld, position=%lld\n", pts, offset, position);
+    //DVR_DEBUG(1, "time=%llu, offset=%lld, position=%lld\n", pts, offset, position);
     if (position < offset) {
       return pts;
     }
@@ -318,6 +323,7 @@
   return DVR_FAILURE;
 }
 
+/* Should consider the case of cut power, todo... */
 int segment_store_info(Segment_Handle_t handle, Segment_StoreInfo_t *p_info)
 {
   Segment_Context_t *p_ctx;
@@ -366,6 +372,7 @@
   return DVR_SUCCESS;
 }
 
+/* Should consider the case of cut power, todo... */
 int segment_load_info(Segment_Handle_t handle, Segment_StoreInfo_t *p_info)
 {
   Segment_Context_t *p_ctx;