Function TestIteratorExpireAt

cache_test.go:757–792

(t *testing.T)

}

func TestIteratorExpireAt(t *testing.T) {
	cache := NewCache(1024)
	expireSecond := uint32(5)
	// Set some value that expires to make sure expired entry is not returned.
	cache.Set([]byte("no_expire"), []byte("def"), 0)
	cache.Set([]byte("has_expire"), []byte("exp"), int(expireSecond))

	it := cache.NewIterator()
	for {
		next := it.Next()
		if next == nil {
			break
		}
		if string(next.Key) == "no_expire" && next.ExpireAt != 0 {
			t.Fatalf("no_expire's ExpireAt should be 0")
		}
		expectExpireAt := uint32(time.Now().Unix()) + expireSecond
		if string(next.Key) == "has_expire" && next.ExpireAt != expectExpireAt {
			t.Fatalf("has_expire's ExpireAt should be 10,actually is %d", next.ExpireAt)
		}
	}
	time.Sleep(time.Duration(expireSecond) * time.Second)
	it2 := cache.NewIterator()
	for {
		next := it2.Next()
		if next == nil {
			return
		}
		if string(next.Key) == "no_expire" && next.ExpireAt != 0 {
			t.Fatalf("no_expire's ExpireAt should be 0")
		}
		if string(next.Key) == "has_expire" {
			t.Fatalf("has_expire should expired")
		}
	}
}

func TestSetLargerEntryDeletesWrongEntry(t *testing.T) {
	cachesize := 512 * 1024