bug fixed logs print copy

zhangmeng

2020-01-17 f7c4a3cfd07adede3308f8d9d3d7315427d90a7c

 rpc/recv.go

@@ -8,7 +8,7 @@
   "basic.com/valib/deliver.git"
)

const mode = deliver.Shm
const mode = deliver.PushPull

// Reciever recv from ipc
type Reciever struct {
@@ -54,19 +54,19 @@
         if r.shm {
            if d, err := i.Recv(); err != nil {
               i.Close()
               r.fnLogger("ANALYSIS RECV ERROR: ", err)
               r.fnLogger("Reciever RECV ERROR: ", err)

               c, err := deliver.NewServerWithError(deliver.Shm, r.ipcURL)
               for {
                  if err == nil {
                     break
                  }
                  r.fnLogger("Reciever CREATE FAILED : ", err)
                  time.Sleep(time.Second)
                  c, err = deliver.NewServerWithError(deliver.Shm, r.ipcURL)
                  r.fnLogger("ANALYSIS CREATE FAILED : ", err)
               }
               i = c
               r.fnLogger("ANALYSIS CREATE SHM")
               r.fnLogger("Reciever CREATE SHM")
            } else {
               if d != nil {
                  count++
@@ -74,7 +74,9 @@
                     count = 0
                     r.fnLogger("~~~shm recv image:", len(d))
                  }
                  r.out <- d
                  if len(d) > 2 {
                     r.out <- d
                  }
               }
            }
         } else {
@@ -86,7 +88,9 @@
                  count = 0
                  r.fnLogger("~~~mangos recv image:", len(msg))
               }
               r.out <- msg
               if len(msg) > 2 {
                  r.out <- msg
               }
            }
         }
         time.Sleep(10 * time.Millisecond)
@@ -100,9 +104,9 @@
      if err == nil {
         break
      }
      r.fnLogger("Reciever CLIENT CREATE FAILED : ", err)
      time.Sleep(1 * time.Second)
      c, err = deliver.NewServerWithError(deliver.Shm, r.ipcURL)
      r.fnLogger("CLIENT CREATE FAILED : ", err)
   }
   r.run(ctx, c)
}