big refacting of communitation architect

opencv-motion-detect/evdaemon.cpp

@@ -242,7 +242,6 @@ class EvDaemon{
         
     }
 
-
     int handleMsg(vector<vector<uint8_t> > &body)
     {
         int ret = 0;
@@ -287,7 +286,9 @@ class EvDaemon{
                 
                 spdlog::warn("evdaemon {} peer disconnected: {}", devSn, selfId);
                 // restart this module
-                startSubModule(selfId);
+                if(bBootstrap) {
+                    startSubModule(selfId);
+                }                
             }
 
             if(ret < 0) {

opencv-motion-detect/evpuller.cpp

@@ -246,16 +246,19 @@ protected:
     void run()
     {
         int ret = 0;
-        AVDictionary * optsIn;
-        av_dict_set(&optsIn, "timeout", "7", 0);
+        // AVDictionary * optsIn;
+        // av_dict_set(&optsIn, "timeout", "7", 0);
+        spdlog::info("evpuller {} openning stream: {}", selfId, urlIn);
         if ((ret = avformat_open_input(&pAVFormatInput, urlIn.c_str(), NULL, NULL)) < 0) {
             spdlog::error("Could not open input stream {}", urlIn);
         }
+
+        spdlog::info("evpuller {} finding sgtream info: {}", selfId, urlIn);
         if ((ret = avformat_find_stream_info(pAVFormatInput, NULL)) < 0) {
             spdlog::error("Failed to retrieve input stream information");
         }
 
-        pAVFormatInput->flags = AVFMT_FLAG_NOBUFFER | AVFMT_FLAG_FLUSH_PACKETS;
+        //pAVFormatInput->flags = AVFMT_FLAG_NOBUFFER | AVFMT_FLAG_FLUSH_PACKETS;
 
         numStreams = pAVFormatInput->nb_streams;
         int *streamList = (int *)av_mallocz_array(numStreams, sizeof(*streamList));

opencv-motion-detect/inc/av_common.hpp

@@ -191,7 +191,7 @@ int encode(AVFormatContext *ctx, char **bytes)
     wholeSize += strlen(PS_MARK_S);
     // num streams
     wholeSize += sizeof(ctx->nb_streams);
-    spdlog::info("encode sizeof streams: {:d}, {:d}", sizeof(ctx->nb_streams), ctx->nb_streams);
+    spdlog::info("encode num of streams: {:d}", ctx->nb_streams);
     for (int i = 0; i < ctx->nb_streams; i++)
     {
         wholeSize += sizeof(AVStream);