From e15f06954707abc5042a29664dbd71abdaea1be2 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期四, 16 一月 2020 16:38:47 +0800
Subject: [PATCH] debug reid shm as server
---
run.go | 4 ++--
rpc/recv.go | 4 ++--
rpc/send.go | 4 ++--
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/rpc/recv.go b/rpc/recv.go
index 2b0ca39..97e45b0 100644
--- a/rpc/recv.go
+++ b/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)
diff --git a/rpc/send.go b/rpc/send.go
index 70835d7..d861300 100644
--- a/rpc/send.go
+++ b/rpc/send.go
@@ -85,13 +85,13 @@
}
func (s *Sender) runShm(ctx context.Context) {
- c, err := deliver.NewClientWithError(deliver.Shm, s.ipcURL)
+ c, err := deliver.NewServerWithError(deliver.Shm, s.ipcURL)
for {
if err == nil {
break
}
time.Sleep(1 * time.Second)
- c, err = deliver.NewClientWithError(deliver.Shm, s.ipcURL)
+ c, err = deliver.NewServerWithError(deliver.Shm, s.ipcURL)
s.fnLogger("CLIENT CREATE FAILED : ", err)
}
s.run(ctx, c)
diff --git a/run.go b/run.go
index 290607d..95a9958 100644
--- a/run.go
+++ b/run.go
@@ -120,8 +120,8 @@
postPush = `_1`
)
- ipcSnd := url + postPush
- ipcRcv := url + postPull
+ ipcSnd := s.ipc + postPush
+ ipcRcv := s.ipc + postPull
sndURL := sdkhelper.GetIpcAddress(true, ipcSnd)
rcvURL := sdkhelper.GetIpcAddress(true, ipcRcv)
--
Gitblit v1.8.0