|
@@ -70,7 +70,9 @@ func main() {
|
|
|
|
|
|
|
|
KillRpcClient, err := rpc.Dial("tcp", config.LocalConfig.Node.Ip+":"+config.CloudConfig.RpcPort)
|
|
KillRpcClient, err := rpc.Dial("tcp", config.LocalConfig.Node.Ip+":"+config.CloudConfig.RpcPort)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
- c_log.GlobalLogger.Error("创建rpc客户端连接master失败：", err)
|
|
|
|
|
|
|
+ // 此处如果连接失败说明采集程序已经停止了
|
|
|
|
|
+ lastStatus = "NONE"
|
|
|
|
|
+ c_log.GlobalLogger.Error("说明采集程序已经停止：", err)
|
|
|
continue
|
|
continue
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -84,7 +86,6 @@ func main() {
|
|
|
lastStatus = status
|
|
lastStatus = status
|
|
|
c_log.GlobalLogger.Info("结束任务后，获取数据闭环平台最新配置。")
|
|
c_log.GlobalLogger.Info("结束任务后，获取数据闭环平台最新配置。")
|
|
|
config.InitPlatformConfig()
|
|
config.InitPlatformConfig()
|
|
|
- lastStatus = "NONE"
|
|
|
|
|
KillRpcClient.Close()
|
|
KillRpcClient.Close()
|
|
|
} else {
|
|
} else {
|
|
|
c_log.GlobalLogger.Error("未知的采集任务状态。【status】=", status)
|
|
c_log.GlobalLogger.Error("未知的采集任务状态。【status】=", status)
|
