-
Notifications
You must be signed in to change notification settings - Fork 392
/
ringbuf_test.go
41 lines (37 loc) · 931 Bytes
/
ringbuf_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
package freecache
import (
"testing"
)
func TestRingBuf(t *testing.T) {
rb := NewRingBuf(16, 0)
for i := 0; i < 2; i++ {
rb.Write([]byte("fghibbbbccccddde"))
rb.Write([]byte("fghibbbbc"))
rb.Resize(16)
off := rb.Evacuate(9, 3)
t.Log(string(rb.Dump()))
if off != rb.End()-3 {
t.Log(string(rb.Dump()), rb.End())
t.Fatalf("off got %v", off)
}
off = rb.Evacuate(15, 5)
t.Log(string(rb.Dump()))
if off != rb.End()-5 {
t.Fatalf("off got %v", off)
}
rb.Resize(64)
rb.Resize(32)
data := make([]byte, 5)
rb.ReadAt(data, off)
if string(data) != "efghi" {
t.Fatalf("read at should be efghi, got %v", string(data))
}
off = rb.Evacuate(0, 10)
if off != -1 {
t.Fatal("evacutate out of range offset should return error")
}
/* -- After reset the buffer should behave exactly the same as a new one.
* Hence, run the test once more again with reset buffer. */
rb.Reset(0)
}
}