From e98330371e72127945f974eaddef9d53a1a74f2b Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期二, 10 九月 2019 18:06:31 +0800
Subject: [PATCH] update call compare
---
ruleserver/readyDataForRule.go | 7 +++----
1 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/ruleserver/readyDataForRule.go b/ruleserver/readyDataForRule.go
index a641688..e4430c7 100644
--- a/ruleserver/readyDataForRule.go
+++ b/ruleserver/readyDataForRule.go
@@ -51,7 +51,7 @@
}
logger.Debug("鏈満淇℃伅鍜宻erver淇℃伅锛�", localConfig, serverIp, serverPort)
bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId)
- Push1()
+ go Push1()
}
var sender chan *protomsg.CompareArgs = make(chan *protomsg.CompareArgs)
@@ -386,13 +386,12 @@
if errSize != nil {
logger.Error("Failed set MaxRecvSize: %v", err)
}
+ //sock.AddTransport(ipc.NewTransport())
+ sock.AddTransport(tcp.NewTransport())
serverIP, _ := GetLocalIP()
if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: %s", err.Error())
}
- //sock.AddTransport(ipc.NewTransport())
- sock.AddTransport(tcp.NewTransport())
-
logger.Info("搴忓垪鍖栨暟鎹�")
for {
--
Gitblit v1.8.0