files ring

opencv-motion-detect/evmgr.cpp

@@ -322,6 +322,9 @@ error_exit:
                             }
                         }
                         bProcessed = true;
+                    }else if(jmeta["type"] == EV_MSG_META_AVFORMATCTX) {
+                        bProcessed = true;
+                        // ignore;
                     }
                 }catch(exception &e) {
                     bProcessed = false;

opencv-motion-detect/evmlmotion.cpp

@@ -158,11 +158,11 @@ private:
                             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);
                         }
+                        bProcessed = true;
                     }
                 }
             }

opencv-motion-detect/evpusher.cpp

@@ -260,12 +260,11 @@ private:
                             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);
                         }
-                        
+                        bProcessed = true;
                     }
                 }
             }