From eebbef52c920000a16e96e015da24f8457b8bfb2 Mon Sep 17 00:00:00 2001
From: boyce <x@atbc.com>
Date: Fri, 8 Mar 2024 10:32:32 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E9=87=8D=E5=A4=8D=E5=90=AF?=
 =?UTF-8?q?=E5=8A=A8=E9=AA=8C=E8=AF=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 node/node.go | 51 ++++++++++++++++++++++++++++-----------------------
 1 file changed, 28 insertions(+), 23 deletions(-)

diff --git a/node/node.go b/node/node.go
index 1a30448..d8e577a 100644
--- a/node/node.go
+++ b/node/node.go
@@ -289,38 +289,43 @@ func startNode(args interface{}) error {
 	if err != nil {
 		return fmt.Errorf("invalid option %s", param)
 	}
-	processId, err := getRunProcessPid(nodeId)
-	if err != nil {
-		return err
+	for{
+		processId, pErr := getRunProcessPid(nodeId)
+		if pErr != nil {
+			break
+		}
+
+		name, cErr := sysprocess.GetProcessNameByPID(int32(processId))
+		myName, mErr := sysprocess.GetMyProcessName()
+		//当前进程名获取失败，不应该发生
+		if mErr != nil {
+			log.SInfo("get my process's name is error,", err.Error())
+			os.Exit(-1)
+		}
+
+		//进程id存在，而且进程名也相同，被认为是当前进程重复运行
+		if cErr == nil && name == myName {
+			log.SInfo(fmt.Sprintf("repeat runs are not allowed,node is %d,processid is %d",nodeId,processId))
+			os.Exit(-1)
+		}
+		break
 	}
 
-	name, cErr := sysprocess.GetProcessNameByPID(int32(processId))
-	myName, mErr := sysprocess.GetMyProcessName()
-	//当前进程名获取失败，不应该发生
-	if mErr != nil {
-		log.SInfo("get my process's name is error,", err.Error())
-		os.Exit(-1)
-	}
-
-	//进程id存在，而且进程名也相同，被认为是当前进程重复运行
-	if cErr == nil && name == myName {
-		log.SInfo(fmt.Sprintf("repeat runs are not allowed,node is %d,processid is %d",nodeId,processId))
-		os.Exit(-1)
-	}
-
-	timer.StartTimer(10*time.Millisecond, 1000000)
+	//2.记录进程id号
 	log.Info("Start running server.")
-	//2.初始化node
+	writeProcessPid(nodeId)
+	timer.StartTimer(10*time.Millisecond, 1000000)
+
+	//3.初始化node
 	initNode(nodeId)
 
-	//3.运行service
+	//4.运行service
 	service.Start()
 
-	//4.运行集群
+	//5.运行集群
 	cluster.GetCluster().Start()
 
-	//5.记录进程id号
-	writeProcessPid(nodeId)
+
 
 	//6.监听程序退出信号&性能报告
 	bRun := true