revise getModulesOperFromConfDiff and related applications

opencv-motion-detect/evmlmotion.cpp

@@ -154,11 +154,15 @@ private:
                 else if(peerId == pullerGid) {
                     if(metaType == EV_MSG_META_AVFORMATCTX) {
                         lock_guard<mutex> lock(this->mutMsg);
-                        pAVFormatInput = (AVFormatContext *)malloc(sizeof(AVFormatContext));
-                        AVFormatCtxSerializer::decode((char *)(v[2].data()), v[2].size(), pAVFormatInput);
-                        gotFormat = true;
-                        bProcessed = true;
-                        cvMsg.notify_one();
+                        if(pAVFormatInput == nullptr) {
+                            pAVFormatInput = (AVFormatContext *)malloc(sizeof(AVFormatContext));
+                            AVFormatCtxSerializer::decode((char *)(v[2].data()), v[2].size(), pAVFormatInput);
+                            gotFormat = true;
+                            bProcessed = true;
+                            cvMsg.notify_one();
+                        }else{
+                            spdlog::warn("evmlmotion {} received avformatctx msg from {}, but already proceessed before, ignored. TODO: reinit", selfId, peerId);
+                        }
                     }
                 }
             }

opencv-motion-detect/evpusher.cpp

@@ -256,11 +256,16 @@ private:
                 else if(peerId == pullerGid) {
                     if(metaType == EV_MSG_META_AVFORMATCTX) {
                         lock_guard<mutex> lock(this->mutMsg);
-                        pAVFormatInput = (AVFormatContext *)malloc(sizeof(AVFormatContext));
-                        AVFormatCtxSerializer::decode((char *)(v[2].data()), v[2].size(), pAVFormatInput);
-                        gotFormat = true;
-                        bProcessed = true;
-                        cvMsg.notify_one();
+                        if(pAVFormatInput == nullptr) {
+                            pAVFormatInput = (AVFormatContext *)malloc(sizeof(AVFormatContext));
+                            AVFormatCtxSerializer::decode((char *)(v[2].data()), v[2].size(), pAVFormatInput);
+                            gotFormat = true;
+                            bProcessed = true;
+                            cvMsg.notify_one();
+                        }else{
+                            spdlog::warn("evpusher {} received avformatctx msg from {}, but already proceessed before, ignored. TODO: reinit", selfId, peerId);
+                        }
+                        
                     }
                 }
             }

opencv-motion-detect/evslicer.cpp

@@ -91,11 +91,15 @@ private:
                 meta = json::parse(body2str(v[1]))["type"];
                 if(meta == EV_MSG_META_AVFORMATCTX) {
                     lock_guard<mutex> lock(this->mutMsg);
-                    pAVFormatInput = (AVFormatContext *)malloc(sizeof(AVFormatContext));
-                    AVFormatCtxSerializer::decode((char *)(v[2].data()), v[2].size(), pAVFormatInput);
-                    gotFormat = true;
-                    cvMsg.notify_one();
-                    spdlog::info("evslicer {} got avformat from {}", selfId, peerId);
+                    if(pAVFormatInput == nullptr) {
+                        pAVFormatInput = (AVFormatContext *)malloc(sizeof(AVFormatContext));
+                        AVFormatCtxSerializer::decode((char *)(v[2].data()), v[2].size(), pAVFormatInput);
+                        gotFormat = true;
+                        cvMsg.notify_one();
+                        spdlog::info("evslicer {} got avformat from {}", selfId, peerId);
+                    }else{
+                        spdlog::warn("evslicer {} received avformatctx msg from {}, but already proceessed before, ignored. TODO: reinit", selfId, peerId);
+                    }                    
                 }
                 else if(meta == EV_MSG_META_EVENT) {
                     data = json::parse(body2str(v[2]));