diff options
| author | Martin Polden <mpolden@mpolden.no> | 2019-12-30 17:49:06 +0100 |
|---|---|---|
| committer | Martin Polden <mpolden@mpolden.no> | 2019-12-30 17:49:06 +0100 |
| commit | 94234363cfb954b1bf3d50e7f9d2e6bef86287c7 (patch) | |
| tree | 862a9a3b92d8715e44f6ac363a67a72ce89d5c96 /cache/cache_test.go | |
| parent | e6d2c75780bcf161ea75c5a6f2dc43cfc93ecfe4 (diff) | |
Reduce lock contention by refreshing at query time
Diffstat (limited to 'cache/cache_test.go')
| -rw-r--r-- | cache/cache_test.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/cache/cache_test.go b/cache/cache_test.go index 3ea6bf3..e24e3b2 100644 --- a/cache/cache_test.go +++ b/cache/cache_test.go @@ -235,11 +235,12 @@ func TestCachePrefetch(t *testing.T) { var key uint64 = 1 ip := net.ParseIP("192.0.2.1") response := newA("r1.", 60, ip) + exchanger.answer = response c.Set(key, response) // Not refreshed yet c.now = func() time.Time { return now.Add(30 * time.Second) } - c.refreshExpired(0) + c.refresh(key, response) rr, _ := c.Get(key) answers := dnsutil.Answers(rr) if got, want := answers[0], ip.String(); got != want { @@ -255,7 +256,7 @@ func TestCachePrefetch(t *testing.T) { // Refresh expired entry ip = net.ParseIP("192.0.2.2") exchanger.answer = newA("r1.", 60, ip) - c.refreshExpired(0) + c.refresh(key, response) rr, _ = c.Get(key) answers = dnsutil.Answers(rr) if got, want := answers[0], ip.String(); got != want { |