aboutsummaryrefslogtreecommitdiff
path: root/timer.go
diff options
context:
space:
mode:
authorMathias Hall-Andersen <mathias@hall-andersen.dk>2018-02-04 16:08:26 +0100
committerMathias Hall-Andersen <mathias@hall-andersen.dk>2018-02-04 16:08:26 +0100
commita0f54cbe5ac2cd8b8296c2c57c30029dd349cff0 (patch)
tree64574090d79ff3899c5c18e5268e450028e4656b /timer.go
parent5871ec04deb8f4715cab37146940baa35c08cbee (diff)
downloadwireguard-go-a0f54cbe5ac2cd8b8296c2c57c30029dd349cff0.tar.gz
wireguard-go-a0f54cbe5ac2cd8b8296c2c57c30029dd349cff0.zip
Align with go library layout
Diffstat (limited to 'timer.go')
-rw-r--r--timer.go59
1 files changed, 59 insertions, 0 deletions
diff --git a/timer.go b/timer.go
new file mode 100644
index 0000000..f00ca49
--- /dev/null
+++ b/timer.go
@@ -0,0 +1,59 @@
+package main
+
+import (
+ "time"
+)
+
+type Timer struct {
+ pending AtomicBool
+ timer *time.Timer
+}
+
+/* Starts the timer if not already pending
+ */
+func (t *Timer) Start(dur time.Duration) bool {
+ set := t.pending.Swap(true)
+ if !set {
+ t.timer.Reset(dur)
+ return true
+ }
+ return false
+}
+
+/* Stops the timer
+ */
+func (t *Timer) Stop() {
+ set := t.pending.Swap(true)
+ if set {
+ t.timer.Stop()
+ select {
+ case <-t.timer.C:
+ default:
+ }
+ }
+ t.pending.Set(false)
+}
+
+func (t *Timer) Pending() bool {
+ return t.pending.Get()
+}
+
+func (t *Timer) Reset(dur time.Duration) {
+ t.pending.Set(false)
+ t.Start(dur)
+}
+
+func (t *Timer) Wait() <-chan time.Time {
+ return t.timer.C
+}
+
+func NewTimer() (t Timer) {
+ t.pending.Set(false)
+ t.timer = time.NewTimer(0)
+ t.timer.Stop()
+ select {
+ case <-t.timer.C:
+ default:
+ }
+ return
+}