panlei
2019-08-22 eaab6d509a94dad4c4082d09602fa84028bec8a7
not exit
1个文件已修改
7 ■■■■■ 已修改文件
ruleserver/readyDataForRule.go 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruleserver/readyDataForRule.go
@@ -8,16 +8,15 @@
    "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"
@@ -337,11 +336,11 @@
    //bytes := []byte("ndfasojdfaidsos")
    if err = sock.Send(bytes); err != nil {
        logger.Error("推送socket发送数据失败: %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