evdameon, evcloudsvc: subsystem monitor thread and defered uploading

opencv-motion-detect/evdaemon.cpp

@@ -454,14 +454,22 @@ private:
     int sendCmd2Peer(string peerId, string cmdVal, string msg)
     {
         json meta;
+        int ret = 0;
         meta["type"] = EV_MSG_META_TYPE_CMD;
         meta["value"] = cmdVal;
-        int ret = z_send(pRouter, peerId, this->daemonId, meta, msg);
-        if(ret < 0) {
-            spdlog::error("evdaemon {} failed to send msg to peer {}: {} - {}", devSn, peerId, meta.dump(), msg);
-        }
-        else {
-            spdlog::info("evdaemon {} successfully send msg to peer {}: {} - {}", devSn, peerId, meta.dump(), msg);
+        if(msg == "0"){
+            auto sp = strutils::split(peerId, ':');
+            if(sp.size() == 3){
+                system((string("pkill -9 ") + sp[1]).c_str());
+            }
+        }else{
+            ret = z_send(pRouter, peerId, this->daemonId, meta, msg);
+            if(ret < 0) {
+                spdlog::error("evdaemon {} failed to send msg to peer {}: {} - {}", devSn, peerId, meta.dump(), msg);
+            }
+            else {
+                spdlog::info("evdaemon {} successfully send msg to peer {}: {} - {}", devSn, peerId, meta.dump(), msg);
+            }
         }
         return ret;
     }

opencv-motion-detect/inc/zmqhelper.cpp

@@ -207,7 +207,7 @@ int forkSubsystem(string devSn, string peerId, int drPort, pid_t &pid){
     auto v = strutils::split(peerId, ':');
     string modName = v[1];
     string sn = v[0];
-    system(string("killall " + modName).c_str());
+    system(string("pkill -9 " + modName).c_str());
     if( (pid = fork()) == -1 ) {
         spdlog::error("evdamon {} failed to fork subsytem: {}", devSn, peerId);
         return -1;