feature: multiple cameras clusters on one box

opencv-motion-detect/evmlmotion.cpp

@@ -100,6 +100,7 @@ private:
             msg +=body2str(b) + ";";
         }
 
+        // msg = msg.substr(0, msg.size()> 100? 15:msg.size());
         bool bProcessed = false;
         if(v.size() == 3) {
             try {
@@ -141,6 +142,8 @@ private:
             msg +=body2str(b) + ";";
         }
 
+        msg = msg.substr(0, msg.size()> EV_MSG_DEBUG_LEN? EV_MSG_DEBUG_LEN:msg.size());
+
         bool bProcessed = false;
         if(v.size() == 3) {
             try {
@@ -774,10 +777,6 @@ protected:
                 bStopSig = true;
                 break;
             }
-            // if(1 == getppid()) {
-            //     spdlog::error("evmlmotion {} exit since evdaemon is dead", selfId);
-            //     exit(1);
-            // }
 
             // business logic
             int ret =zmq_msg_init(&msg);

opencv-motion-detect/evpuller.cpp

@@ -129,7 +129,7 @@ private:
             string sMeta = body2str(v[1]);
             string peerId = body2str(v[0]);
             auto meta = json::parse(sMeta);
-            if(meta["type"].get<string>() == EV_MSG_META_AVFORMATCTX) {
+            if(meta["type"].get<string>() == EV_MSG_META_AVFORMATCTX && body2str(v[2]) == MSG_HELLO) {
                 sendAVInputCtxMsg(peerId);
             }
             else if(meta["type"].get<string>() == EV_MSG_META_EVENT) {
@@ -477,6 +477,8 @@ public:
                     for(auto &v: body) {
                         msg += body2str(v) + ",";
                     }
+
+                    msg = msg.substr(0, msg.size()> EV_MSG_DEBUG_LEN? EV_MSG_DEBUG_LEN:msg.size());
                     spdlog::info("evpuller {} received edge msg: {}", selfId, msg);
                     this->handleEdgeMsg(body);
                 }

opencv-motion-detect/evpusher.cpp

@@ -239,6 +239,8 @@ private:
             msg +=body2str(b) + ";";
         }
 
+        msg = msg.substr(0, msg.size()> EV_MSG_DEBUG_LEN? EV_MSG_DEBUG_LEN:msg.size());
+
         bool bProcessed = false;
         if(v.size() == 3) {
             try {

opencv-motion-detect/evslicer.cpp

@@ -86,6 +86,7 @@ private:
             msg +=body2str(b) + ";";
         }
 
+        msg = msg.substr(0, msg.size()> EV_MSG_DEBUG_LEN? EV_MSG_DEBUG_LEN:msg.size());
         if(v.size() == 3) {
             try {
                 peerId = body2str(v[0]);

opencv-motion-detect/inc/zmqhelper.hpp

@@ -22,6 +22,7 @@ using namespace std;
 using namespace nlohmann;
 
 namespace zmqhelper {
+#define EV_MSG_DEBUG_LEN 128
 #define EV_HEARTBEAT_SECONDS 30
 #define MSG_HELLO "hello"
 #define EV_MSG_META_PING "ping"