From 0786441ed1828c411a16d6648baee753a02a3ddb Mon Sep 17 00:00:00 2001
From: zhangmeng <zhangmeng@aiotlink.com>
Date: 星期二, 25 二月 2020 11:24:16 +0800
Subject: [PATCH] expand tabs to 4 spaces
---
common/reboot.go | 82 ++++++++++++++++++++--------------------
1 files changed, 41 insertions(+), 41 deletions(-)
diff --git a/common/reboot.go b/common/reboot.go
index e4a9e4c..61ba8ce 100644
--- a/common/reboot.go
+++ b/common/reboot.go
@@ -1,64 +1,64 @@
package common
import (
- "context"
- "os"
- "sync"
- "time"
+ "context"
+ "os"
+ "sync"
+ "time"
)
// Disturber stop
type Disturber struct {
- mtx sync.Mutex
- live bool
- until int
- maxTry int
+ mtx sync.Mutex
+ live bool
+ until int
+ maxTry int
}
// NewDisturber new
func NewDisturber(maxTry int) *Disturber {
- return &Disturber{
- live: true,
- until: 0,
- maxTry: maxTry,
- }
+ return &Disturber{
+ live: true,
+ until: 0,
+ maxTry: maxTry,
+ }
}
// Prevent prevent
func (d *Disturber) Prevent() {
- d.mtx.Lock()
- defer d.mtx.Unlock()
- d.live = true
+ d.mtx.Lock()
+ defer d.mtx.Unlock()
+ d.live = true
}
// MaybeReboot reboot
func (d *Disturber) MaybeReboot(ctx context.Context, fn func(...interface{})) {
- d.live = true
- for {
- select {
- case <-ctx.Done():
- return
- default:
- d.mtx.Lock()
- running := d.live
- d.mtx.Unlock()
+ d.live = true
+ for {
+ select {
+ case <-ctx.Done():
+ return
+ default:
+ d.mtx.Lock()
+ running := d.live
+ d.mtx.Unlock()
- if running {
- d.until = 0
+ if running {
+ d.until = 0
- d.mtx.Lock()
- d.live = false
- d.mtx.Unlock()
+ d.mtx.Lock()
+ d.live = false
+ d.mtx.Unlock()
- } else {
- d.until++
- fn("!!!!!!No Running: ", d.until)
- if d.until > d.maxTry {
- fn("!!!!!!Too Long Running, Reboot: ", d.maxTry)
- os.Exit(0)
- }
- }
- time.Sleep(time.Second)
- }
- }
+ } else {
+ d.until++
+ fn("!!!!!!No Running: ", d.until)
+ if d.until > d.maxTry {
+ fn("!!!!!!Too Long Running, Reboot: ", d.maxTry)
+ os.Exit(0)
+ }
+ }
+ time.Sleep(time.Second)
+ }
+ }
}
--
Gitblit v1.8.0