-
Notifications
You must be signed in to change notification settings - Fork 48
/
register_slave_test.go
122 lines (98 loc) · 2.36 KB
/
register_slave_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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
package myreplication
import (
"reflect"
"testing"
)
func TestRegisterSlave(t *testing.T) {
rs := registerSlave{}
pack := rs.writeServer(uint32(10))
result := pack.packBytes()
expectedLength := []byte{0x12, 0x00, 0x00}
offset := 0
if !reflect.DeepEqual(expectedLength, result[offset:offset+3]) {
t.Fatal(
"Incorrect query length",
"expected", expectedLength,
"got", result[offset:offset+3],
)
}
offset += 3
expectedSequence := byte(0)
if expectedSequence != result[offset : offset+1][0] {
t.Fatal(
"Incorrect sequence",
"expected", expectedSequence,
"got", result[offset : offset+1][0],
)
}
offset++
if _COM_REGISTER_SLAVE != result[offset : offset+1][0] {
t.Fatal(
"Incorrect command",
"expected", _COM_QUERY,
"got", result[offset : offset+1][0],
)
}
offset++
expectedServerId := []byte{0x0A, 0x00, 0x00, 0x00}
if !reflect.DeepEqual(expectedServerId, result[offset:offset+4]) {
t.Fatal(
"Incorrect servert id",
"expected", expectedServerId,
"got", result[offset:offset+4],
)
}
offset += 4
expectedStrLength := byte(0)
if expectedStrLength != result[offset : offset+1][0] {
t.Fatal(
"Expected hostname length",
"expected", expectedStrLength,
"got", result[offset : offset+1][0],
)
}
offset++
if expectedStrLength != result[offset : offset+1][0] {
t.Fatal(
"Expected username length",
"expected", expectedStrLength,
"got", result[offset : offset+1][0],
)
}
offset++
if expectedStrLength != result[offset : offset+1][0] {
t.Fatal(
"Expected password length",
"expected", expectedStrLength,
"got", result[offset : offset+1][0],
)
}
offset++
expectedPort := []byte{0x00, 0x00}
if !reflect.DeepEqual(expectedPort, result[offset:offset+2]) {
t.Fatal(
"Expected port",
"expected", expectedPort,
"got", result[offset:offset+2],
)
}
offset += 2
expectedReplicationRank := []byte{0x00, 0x00, 0x00, 0x00}
if !reflect.DeepEqual(expectedReplicationRank, result[offset:offset+4]) {
t.Fatal(
"Expected replication rank",
"expected", expectedReplicationRank,
"got", result[offset:offset+4],
)
}
offset += 4
expectedMasterId := []byte{0x00, 0x00, 0x00, 0x00}
if !reflect.DeepEqual(expectedMasterId, result[offset:offset+4]) {
t.Fatal(
"Expected master id",
"expected", expectedMasterId,
"got", result[offset:offset+4],
)
}
offset += 4
}