From e796f659289cba74d93bfacb23722c11c04926f0 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期四, 16 一月 2020 17:00:12 +0800
Subject: [PATCH] debug reid shm as server 2
---
rpc/recv.go | 4 ++--
rpc/send.go | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/rpc/recv.go b/rpc/recv.go
index 97e45b0..e258029 100644
--- a/rpc/recv.go
+++ b/rpc/recv.go
@@ -56,13 +56,13 @@
i.Close()
r.fnLogger("ANALYSIS RECV ERROR: ", err)
- c, err := deliver.NewClientWithError(deliver.Shm, r.ipcURL)
+ c, err := deliver.NewServerWithError(deliver.Shm, r.ipcURL)
for {
if err == nil {
break
}
time.Sleep(time.Second)
- c, err = deliver.NewClientWithError(deliver.Shm, r.ipcURL)
+ c, err = deliver.NewServerWithError(deliver.Shm, r.ipcURL)
r.fnLogger("ANALYSIS CREATE FAILED : ", err)
}
i = c
diff --git a/rpc/send.go b/rpc/send.go
index d861300..7111a43 100644
--- a/rpc/send.go
+++ b/rpc/send.go
@@ -57,13 +57,13 @@
i.Close()
s.fnLogger("ANALYSIS SENDER ERROR: ", err)
- c, err := deliver.NewClientWithError(deliver.Shm, s.ipcURL)
+ c, err := deliver.NewServerWithError(deliver.Shm, s.ipcURL)
for {
if err == nil {
break
}
time.Sleep(time.Second)
- c, err = deliver.NewClientWithError(deliver.Shm, s.ipcURL)
+ c, err = deliver.NewServerWithError(deliver.Shm, s.ipcURL)
s.fnLogger("CLIENT CREATE FAILED : ", err)
}
i = c
--
Gitblit v1.8.0