diff options
| author | Chris Lu <chris.lu@gmail.com> | 2014-03-19 04:48:13 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2014-03-19 04:48:13 -0700 |
| commit | 0563773944aa96c1bb87a2e840f00c0e34a8175f (patch) | |
| tree | 723610067336d0367e53ad01e7bd163640b32601 /go/replication/volume_growth.go | |
| parent | 463589da016e9a56cee0300b50219947dbd2fc64 (diff) | |
| download | seaweedfs-0563773944aa96c1bb87a2e840f00c0e34a8175f.tar.xz seaweedfs-0563773944aa96c1bb87a2e840f00c0e34a8175f.zip | |
switch to ReadAt() for thread-safe read
fix bugs during volume compaction
Diffstat (limited to 'go/replication/volume_growth.go')
| -rw-r--r-- | go/replication/volume_growth.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/go/replication/volume_growth.go b/go/replication/volume_growth.go index d5dd90b13..33dfc570e 100644 --- a/go/replication/volume_growth.go +++ b/go/replication/volume_growth.go @@ -137,7 +137,7 @@ func (vg *VolumeGrowth) grow(topo *topology.Topology, vid storage.VolumeId, coll if err := AllocateVolume(server, vid, collection, rp); err == nil { vi := storage.VolumeInfo{Id: vid, Size: 0, Collection: collection, ReplicaPlacement: rp, Version: storage.CurrentVersion} server.AddOrUpdateVolume(vi) - topo.RegisterVolumeLayout(&vi, server) + topo.RegisterVolumeLayout(vi, server) glog.V(0).Infoln("Created Volume", vid, "on", server) } else { glog.V(0).Infoln("Failed to assign", vid, "to", servers, "error", err) |