|
@@ -60,11 +60,11 @@ func main() {
|
|
var killArgs *commonService.KillSignal
|
|
var killArgs *commonService.KillSignal
|
|
if lastStatus == "UN_CHANGE" && status == "CHANGE" {
|
|
if lastStatus == "UN_CHANGE" && status == "CHANGE" {
|
|
killArgs = &commonService.KillSignal{NodeName: cfg.LocalConfig.Node.Name, DropUploadData: cfg.PlatformConfig.DropUploadData, Restart: true}
|
|
killArgs = &commonService.KillSignal{NodeName: cfg.LocalConfig.Node.Name, DropUploadData: cfg.PlatformConfig.DropUploadData, Restart: true}
|
|
- log.GlobalLogger.Info("更新任务,发送rpc重启信号到localhost:", killArgs)
|
|
|
|
|
|
+ log.GlobalLogger.Info("更新任务,发送rpc重启信号到本地"+cfg.LocalConfig.Node.Name+":", killArgs)
|
|
}
|
|
}
|
|
if lastStatus == "UN_CHANGE" && status == "NONE" {
|
|
if lastStatus == "UN_CHANGE" && status == "NONE" {
|
|
killArgs = &commonService.KillSignal{NodeName: cfg.LocalConfig.Node.Name, DropUploadData: cfg.PlatformConfig.DropUploadData, Restart: false}
|
|
killArgs = &commonService.KillSignal{NodeName: cfg.LocalConfig.Node.Name, DropUploadData: cfg.PlatformConfig.DropUploadData, Restart: false}
|
|
- log.GlobalLogger.Info("杀死任务,发送rpc结束信号到从节点:", killArgs)
|
|
|
|
|
|
+ log.GlobalLogger.Info("杀死任务,发送rpc结束信号到本地"+cfg.LocalConfig.Node.Name+":", killArgs)
|
|
}
|
|
}
|
|
|
|
|
|
KillRpcClient, err := rpc.Dial("tcp", cfg.LocalConfig.Node.Ip+":"+cfg.CloudConfig.RpcPort)
|
|
KillRpcClient, err := rpc.Dial("tcp", cfg.LocalConfig.Node.Ip+":"+cfg.CloudConfig.RpcPort)
|