From ed038f1e3261af1bd98148afb893524908cc41ed Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期二, 04 二月 2020 10:58:56 +0800
Subject: [PATCH] remove to rule process ipc
---
rpc/recv.go | 10 +++++++---
1 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/rpc/recv.go b/rpc/recv.go
index 3a67145..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 {
@@ -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)
--
Gitblit v1.8.0