evdameon, evcloudsvc: subsystem monitor thread and defered uploading

opencv-motion-detect/evdaemon.cpp

@@ -379,7 +379,12 @@ private:
                         spdlog::info("evdaemon {} failed to create subsystem {}", devSn, k);
                     }
                 }
+
                 this->bColdStart = false;
+                {
+                    lock_guard<mutex> lock(this->mutSubMonitor);
+                    this->cvSubMonitor.notify_all();
+                }
             }
             else {
                 // calc diff
@@ -1076,74 +1081,76 @@ public:
             while(true){
                 {
                     unique_lock<mutex> lk(this->mutSubMonitor);
-                    this->cvSubMonitor.wait_for(lk, 5s, [this] {return !this->bColdStart;});
-
-                    vector<string> tmp;
-                    json unkown;
-                    vector<string> terms;
-                    string info;
-                    json ret;
-                    int cnt = 0;
-                    for(auto &[k,v]: this->peerData["config"].items()) {
-                        if(this->peerData["enabled"].count(k) != 0 && this->peerData["enabled"][k] != 0) {
-                            if((this->peerData["status"].count(k) == 0 || this->peerData["status"][k] == 0)) {
-                                tmp.push_back(k);
-                                info += (cnt == 0? "" : string(", ")) + k;
-                            }
-                            else if(this->peerData["status"][k] == -1) {
-                                unkown[k] = -1;
-                            }
-                        }
-                        else {
-                            terms.push_back(k);
-                        }
-                        cnt++;
-                    }
+                    this->cvSubMonitor.wait(lk, [this] {return !this->bColdStart;});
+                }
 
-                    spdlog::info("evdaemon {} will start following subsystems: {}", devSn, info);
-                    //
-                    for(string &e : tmp) {
-                        pid_t pid = 0;
-                        this->peerData["status"][e] = 0;
-                        ret = zmqhelper::forkSubsystem(devSn, e, portRouter, pid);
-                        if(0 == ret) {
-                            this->peerData["pids"][e] = pid;
-                            spdlog::info("evdaemon {} created subsystem {}", devSn, e);
+                /// anti frequent restart
+                this_thread::sleep_for(10s);
+                vector<string> tmp;
+                json unkown;
+                vector<string> terms;
+                string info;
+                json ret;
+                int cnt = 0;
+                for(auto &[k,v]: this->peerData["config"].items()) {
+                    if(this->peerData["enabled"].count(k) != 0 && this->peerData["enabled"][k] != 0) {
+                        if((this->peerData["status"].count(k) == 0 || this->peerData["status"][k] == 0)) {
+                            tmp.push_back(k);
+                            info += (cnt == 0? "" : string(", ")) + k;
                         }
-                        else {
-                            spdlog::info("evdaemon {} failed to create subsystem {}", devSn, e);
+                        else if(this->peerData["status"][k] == -1) {
+                            unkown[k] = -1;
                         }
                     }
+                    else {
+                        terms.push_back(k);
+                    }
+                    cnt++;
+                }
 
-                    for(string &e: terms) {
-                        if(this->peerData["pids"].count(e) != 0) {
-                            kill(this->peerData["pids"][e], SIGTERM);
-                        }
+                spdlog::info("evdaemon {} will start following subsystems: {}", devSn, info);
+                //
+                for(string &e : tmp) {
+                    pid_t pid = 0;
+                    this->peerData["status"][e] = 0;
+                    ret = zmqhelper::forkSubsystem(devSn, e, portRouter, pid);
+                    if(0 == ret) {
+                        this->peerData["pids"][e] = pid;
+                        spdlog::info("evdaemon {} created subsystem {}", devSn, e);
                     }
+                    else {
+                        spdlog::info("evdaemon {} failed to create subsystem {}", devSn, e);
+                    }
+                }
 
-                    while(unkown.size() != 0 && cnt < 3) {
-                        this_thread::sleep_for(chrono::seconds(3));
-                        for(auto &[k,v]: unkown.items()) {
-                            if(this->peerData["status"][k] != -1 && this->peerData["status"][k] != 0) {
-                                // no need to start
-                                unkown.erase(k);
-                            }
-                        }
-                        cnt++;
+                for(string &e: terms) {
+                    if(this->peerData["pids"].count(e) != 0) {
+                        kill(this->peerData["pids"][e], SIGTERM);
                     }
+                }
 
+                while(unkown.size() != 0 && cnt < 3) {
+                    this_thread::sleep_for(chrono::seconds(3));
                     for(auto &[k,v]: unkown.items()) {
-                        pid_t pid = 0;
-                        this->peerData["status"][k] = 0;
-                        ret = zmqhelper::forkSubsystem(devSn, k, portRouter, pid);
-                        if(0 == ret) {
-                            this->peerData["pids"][k] = pid;
-                            spdlog::info("evdaemon {} created subsystem {}", devSn, k);
-                        }
-                        else {
-                            spdlog::info("evdaemon {} failed to create subsystem {}", devSn, k);
+                        if(this->peerData["status"][k] != -1 && this->peerData["status"][k] != 0) {
+                            // no need to start
+                            unkown.erase(k);
                         }
                     }
+                    cnt++;
+                }
+
+                for(auto &[k,v]: unkown.items()) {
+                    pid_t pid = 0;
+                    this->peerData["status"][k] = 0;
+                    ret = zmqhelper::forkSubsystem(devSn, k, portRouter, pid);
+                    if(0 == ret) {
+                        this->peerData["pids"][k] = pid;
+                        spdlog::info("evdaemon {} created subsystem {}", devSn, k);
+                    }
+                    else {
+                        spdlog::info("evdaemon {} failed to create subsystem {}", devSn, k);
+                    }
                 }
             }
         });