zhangmeng
2019-08-27 9c770865849b34ea48f66763aa11a83a10aa457c
profile/shmsend.go
@@ -22,20 +22,21 @@
         return
      default:
         if err = s.Send(buf); err != nil {
            s.Close()
            url := "hello"
            i, err := deliver.NewClientWithError(deliver.Shm, url)
            for {
               if err == nil {
                  break
               }
               time.Sleep(1 * time.Second)
               i, err = deliver.NewClientWithError(deliver.Shm, url)
               fmt.Println("client create failed : ", err)
            // s.Close()
            // url := "hello"
            // i, err := deliver.NewClientWithError(deliver.Shm, url)
            // for {
            //    if err == nil {
            //       break
            //    }
            //    time.Sleep(1 * time.Second)
            //    i, err = deliver.NewClientWithError(deliver.Shm, url)
            }
            s = i
            //    fmt.Println("client create failed : ", err)
            // }
            // s = i
            fmt.Printf("can't send message on push socket: %s\n", err.Error())
         } else {