commit

kinglong/control/main/control.go

@@ -86,6 +86,7 @@ func main() {
 				continue
 			}
 			// 获取一下最新配置
+			c_log.GlobalLogger.Info("获取数据闭环平台最新配置。")
 			cfg.InitPlatformConfig()
 			KillRpcClientMaster.Close()
 			KillRpcClientSlave.Close()

pji/control/main/control.go

@@ -65,15 +65,16 @@ func main() {
 			reply := 0
 			err = KillRpcClient.Call("KillService.Kill", masterArgs, &reply)
 			if err != nil {
-				c_log.GlobalLogger.Error("发送rpc请求到master失败：", err)
-				KillRpcClient.Close()
-				continue
+				c_log.GlobalLogger.Error("发送 rpc 请求到 master 报错：", err)
+				//TODO 这里会报错unexpected EOF但是不影响，先注释 close 和 continue
+				//KillRpcClient.Close()
+				//continue
 			}
-			// 获取一下最新配置
+			c_log.GlobalLogger.Info("获取数据闭环平台最新配置。")
 			commonConfig.InitPlatformConfig()
 			KillRpcClient.Close()
 		} else {
-			c_log.GlobalLogger.Error("未知的采集任务状态。status=", status)
+			c_log.GlobalLogger.Error("未知的采集任务状态。【status】=", status)
 		}
 	}