summaryrefslogtreecommitdiffhomepage
path: root/timer.go
diff options
context:
space:
mode:
authorMathias Hall-Andersen <mathias@hall-andersen.dk>2018-05-05 02:20:52 +0200
committerMathias Hall-Andersen <mathias@hall-andersen.dk>2018-05-05 02:20:52 +0200
commit6db41d5a269c79bd04b18dbfa171cc241a6cdcc9 (patch)
tree7cfd9a8461b5c66dd971971e3706ada4c8b0484a /timer.go
parent168ef61a638e4875b260edbc51551bae0dc34ac3 (diff)
Initial version of migration to new event model
- Begin move away from global timer state. - Made logging format more consistent
Diffstat (limited to 'timer.go')
-rw-r--r--timer.go65
1 files changed, 0 insertions, 65 deletions
diff --git a/timer.go b/timer.go
deleted file mode 100644
index 74e3a4e..0000000
--- a/timer.go
+++ /dev/null
@@ -1,65 +0,0 @@
-package main
-
-import (
- "sync"
- "time"
-)
-
-type Timer struct {
- mutex sync.Mutex
- pending bool
- timer *time.Timer
-}
-
-/* Starts the timer if not already pending
- */
-func (t *Timer) Start(dur time.Duration) bool {
- t.mutex.Lock()
- defer t.mutex.Unlock()
-
- started := !t.pending
- if started {
- t.timer.Reset(dur)
- }
- return started
-}
-
-func (t *Timer) Stop() {
- t.mutex.Lock()
- defer t.mutex.Unlock()
-
- t.timer.Stop()
- select {
- case <-t.timer.C:
- default:
- }
- t.pending = false
-}
-
-func (t *Timer) Pending() bool {
- t.mutex.Lock()
- defer t.mutex.Unlock()
-
- return t.pending
-}
-
-func (t *Timer) Reset(dur time.Duration) {
- t.mutex.Lock()
- defer t.mutex.Unlock()
- t.timer.Reset(dur)
-}
-
-func (t *Timer) Wait() <-chan time.Time {
- return t.timer.C
-}
-
-func NewTimer() (t Timer) {
- t.pending = false
- t.timer = time.NewTimer(time.Hour)
- t.timer.Stop()
- select {
- case <-t.timer.C:
- default:
- }
- return
-}