From ffd71d97fc9eb5236e6a92db408745ddf080217b Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期一, 06 五月 2019 13:28:05 +0800
Subject: [PATCH] 整理代码
---
analysis/work/service/ipcreciever.go | 21 ++++++++++++---------
1 files changed, 12 insertions(+), 9 deletions(-)
diff --git a/analysis/work/service/reciever.go b/analysis/work/service/ipcreciever.go
similarity index 81%
rename from analysis/work/service/reciever.go
rename to analysis/work/service/ipcreciever.go
index b952d99..68e1147 100644
--- a/analysis/work/service/reciever.go
+++ b/analysis/work/service/ipcreciever.go
@@ -53,21 +53,24 @@
}
}
-// Run run task from ipc data
-func (r *Reciever) Run(asServer bool) {
- var i *ipc.IPC
- if asServer {
- i = ipc.NewServer(r.ctxIPC.ctx, r.ipcURL)
- } else {
- i = ipc.NewClient(r.ctxIPC.ctx, r.ipcURL)
- }
-
+func (r *Reciever) run(i *ipc.IPC) {
dataChan := make(chan []byte)
go unserilizeImageInfo(dataChan, r.chImage)
i.RecvToChannel(dataChan)
}
+// RunAsServer run a IPC server
+func (r *Reciever) RunAsServer() {
+ r.run(ipc.NewServer(r.ctxIPC.ctx, r.ipcURL))
+
+}
+
+// RunAsClient run as a IPC client
+func (r *Reciever) RunAsClient() {
+ r.run(ipc.NewClient(r.ctxIPC.ctx, r.ipcURL))
+}
+
// Stop stop reciever, run in goroutine
func (r *Reciever) Stop() {
if r.ctxIPC.cancel != nil {
--
Gitblit v1.8.0