init

opencv-motion-detect/evmgr.cpp

@@ -315,7 +315,7 @@ public:
 int main(int argc, const char *argv[])
 {
     av_log_set_level(AV_LOG_ERROR);
-    spdlog::set_level(spdlog::level::debug);
+    spdlog::set_level(spdlog::level::info);
     EvMgr mgr;
     mgr.join();
     return 0;

opencv-motion-detect/evmlmotion.cpp

@@ -569,8 +569,8 @@ protected:
                 }
             }
             zmq_msg_close(&msg);
-            if(pktCnt % 1024 == 0) {
-                spdlog::info("seq: {}, pts: {}, dts: {}, dur: {}, idx: {}", pktCnt, packet.pts, packet.dts, packet.duration, packet.stream_index);
+            if(pktCnt % EV_LOG_PACKET_CNT == 0) {
+                spdlog::info("seq: {}, pts: {}, dts: {}, idx: {}", pktCnt, packet.pts, packet.dts, packet.stream_index);
             }
             pktCnt++;
 

opencv-motion-detect/evpuller.cpp

@@ -296,7 +296,7 @@ protected:
                 av_packet_unref(&packet);
                 continue;
             }
-            if(pktCnt % 1024 == 0) {
+            if(pktCnt % EV_LOG_PACKET_CNT == 0) {
                 spdlog::info("pktCnt: {:d}", pktCnt);
             }
 

opencv-motion-detect/evpusher.cpp

@@ -351,8 +351,12 @@ protected:
                 continue;
             }
 
-            // decode
+            if(pktCnt % EV_LOG_PACKET_CNT == 0) {
+                spdlog::info("seq: {}, pts: {}, dts: {}, idx: {}", pktCnt, packet.pts, packet.dts, packet.stream_index);
+            }
+
             pktCnt++;
+            // decode
             ret = AVPacketSerializer::decode((char*)zmq_msg_data(&msg), ret, &packet);
             {
                 if (ret < 0) {
@@ -369,10 +373,6 @@ protected:
             packet.stream_index = streamList[packet.stream_index];
             out_stream = pAVFormatRemux->streams[packet.stream_index];
 
-            //calc pts
-            if(pktCnt % (18*60*5) == 0) {
-                spdlog::info("seq: {:lld}, pts: {:lld}, dts: {:lld}, dur: {:lld}, idx: {:d}", pktCnt, packet.pts, packet.dts, packet.duration, packet.stream_index);
-            }
             /* copy packet */
             if(pktCnt == 0) {
                 packet.pts = 0;

opencv-motion-detect/evslicer.cpp

@@ -402,8 +402,8 @@ protected:
                 out_stream = pAVFormatRemux->streams[packet.stream_index];
                 //calc pts
 
-                if(pktCnt % 1024 == 0) {
-                    spdlog::info("seq: {}, pts: {}, dts: {}, dur: {}, idx: {}", pktCnt, packet.pts, packet.dts, packet.duration, packet.stream_index);
+                if(pktCnt % EV_LOG_PACKET_CNT == 0) {
+                    spdlog::info("seq: {}, pts: {}, dts: {}, idx: {}", pktCnt, packet.pts, packet.dts, packet.stream_index);
                 }
                 /* copy packet */
                 if(pktCnt == 0) {
@@ -481,6 +481,7 @@ public:
 
 int main(int argc, const char *argv[])
 {
+    av_log_set_level(AV_LOG_ERROR);
     spdlog::set_level(spdlog::level::info);
     EvSlicer es;
     es.join();

opencv-motion-detect/inc/common.hpp

@@ -17,6 +17,8 @@ using json = nlohmann::json;
 #define PS_MARK_E "DEADBEEF"
 #define PS_MARK_S "BEEFDEAD"
 
+#define EV_LOG_PACKET_CNT (18*60*5)
+
 void avlogThrow(void *avcl, int lvl, const char *fmt, ...)
 {
     (void)avcl;