-
Notifications
You must be signed in to change notification settings - Fork 0
/
l1cache_test.go
68 lines (58 loc) · 1.17 KB
/
l1cache_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
package nexus
import (
"fmt"
"math/rand"
"testing"
"time"
)
func randInt(min int, max int) int {
if max-min <= 0 {
return min
}
rand.Seed(time.Now().UTC().UnixNano())
return min + rand.Intn(max-min)
}
func Test_Get(t *testing.T) {
c := NewL1Cache()
c.Set("foo", "bar", 3)
result, ok := c.Get("foo")
if ok == false {
t.Error("set but cannot get")
}
if result != "bar" {
t.Error("get value not equal to set value")
}
}
func Test_Set(t *testing.T) {
c := NewL1Cache()
ret := c.Set("foo", "bar", 0)
if ret == nil {
t.Error("should not set with timeout = 0")
}
ret = c.Set("foo", "bar", 86401)
if ret == nil {
t.Error("should return an error")
}
ret = c.Set("foo", "bar", 3)
if ret != nil {
t.Error("set failed")
}
ret = c.Set("foo", "bar2", 3)
if ret == nil {
t.Error("duplicate set should not happen")
}
}
func Test_Purge(t *testing.T) {
c := NewL1Cache()
for i := 0; i < 2000; i++ {
time.Sleep(10 * time.Millisecond)
fmt.Println("cache size", len(c.cache))
if i < 1000 {
timeout := randInt(1, 10)
c.Set(fmt.Sprintf("item%d", i), fmt.Sprintf("value%d", i), timeout)
}
}
if len(c.cache) != 0 {
t.Error("cache purge problem")
}
}