restart evpusher evpuller evslicer evmlmotion when puller restarted

opencv-motion-detect/evmlmotion.cpp

@@ -161,7 +161,9 @@ private:
                             cvMsg.notify_one();
                         }
                         else {
-                            spdlog::warn("evmlmotion {} received avformatctx msg from {}, but already proceessed before, ignored. TODO: reinit", selfId, peerId);
+                            spdlog::warn("evmlmotion {} received avformatctx msg from {}, but already proceessed before, restarting", selfId, peerId);
+                            spdlog::error("evmlmotion {} restart since reinit", selfId);
+                            exit(0);
                         }
                         bProcessed = true;
                     }

opencv-motion-detect/evpusher.cpp

@@ -257,7 +257,9 @@ private:
                             cvMsg.notify_one();
                         }
                         else {
-                            spdlog::warn("evpusher {} received avformatctx msg from {}, but already proceessed before, ignored. TODO: reinit", selfId, peerId);
+                            spdlog::warn("evpusher {} received avformatctx msg from {}, but already proceessed before, restarting", selfId, peerId);
+                            spdlog::error("evpusher {} restart since reinit", selfId);
+                            exit(0);
                         }
                         bProcessed = true;
                     }

opencv-motion-detect/evslicer.cpp

@@ -92,7 +92,9 @@ private:
                         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);
+                        spdlog::warn("evslicer {} received avformatctx msg from {}, but already proceessed before, restarting", selfId, peerId);
+                        spdlog::error("evpusher {} restart since reinit", selfId);
+                        exit(0);
                     }
                 }
                 else if(meta == EV_MSG_META_EVENT) {