diff options
| -rw-r--r-- | watchdog.go | 32 |
1 files changed, 3 insertions, 29 deletions
diff --git a/watchdog.go b/watchdog.go index 41bc698..df32b8d 100644 --- a/watchdog.go +++ b/watchdog.go @@ -2,36 +2,11 @@ package main import ( "fmt" - "os" "time" "go.wit.com/log" ) -// scan hypervisors every i seconds -func (h *HyperT) NewWatchdog() { - var delay int = 99 - var i int = delay - h.MyTicker(h.Delay, h.Hostname, func() { - i += 1 - // check if the env var is set to autoscan - if os.Getenv("WATCHDOG_AUTO_SCAN") != "true" { - if i < delay { - i = delay - } - // print every 'delay' seconds - if i%delay == 0 { - log.Info("Not auto scanning", i, "WATCHDOG_AUTO_SCAN =", os.Getenv("WATCHDOG_AUTO_SCAN")) - } - return - } - if i < delay { - return - } - i = 0 - }) -} - // timeFunction takes a function as an argument and returns the execution time. func TimeFunction(f func()) time.Duration { startTime := time.Now() // Record the start time @@ -39,8 +14,8 @@ func TimeFunction(f func()) time.Duration { return time.Since(startTime) // Calculate the elapsed time } -func (h *HyperT) MyTicker(t time.Duration, name string, f func()) { - h.Dog = time.NewTicker(t) +func (h *HyperT) NewWatchdog() { + h.Dog = time.NewTicker(h.Delay) defer h.Dog.Stop() done := make(chan bool) /* @@ -56,9 +31,8 @@ func (h *HyperT) MyTicker(t time.Duration, name string, f func()) { fmt.Println("Done!") return case t := <-h.Dog.C: - log.Log(POLL, "Watchdog() ticked", name, "Current time: ", t) + log.Log(POLL, "Watchdog() ticked", h.Hostname, "Current time: ", t) h.Scan() - // f() } } } |