forked from scylladb/gocql
-
Notifications
You must be signed in to change notification settings - Fork 4
/
ring_test.go
38 lines (31 loc) · 1.03 KB
/
ring_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
package gocql
import (
"net"
"testing"
)
func TestRing_AddHostIfMissing_Missing(t *testing.T) {
ring := &ring{}
host := &HostInfo{hostId: MustRandomUUID().String(), connectAddress: net.IPv4(1, 1, 1, 1)}
h1, ok := ring.addHostIfMissing(host)
if ok {
t.Fatal("host was reported as already existing")
} else if !h1.Equal(host) {
t.Fatalf("hosts not equal that are returned %v != %v", h1, host)
} else if h1 != host {
t.Fatalf("returned host same pointer: %p != %p", h1, host)
}
}
func TestRing_AddHostIfMissing_Existing(t *testing.T) {
ring := &ring{}
host := &HostInfo{hostId: MustRandomUUID().String(), connectAddress: net.IPv4(1, 1, 1, 1)}
ring.addHostIfMissing(host)
h2 := &HostInfo{hostId: host.hostId, connectAddress: net.IPv4(2, 2, 2, 2)}
h1, ok := ring.addHostIfMissing(h2)
if !ok {
t.Fatal("host was not reported as already existing")
} else if !h1.Equal(host) {
t.Fatalf("hosts not equal that are returned %v != %v", h1, host)
} else if h1 != host {
t.Fatalf("returned host same pointer: %p != %p", h1, host)
}
}