aboutsummaryrefslogtreecommitdiff
path: root/weed/topology/node.go
diff options
context:
space:
mode:
authorwusong <75450248+wusongANKANG@users.noreply.github.com>2023-06-06 15:17:51 +0800
committerGitHub <noreply@github.com>2023-06-06 00:17:51 -0700
commit9bdbf9c880f1d295e55dfdf4dec8c66875c9582f (patch)
tree6e5fd963e29ef587f70ed4fbc4de0ef38141614d /weed/topology/node.go
parent0bffb3770f4096cd8b0eb1be397a9e1372aaeea0 (diff)
downloadseaweedfs-9bdbf9c880f1d295e55dfdf4dec8c66875c9582f.tar.xz
seaweedfs-9bdbf9c880f1d295e55dfdf4dec8c66875c9582f.zip
revert #4491 (#4550)
Co-authored-by: wang wusong <wangwusong@virtaitech.com>
Diffstat (limited to 'weed/topology/node.go')
-rw-r--r--weed/topology/node.go2
1 files changed, 0 insertions, 2 deletions
diff --git a/weed/topology/node.go b/weed/topology/node.go
index 1380e79f8..1c7e3e468 100644
--- a/weed/topology/node.go
+++ b/weed/topology/node.go
@@ -248,7 +248,6 @@ func (n *NodeImpl) CollectDeadNodeAndFullVolumes(freshThreshHold int64, volumeSi
if n.IsRack() {
for _, c := range n.Children() {
dn := c.(*DataNode) //can not cast n to DataNode
- dn.RLock()
for _, v := range dn.GetVolumes() {
topo := n.GetTopology()
diskType := types.ToDiskType(v.DiskType)
@@ -278,7 +277,6 @@ func (n *NodeImpl) CollectDeadNodeAndFullVolumes(freshThreshHold int64, volumeSi
}
}
}
- dn.RUnlock()
}
} else {
for _, c := range n.Children() {