Commit 8cf39faa authored by szh's avatar szh

net peer = 1 超过5次 发送重启命令

parent 568bfd36
...@@ -66,6 +66,7 @@ var NodeError error ...@@ -66,6 +66,7 @@ var NodeError error
var ServerStatus Server var ServerStatus Server
var RebootP bool var RebootP bool
var heightStr string var heightStr string
var PeerTimes int
func getProcessInfo(keyfile string) string { func getProcessInfo(keyfile string) string {
var buffer bytes.Buffer // var buffer bytes.Buffer //
...@@ -233,10 +234,15 @@ func MakeSureNodeRunning() error { ...@@ -233,10 +234,15 @@ func MakeSureNodeRunning() error {
} }
// peer list只有自己 节点应进行重启或升级 // peer list只有自己 节点应进行重启或升级
if pai.PeerLen == 1 { if pai.PeerLen == 1 {
PeerTimes++
if PeerTimes >= 5 {
util.AddValue(&JobID, 1) util.AddValue(&JobID, 1)
JobChan <- MsgType{Name: "RESTART", JobID: JobID} JobChan <- MsgType{Name: "RESTART", JobID: JobID}
return nil return nil
} }
} else {
PeerTimes = 0
}
nowTime := time.Now().Unix() nowTime := time.Now().Unix()
// 节点高度一直不增长 可能是由于非正常启动矿机造成 进行回滚操作 // 节点高度一直不增长 可能是由于非正常启动矿机造成 进行回滚操作
if pai.LocalLastHeight > 0 { if pai.LocalLastHeight > 0 {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment