diff options
| author | 霍晓栋 <huoxd@jiedaibao.com> | 2016-09-08 10:34:24 +0800 |
|---|---|---|
| committer | 霍晓栋 <huoxd@jiedaibao.com> | 2016-09-08 10:34:24 +0800 |
| commit | 1c2affea8e2a074b13b1cb4d925a97464cbee76c (patch) | |
| tree | bd77e4d8fc5ff38ca3e4fe9ee2b2d3112aeb0727 /weed/topology/data_node.go | |
| parent | 3aa021a812317fa640ebe2c7ec3b2a78492fa319 (diff) | |
| parent | 0559aa96738d727e055190301bbb0624c74ced7f (diff) | |
| download | seaweedfs-1c2affea8e2a074b13b1cb4d925a97464cbee76c.tar.xz seaweedfs-1c2affea8e2a074b13b1cb4d925a97464cbee76c.zip | |
Merge remote-tracking branch 'upstream/master'
Diffstat (limited to 'weed/topology/data_node.go')
| -rw-r--r-- | weed/topology/data_node.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/topology/data_node.go b/weed/topology/data_node.go index da6ed2895..b7f039559 100644 --- a/weed/topology/data_node.go +++ b/weed/topology/data_node.go @@ -53,7 +53,7 @@ func (dn *DataNode) UpdateVolumes(actualVolumes []storage.VolumeInfo) (deletedVo for _, v := range actualVolumes { actualVolumeMap[v.Id] = v } - dn.RLock() + dn.Lock() for vid, v := range dn.volumes { if _, ok := actualVolumeMap[vid]; !ok { glog.V(0).Infoln("Deleting volume id:", vid) @@ -62,8 +62,8 @@ func (dn *DataNode) UpdateVolumes(actualVolumes []storage.VolumeInfo) (deletedVo dn.UpAdjustVolumeCountDelta(-1) dn.UpAdjustActiveVolumeCountDelta(-1) } - } //TODO: adjust max volume id, if need to reclaim volume ids - dn.RUnlock() + } + dn.Unlock() for _, v := range actualVolumes { dn.AddOrUpdateVolume(v) } |