rpc/recv.go
@@ -95,13 +95,13 @@ } func (r *Reciever) runShm(ctx context.Context) { c, err := deliver.NewClientWithError(deliver.Shm, r.ipcURL) c, err := deliver.NewServerWithError(deliver.Shm, r.ipcURL) for { if err == nil { break } time.Sleep(1 * time.Second) c, err = deliver.NewClientWithError(deliver.Shm, r.ipcURL) c, err = deliver.NewServerWithError(deliver.Shm, r.ipcURL) r.fnLogger("CLIENT CREATE FAILED : ", err) } r.run(ctx, c)