aboutsummaryrefslogtreecommitdiff
path: root/go/replication/volume_growth.go
diff options
context:
space:
mode:
Diffstat (limited to 'go/replication/volume_growth.go')
-rw-r--r--go/replication/volume_growth.go3
1 files changed, 1 insertions, 2 deletions
diff --git a/go/replication/volume_growth.go b/go/replication/volume_growth.go
index 6e5bf1f5c..d7d1c90bd 100644
--- a/go/replication/volume_growth.go
+++ b/go/replication/volume_growth.go
@@ -2,7 +2,6 @@ package replication
import (
"code.google.com/p/weed-fs/go/glog"
- "code.google.com/p/weed-fs/go/operation"
"code.google.com/p/weed-fs/go/storage"
"code.google.com/p/weed-fs/go/topology"
"errors"
@@ -200,7 +199,7 @@ func (vg *VolumeGrowth) GrowByCountAndType(count int, collection string, repType
}
func (vg *VolumeGrowth) grow(topo *topology.Topology, vid storage.VolumeId, collection string, repType storage.ReplicationType, servers ...*topology.DataNode) error {
for _, server := range servers {
- if err := operation.AllocateVolume(server, vid, collection, repType); err == nil {
+ if err := AllocateVolume(server, vid, collection, repType); err == nil {
vi := storage.VolumeInfo{Id: vid, Size: 0, Collection: collection, RepType: repType, Version: storage.CurrentVersion}
server.AddOrUpdateVolume(vi)
topo.RegisterVolumeLayout(&vi, server)