neoris/core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Start the moved process before old gets deleted

Browse Source
This commit is contained in:
Ingo Oppermann 2024-12-10 17:13:21 +01:00
parent 893f8c2b1f
commit 85317b7d01
No known key found for this signature in database
GPG Key ID: 2AB32426E9DD229E
1 changed files with 19 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
cluster/leader.go
View File

@ -653,36 +653,36 @@ func (c *cluster) applyOp(op interface{}, logger log.Logger) processOpError {
}).Log("Moving process, stopping process")
}
err = c.manager.ProcessDelete(v.fromNodeid, v.config.ProcessID())
if err != nil {
opErr = processOpError{
processid: v.config.ProcessID(),
err: err,
}
logger.Info().WithError(err).WithFields(log.Fields{
"processid": v.config.ProcessID(),
"fromnodeid": v.fromNodeid,
"tonodeid": v.toNodeid,
}).Log("Moving process, removing process")
break
}
if v.order == "start" {
err = c.manager.ProcessCommand(v.toNodeid, v.config.ProcessID(), "start")
if err != nil {
opErr = processOpError{
processid: v.config.ProcessID(),
err: err,
}
//opErr = processOpError{
// processid: v.config.ProcessID(),
// err: err,
//}
logger.Info().WithError(err).WithFields(log.Fields{
"processid": v.config.ProcessID(),
"fromnodeid": v.fromNodeid,
"tonodeid": v.toNodeid,
}).Log("Moving process, starting process")
break
// Continue in case the process couldn't start
}
}
err = c.manager.ProcessDelete(v.fromNodeid, v.config.ProcessID())
if err != nil {
//opErr = processOpError{
// processid: v.config.ProcessID(),
// err: err,
//}
logger.Info().WithError(err).WithFields(log.Fields{
"processid": v.config.ProcessID(),
"fromnodeid": v.fromNodeid,
"tonodeid": v.toNodeid,
}).Log("Moving process, removing process")
// Continue in case the process couldn't be deleted (will be cleaned up later)
}
opErr = processOpError{
processid: v.config.ProcessID(),
err: nil,