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
|
package kafka
import (
"bytes"
"hash/crc32"
"testing"
)
func TestMessageCRC32(t *testing.T) {
m := message{
MagicByte: 1,
Timestamp: 42,
Key: nil,
Value: []byte("Hello World!"),
}
b := &bytes.Buffer{}
w := &writeBuffer{w: b}
w.write(m)
h := crc32.New(crc32.IEEETable)
h.Write(b.Bytes()[4:])
sum1 := h.Sum32()
sum2 := uint32(m.crc32(&crc32Writer{table: crc32.IEEETable}))
if sum1 != sum2 {
t.Error("bad CRC32:")
t.Logf("expected: %d", sum1)
t.Logf("found: %d", sum2)
}
}
|
