aboutsummaryrefslogtreecommitdiff
path: root/go/replication
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2013-04-14 19:30:26 -0700
committerChris Lu <chris.lu@gmail.com>2013-04-14 19:30:26 -0700
commita4369b35a74752c4fc4005dbdf682401c2fb000c (patch)
tree789579d0418ca8753e180a0f0d663a01eed34093 /go/replication
parent4d8ce2fe26781b070a96f5fa5c6e4906c28016ee (diff)
downloadseaweedfs-a4369b35a74752c4fc4005dbdf682401c2fb000c.tar.xz
seaweedfs-a4369b35a74752c4fc4005dbdf682401c2fb000c.zip
merge changes from about dealing with read only volumes.
https://github.com/tgulacsi/weed-fs/commit/97482255d555f152ea99052aba7d0a0163235e39.diff
Diffstat (limited to 'go/replication')
-rw-r--r--go/replication/volume_growth_test.go6
1 files changed, 5 insertions, 1 deletions
diff --git a/go/replication/volume_growth_test.go b/go/replication/volume_growth_test.go
index 3fbeebc9e..a4104716e 100644
--- a/go/replication/volume_growth_test.go
+++ b/go/replication/volume_growth_test.go
@@ -80,7 +80,11 @@ func setup(topologyLayout string) *topology.Topology {
fmt.Println("data:", data)
//need to connect all nodes first before server adding volumes
- topo := topology.NewTopology("mynetwork", "/etc/weedfs/weedfs.conf", "/tmp", "testing", 32*1024, 5)
+ topo, err := topology.NewTopology("mynetwork", "/etc/weedfs/weedfs.conf",
+ "/tmp", "testing", 32*1024, 5)
+ if err != nil {
+ panic("error: " + err.Error())
+ }
mTopology := data.(map[string]interface{})
for dcKey, dcValue := range mTopology {
dc := topology.NewDataCenter(dcKey)