解决节点不存在时,无法主动创建master节点的问题

This commit is contained in:
yaziming
2020-05-27 19:04:54 +08:00
parent ecc0d62874
commit 93c06d0464
3 changed files with 8 additions and 10 deletions

View File

@@ -81,12 +81,7 @@ func main() {
log.Info("initialized local node successfully")
if model.IsMaster() {
// 初始化Master节点信息
if err := services.InitMasterNodeInfo(); err != nil {
log.Error("init master node info error:" + err.Error())
debug.PrintStack()
panic(err)
}
// 初始化定时任务
if err := services.InitScheduler(); err != nil {
log.Error("init scheduler error:" + err.Error())

View File

@@ -21,5 +21,12 @@ func InitLocalNodeInfo() (err error) {
if err != nil {
return err
}
if model.IsMaster() {
err = model.UpdateMasterNodeInfo(localNode.Identify, localNode.Ip, localNode.Mac, localNode.Hostname)
if err != nil {
return err
}
}
return localNode.Ready()
}

View File

@@ -284,7 +284,3 @@ func InitNodeService() error {
c.Start()
return nil
}
func InitMasterNodeInfo() (err error) {
localNode := local_node.GetLocalNode()
return model.UpdateMasterNodeInfo(localNode.Identify, localNode.Ip, localNode.Mac, localNode.Hostname)
}