aboutsummaryrefslogtreecommitdiff
path: root/go/topology/topo_test.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2013-06-19 18:10:38 -0700
committerChris Lu <chris.lu@gmail.com>2013-06-19 18:10:38 -0700
commit50269b74ce615ab02f6bf64a2bc0fc9e71122267 (patch)
tree887f63247a589cb027e65331b9243edcad61f479 /go/topology/topo_test.go
parent715d327df0ad64a70837711c664e1ef024e0bcc5 (diff)
downloadseaweedfs-50269b74ce615ab02f6bf64a2bc0fc9e71122267.tar.xz
seaweedfs-50269b74ce615ab02f6bf64a2bc0fc9e71122267.zip
add dataCenter option when assign file keys
add dataCenter option when starting volume servers some work related to freeze a volume. Not tested yet.
Diffstat (limited to 'go/topology/topo_test.go')
-rw-r--r--go/topology/topo_test.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/go/topology/topo_test.go b/go/topology/topo_test.go
index 99e570821..d5ea08086 100644
--- a/go/topology/topo_test.go
+++ b/go/topology/topo_test.go
@@ -127,7 +127,10 @@ func TestReserveOneVolume(t *testing.T) {
topo := setup(topologyLayout)
rand.Seed(time.Now().UnixNano())
rand.Seed(1)
- ret, node, vid := topo.RandomlyReserveOneVolume()
+ ret, node, vid := topo.RandomlyReserveOneVolume("dc1")
+ if node.Parent().Parent().Id() != NodeId("dc1") {
+ t.Fail()
+ }
fmt.Println("assigned :", ret, ", node :", node, ", volume id:", vid)
}