update deliver

zhangmeng

2019-05-22 e0875bfe6196fdf4abdc7c099bbb59e7282f1b48

 runShm.go

File was renamed from shm.go
@@ -38,8 +38,15 @@
}

func shmSender(url string, args ...interface{}) {
   s := deliver.NewServer(deliver.Shm, url, args...)

   s, err := deliver.NewServerWithError(deliver.Shm, url, args...)
   for {
      if err == nil {
         break
      }
      fmt.Println("create shm error : ", err)
      time.Sleep(1 * time.Second)
      s, err = deliver.NewServerWithError(deliver.Shm, url, args)
   }
   go shmSenderImpl(s)

   c := make(chan os.Signal, 1)
@@ -97,7 +104,15 @@
   var cs []deliver.Deliver
   for i := 0; i < count; i++ {
      wg.Add(1)
      c := deliver.NewClient(deliver.Shm, url)
      c, err := deliver.NewClientWithError(deliver.Shm, url)
      for {
         if err == nil {
            break
         }
         time.Sleep(1 * time.Second)
         c, err = deliver.NewClientWithError(deliver.Shm, url)
         fmt.Println(i, " client create failed : ", err)
      }
      cs = append(cs, c)
      go shmRecvImpl(&wg, c, url, i)
   }