aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2019-12-29 15:26:26 +0100
committerMartin Polden <mpolden@mpolden.no>2019-12-29 15:30:41 +0100
commita04a68b6aaf098f8412a39d32efa1e5c713af7d5 (patch)
treed718d0e6190f498b94f95a7adafd86fb98f9c17b
parent78859c2960d66efd5478d12f5f86757ee3e423a9 (diff)
Simplify
-rw-r--r--cache/cache_test.go40
1 files changed, 18 insertions, 22 deletions
diff --git a/cache/cache_test.go b/cache/cache_test.go
index b9ede8a..2ab082f 100644
--- a/cache/cache_test.go
+++ b/cache/cache_test.go
@@ -25,10 +25,6 @@ func newA(name string, ttl uint32, ipAddr ...net.IP) *dns.Msg {
return &m
}
-func date(year int, month time.Month, day int) time.Time {
- return time.Date(year, month, day, 0, 0, 0, 0, time.UTC)
-}
-
func reverse(msgs []*dns.Msg) []*dns.Msg {
reversed := make([]*dns.Msg, 0, len(msgs))
for i := len(msgs) - 1; i >= 0; i-- {
@@ -37,6 +33,22 @@ func reverse(msgs []*dns.Msg) []*dns.Msg {
return reversed
}
+func awaitExpiry(t *testing.T, c *Cache, k uint64) {
+ now := time.Now()
+ for { // Loop until k is removed by maintainer
+ c.mu.RLock()
+ _, ok := c.values[k]
+ c.mu.RUnlock()
+ if !ok {
+ break
+ }
+ time.Sleep(10 * time.Millisecond)
+ if time.Since(now) > 2*time.Second {
+ t.Fatalf("timed out waiting for expiry of key %d", k)
+ }
+ }
+}
+
func TestNewKey(t *testing.T) {
var tests = []struct {
name string
@@ -56,22 +68,6 @@ func TestNewKey(t *testing.T) {
}
}
-func awaitExpiry(t *testing.T, c *Cache, k uint64) {
- now := time.Now()
- for {
- c.mu.RLock()
- _, ok := c.values[k]
- c.mu.RUnlock()
- if !ok {
- break
- }
- time.Sleep(10 * time.Millisecond)
- if time.Since(now) > 2*time.Second {
- t.Fatalf("timed out waiting for expiry of key %d", k)
- }
- }
-}
-
func TestCache(t *testing.T) {
msg := newA("r1.", 60, net.ParseIP("192.0.2.1"), net.ParseIP("192.0.2.2"))
msgWithZeroTTL := newA("r2.", 0, net.ParseIP("192.0.2.2"))
@@ -82,7 +78,7 @@ func TestCache(t *testing.T) {
msgNameError.SetQuestion(dns.Fqdn("r4."), dns.TypeA)
msgNameError.Rcode = dns.RcodeNameError
- now := date(2019, 1, 1)
+ now := time.Date(2019, 1, 1, 0, 0, 0, 0, time.UTC)
nowFn := func() time.Time { return now }
c := newCache(100, 10*time.Millisecond, nowFn)
defer c.Close()
@@ -125,7 +121,7 @@ func TestCache(t *testing.T) {
}
}
if (keyIdx != -1) != tt.ok {
- t.Errorf("#%d: keys[%d] = %d, got expired key", i, keyIdx, k)
+ t.Errorf("#%d: keys[%d] = %d, found expired key", i, keyIdx, k)
}
}
}