From 77a05fa27d55ea7e39aee47f71cb5f74308e5e0e Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期五, 30 八月 2019 11:08:06 +0800
Subject: [PATCH] stop bigcache init
---
ruleserver/readyDataForRule.go | 10 ++++------
1 files changed, 4 insertions(+), 6 deletions(-)
diff --git a/ruleserver/readyDataForRule.go b/ruleserver/readyDataForRule.go
index 4511ea0..b99c2be 100644
--- a/ruleserver/readyDataForRule.go
+++ b/ruleserver/readyDataForRule.go
@@ -1,23 +1,21 @@
package ruleserver
import (
- bigCache "basic.com/pubsub/cache.git"
"basic.com/pubsub/cache.git/esutil"
"basic.com/pubsub/protomsg.git"
"encoding/json"
"errors"
"fmt"
"github.com/go-yaml/yaml"
+ "github.com/golang/protobuf/proto"
"io/ioutil"
"math"
"nanomsg.org/go-mangos"
"nanomsg.org/go-mangos/protocol/req"
"nanomsg.org/go-mangos/transport/tcp"
"net"
- "os"
"ruleprocess/cache"
"ruleprocess/logger"
- "github.com/golang/protobuf/proto"
"ruleprocess/structure"
"strconv"
"time"
@@ -52,7 +50,7 @@
logger.Error("鏌ヨ鏈満淇℃伅澶辫触锛�")
}
logger.Debug("鏈満淇℃伅鍜宻erver淇℃伅锛�", localConfig, serverIp, serverPort)
- bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId)
+ //bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId)
sock, err = req.NewSocket();
if err != nil {
logger.Error("鍒涘缓璇锋眰socket澶辫触: %s", err.Error())
@@ -337,11 +335,11 @@
//bytes := []byte("ndfasojdfaidsos")
if err = sock.Send(bytes); err != nil {
logger.Error("鎺ㄩ�乻ocket鍙戦�佹暟鎹け璐�: %s", err.Error())
- os.Exit(1)
+ //os.Exit(1)
}
if msg, err = sock.Recv(); err != nil {
logger.Error("鎺ユ敹鍝嶅簲澶辫触: %s", err.Error())
- os.Exit(1)
+ //os.Exit(1)
}
logger.Debug("鏁版嵁鎺ㄩ�佹垚鍔燂紒鏀跺埌鍝嶅簲,鏁版嵁闀垮害涓猴細",len(msg))
return msg
--
Gitblit v1.8.0