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