commit

aarch64/kinglong/control/main/control.go

@@ -82,14 +82,16 @@ func main() {
 			reply := 0
 			if err = KillRpcClient.Call("KillService.Kill", killArgs, &reply); err != nil {
 				c_log.GlobalLogger.Error("发送rpc请求到master失败：", err)
-				//TODO 这里可能会报错 unexpected EOF 但是不影响，先注释 close 和 continue
+				// 这里可能会报错 unexpected EOF 但是不影响，先注释 close 和 continue
 				//KillRpcClient.Close()
 				//continue
 			}
 			lastStatus = status
 			c_log.GlobalLogger.Info("结束任务后，将数据闭环平台配置置空。")
 			config.PlatformConfig = config.PlatformConfigStruct{}
-			KillRpcClient.Close()
+			if err = KillRpcClient.Close(); err != nil {
+				// 不做处理
+			}
 		} else {
 			c_log.GlobalLogger.Error("未知的采集任务状态。【status】=", status)
 		}

aarch64/pji/control/main/control.go

@@ -85,14 +85,16 @@ func main() {
 			reply := 0
 			if err = KillRpcClient.Call("KillService.Kill", killArgs, &reply); err != nil {
 				c_log.GlobalLogger.Error("发送 rpc 请求到 master 报错：", err)
-				//TODO 这里可能会报错unexpected EOF但是不影响，先注释 close 和 continue
+				// 这里可能会报错unexpected EOF但是不影响，先注释 close 和 continue
 				//KillRpcClient.Close()
 				//continue
 			}
 			lastStatus = status
 			c_log.GlobalLogger.Info("结束任务后，将数据闭环平台配置置空。")
 			commonConfig.PlatformConfig = commonConfig.PlatformConfigStruct{}
-			KillRpcClient.Close()
+			if err = KillRpcClient.Close(); err != nil {
+				// 不做处理
+			}
 		} else {
 			c_log.GlobalLogger.Error("未知的采集任务状态。【status】=", status)
 		}

aarch64/pjisuv/control/main/control.go

@@ -83,7 +83,7 @@ func main() {
 			reply := 0
 			if err = KillRpcClient.Call("KillService.Kill", killArgs, &reply); err != nil {
 				c_log.GlobalLogger.Error("发送rpc请求到master失败：", err)
-				//todo 这里可能会报错 unexpected EOF 但是不影响，先注释 close 和 continue
+				// 这里可能会报错 unexpected EOF 但是不影响，先注释 close 和 continue
 				//KillRpcClient.Close()
 				//continue
 			}
@@ -91,7 +91,7 @@ func main() {
 			c_log.GlobalLogger.Info("结束任务后，将数据闭环平台配置置空。")
 			config.PlatformConfig = config.PlatformConfigStruct{}
 			if err = KillRpcClient.Close(); err != nil {
-				//todo 不做处理
+				// 不做处理
 			}
 		} else {
 			c_log.GlobalLogger.Error("未知的采集任务状态。【status】=", status)