派生自 libgowrapper/face

zhangmeng
2020-01-15 ee1ea6dc3930a07d78c6fd7b6238fa44cde06d79
update
2个文件已修改
24 ■■■■ 已修改文件
common/reboot.go 22 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
run.go 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
common/reboot.go
@@ -7,20 +7,20 @@
    "time"
)
const maxTryBeforeReboot = 10
// Disturber stop
type Disturber struct {
    mtx   sync.Mutex
    live  bool
    until int
    mtx    sync.Mutex
    live   bool
    until  int
    maxTry int
}
// NewDisturber new
func NewDisturber() *Disturber {
func NewDisturber(maxTry int) *Disturber {
    return &Disturber{
        live:  true,
        until: 0,
        live:   true,
        until:  0,
        maxTry: maxTry,
    }
}
@@ -52,9 +52,9 @@
            } else {
                d.until++
                fn("Face No Running: ", d.until)
                if d.until > maxTryBeforeReboot {
                    fn("Face Too Long Running, Reboot")
                fn("!!!!!!No Running: ", d.until)
                if d.until > d.maxTry {
                    fn("!!!!!!Too Long Running, Reboot: ", d.maxTry)
                    os.Exit(0)
                }
            }
run.go
@@ -118,7 +118,7 @@
        ruleMsgMaxCacheSize: ruleMaxSize,
        reserved:            reserved,
        stopper: common.NewDisturber(),
        stopper: common.NewDisturber(10),
    }
}