update deliver

zhangmeng

2019-05-22 e0875bfe6196fdf4abdc7c099bbb59e7282f1b48

 runShm2.go

File was renamed from shm2.go
@@ -37,7 +37,14 @@
}

func shmReciever2(url string, count int, args ...interface{}) {
   s := deliver.NewServer(deliver.Shm, url, args...)
   s, err := deliver.NewServerWithError(deliver.Shm, url, args...)
   for {
      if err == nil {
         break
      }
      time.Sleep(1 * time.Second)
      s, err = deliver.NewServerWithError(deliver.Shm, url, args...)
   }

   go shmRecvImpl2(s, 0)

@@ -92,7 +99,14 @@

   var cs []deliver.Deliver
   for i := 0; i < count; i++ {
      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)
      }
      cs = append(cs, c)
      go shmSenderImpl2(c)
   }