MCPcopy
hub / github.com/segmentio/kafka-go / TestPageBufferWriteReadSeek

Function TestPageBufferWriteReadSeek

protocol/buffer_test.go:10–46  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

8)
9
10func TestPageBufferWriteReadSeek(t *testing.T) {
11 buffer := newPageBuffer()
12 defer buffer.unref()
13
14 io.WriteString(buffer, "Hello World!")
15
16 if n := buffer.Size(); n != 12 {
17 t.Fatal("invalid size:", n)
18 }
19
20 for i := 0; i < 3; i++ {
21 if n := buffer.Len(); n != 12 {
22 t.Fatal("invalid length before read:", n)
23 }
24
25 b, err := ioutil.ReadAll(buffer)
26 if err != nil {
27 t.Fatal(err)
28 }
29
30 if n := buffer.Len(); n != 0 {
31 t.Fatal("invalid length after read:", n)
32 }
33
34 if string(b) != "Hello World!" {
35 t.Fatalf("invalid content after read #%d: %q", i, b)
36 }
37
38 offset, err := buffer.Seek(0, io.SeekStart)
39 if err != nil {
40 t.Fatal(err)
41 }
42 if offset != 0 {
43 t.Fatalf("invalid offset after seek #%d: %d", i, offset)
44 }
45 }
46}
47
48func TestPageRefWriteReadSeek(t *testing.T) {
49 buffer := newPageBuffer()

Callers

nothing calls this directly

Calls 6

newPageBufferFunction · 0.85
LenMethod · 0.65
unrefMethod · 0.45
WriteStringMethod · 0.45
SizeMethod · 0.45
SeekMethod · 0.45

Tested by

no test coverage detected