去掉推送中的失败即退出

panlei

2019-10-25 a9058916c1ae79f36fc6cabc367f25ec2fe0bea4

去掉推送中的失败即退出

 labelFilter/req.go

@@ -9,14 +9,13 @@
    "nanomsg.org/go-mangos/protocol/req"
    "nanomsg.org/go-mangos/transport/ipc"
    "nanomsg.org/go-mangos/transport/tcp"
    "os"
    "ruleprocess/structure"
    "time"
)

func Die(format string, v ...interface{}) {
    logger.Info("+++++++",format)
    os.Exit(1)
    //os.Exit(1)
}

func date() string {
@@ -66,9 +65,9 @@
        fmt.Errorf("Failed set MaxRecvSize: %v", err)
        return
    }
    errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 500)
    errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 3000)
    if errTimeOut != nil {
        fmt.Errorf("Failed set MaxRecvSize: %v", err)
        fmt.Errorf("Failed set MaxRecvDeadline: %v", err)
        return
    }
    //sock.AddTransport(ipc.NewTransport())