From f7c4a3cfd07adede3308f8d9d3d7315427d90a7c Mon Sep 17 00:00:00 2001
From: zhangmeng <zhangmeng@aiotlink.com>
Date: 星期五, 17 一月 2020 09:40:08 +0800
Subject: [PATCH] bug fixed logs print copy
---
rpc/recv.go | 22 +++++++++++++---------
1 files changed, 13 insertions(+), 9 deletions(-)
diff --git a/rpc/recv.go b/rpc/recv.go
index 97e45b0..f2bfc60 100644
--- a/rpc/recv.go
+++ b/rpc/recv.go
@@ -8,7 +8,7 @@
"basic.com/valib/deliver.git"
)
-const mode = deliver.Shm
+const mode = deliver.PushPull
// Reciever recv from ipc
type Reciever struct {
@@ -54,19 +54,19 @@
if r.shm {
if d, err := i.Recv(); err != nil {
i.Close()
- r.fnLogger("ANALYSIS RECV ERROR: ", err)
+ r.fnLogger("Reciever RECV ERROR: ", err)
- c, err := deliver.NewClientWithError(deliver.Shm, r.ipcURL)
+ c, err := deliver.NewServerWithError(deliver.Shm, r.ipcURL)
for {
if err == nil {
break
}
+ r.fnLogger("Reciever CREATE FAILED : ", err)
time.Sleep(time.Second)
- c, err = deliver.NewClientWithError(deliver.Shm, r.ipcURL)
- r.fnLogger("ANALYSIS CREATE FAILED : ", err)
+ c, err = deliver.NewServerWithError(deliver.Shm, r.ipcURL)
}
i = c
- r.fnLogger("ANALYSIS CREATE SHM")
+ r.fnLogger("Reciever CREATE SHM")
} else {
if d != nil {
count++
@@ -74,7 +74,9 @@
count = 0
r.fnLogger("~~~shm recv image:", len(d))
}
- r.out <- d
+ if len(d) > 2 {
+ r.out <- d
+ }
}
}
} else {
@@ -86,7 +88,9 @@
count = 0
r.fnLogger("~~~mangos recv image:", len(msg))
}
- r.out <- msg
+ if len(msg) > 2 {
+ r.out <- msg
+ }
}
}
time.Sleep(10 * time.Millisecond)
@@ -100,9 +104,9 @@
if err == nil {
break
}
+ r.fnLogger("Reciever CLIENT CREATE FAILED : ", err)
time.Sleep(1 * time.Second)
c, err = deliver.NewServerWithError(deliver.Shm, r.ipcURL)
- r.fnLogger("CLIENT CREATE FAILED : ", err)
}
r.run(ctx, c)
}
--
Gitblit v1.8.0