commit 02e890c76cb106366d07cb4ce0c677236d3a8965
author Zhiqiang Han <zhiqiang.han@amlogic.com> Tue Apr 25 14:55:02 2023 +0800
committer Zhiqiang Han <zhiqiang.han@amlogic.com> Tue Apr 25 14:55:02 2023 +0800
tree d7df735742110188b35067ec1adcec7157c65ec0
parent f35c38895baccffae3248e06d6648bd37fb63428

rec: optimize for speed [1/1]

PD#SWPL-120895

Problem:
process slow

Solution:
1. remove redundant operation
2. replace pipe processes with std api

Verify:
PB

Change-Id: I9cfb6ccb8029580e7d43a348984ce1eb68e1924b
Signed-off-by: Zhiqiang Han <zhiqiang.han@amlogic.com>

src/dvr_segment.c

diff --git a/src/dvr_segment.c b/src/dvr_segment.c
index e0f0967..95ca2b6 100644
--- a/src/dvr_segment.c
+++ b/src/dvr_segment.c
@@ -6,6 +6,7 @@
 #include <pthread.h>
 #include "dvr_segment.h"
 #include <segment.h>
+#include <dirent.h>
 
 /**\brief DVR segment file information*/
 typedef struct {
@@ -64,6 +65,7 @@
 
 int dvr_segment_del_by_location(const char *location)
 {
+#if 0
   FILE *fp;
   char cmd[DVR_MAX_LOCATION_SIZE * 2 + 64];
 
@@ -78,6 +80,61 @@
     DVR_RETURN_IF_FALSE(fp);
   }
   pclose(fp);
+#else
+  DVR_RETURN_IF_FALSE(location);
+
+  DVR_INFO("%s location:%s", __func__, location);
+
+  DIR *dir; // pointer to directory
+  struct dirent *entry; // pointer to file entry
+  char *ext; // pointer to file extension
+  char *loc_dname;
+  int loc_dname_len;
+  char *loc_fname;
+  int loc_fname_len;
+  char *path;
+  int path_size;
+
+  /*get the dirname and filename*/
+  loc_fname = strrchr(location, '/');// fine last slash
+  loc_fname_len = strlen(loc_fname);
+  DVR_RETURN_IF_FALSE(loc_fname_len != 0);
+
+  loc_dname_len = loc_fname - location;
+  loc_dname = malloc(loc_dname_len + 1);
+  DVR_RETURN_IF_FALSE(loc_dname != NULL);
+  memcpy(loc_dname, location, loc_dname_len);
+  loc_dname[loc_dname_len] = '\0';
+
+  path_size = strlen(location) + 32;//assume the file ext is no more than 32 bytes
+  path = malloc(path_size);
+  if (path) {
+    dir = opendir(loc_dname); // open directory
+    if (dir != NULL) {
+      while ((entry = readdir(dir)) != NULL) { // read each file entry
+        if (entry->d_type == DT_REG) { // only regular files
+          if (strncmp(entry->d_name, loc_fname, loc_fname_len) == 0) {
+            snprintf(path, path_size, "%s/%s", loc_dname, entry->d_name);
+            if (remove(path) != 0) {
+              DVR_INFO("%s cannot delete file:%s", __func__, path);
+            }
+          }
+        }
+      }
+      closedir(dir); // close directory
+    } else {
+      DVR_INFO("%s location:%s canot open", __func__, location);
+    }
+    free(path);
+
+  } else {
+
+    free(loc_dname);
+    DVR_INFO("%s mem fail", __func__);
+  }
+
+  free(loc_dname);
+#endif
   DVR_INFO("%s location:%s end", __func__, location);
   return DVR_SUCCESS;
 }

src/dvr_wrapper.c

diff --git a/src/dvr_wrapper.c b/src/dvr_wrapper.c
index 0bb6bc3..197bbb1 100644
--- a/src/dvr_wrapper.c
+++ b/src/dvr_wrapper.c
@@ -1235,7 +1235,8 @@
 
   //wait for the file status to stabilize before set the new segment id
   uint64_t new_segment_id = 0;
-  {
+
+  if (params->save_rec_file != 0) {
     uint32_t segment_nb = 0;
     uint64_t *p_segment_ids = NULL;
     error = dvr_segment_get_list(ctx->record.param_open.location, &segment_nb, &p_segment_ids);
@@ -1248,8 +1249,9 @@
     if (p_segment_ids != NULL) {
       free(p_segment_ids);
     }
-    DVR_WRAPPER_DEBUG("new_segment_id:%lld\n", new_segment_id);
   }
+  DVR_WRAPPER_DEBUG("new_segment_id:%lld\n", new_segment_id);
+
   ctx->record.next_segment_id = new_segment_id;
   ctx->current_segment_id = new_segment_id;