bug fixed logs print copy

zhangmeng

2020-01-17 f7c4a3cfd07adede3308f8d9d3d7315427d90a7c

 rpc/send.go

@@ -57,13 +57,13 @@
               i.Close()
               s.fnLogger("ANALYSIS SENDER ERROR: ", err)

               c, err := deliver.NewClientWithError(deliver.Shm, s.ipcURL)
               c, err := deliver.NewServerWithError(deliver.Shm, s.ipcURL)
               for {
                  if err == nil {
                     break
                  }
                  time.Sleep(time.Second)
                  c, err = deliver.NewClientWithError(deliver.Shm, s.ipcURL)
                  c, err = deliver.NewServerWithError(deliver.Shm, s.ipcURL)
                  s.fnLogger("CLIENT CREATE FAILED : ", err)
               }
               i = c
@@ -85,13 +85,13 @@
}

func (s *Sender) runShm(ctx context.Context) {
   c, err := deliver.NewClientWithError(deliver.Shm, s.ipcURL)
   c, err := deliver.NewServerWithError(deliver.Shm, s.ipcURL)
   for {
      if err == nil {
         break
      }
      time.Sleep(1 * time.Second)
      c, err = deliver.NewClientWithError(deliver.Shm, s.ipcURL)
      c, err = deliver.NewServerWithError(deliver.Shm, s.ipcURL)
      s.fnLogger("CLIENT CREATE FAILED : ", err)
   }
   s.run(ctx, c)