From e0875bfe6196fdf4abdc7c099bbb59e7282f1b48 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期三, 22 五月 2019 13:38:04 +0800
Subject: [PATCH] update deliver
---
runShm2.go | 18 ++++++++++++++++--
1 files changed, 16 insertions(+), 2 deletions(-)
diff --git a/shm2.go b/runShm2.go
similarity index 80%
rename from shm2.go
rename to runShm2.go
index 791241d..34ea9df 100644
--- a/shm2.go
+++ b/runShm2.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)
}
--
Gitblit v1.8.0