gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(master): fix dead lock for flashnode

Browse Source 
close:#22985995

Signed-off-by: chihe <chihe@oppo.com>
This commit is contained in:
chihe 2025-01-17 16:35:51 +08:00 committed by zhumingze1108
parent 5e57eb1ecd
commit 12917180d4
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
master/cluster.go
View File

@ -4145,12 +4145,13 @@ func (c *Cluster) allFlashNodes() (flashNodes []proto.NodeView) {
flashNodes = make([]proto.NodeView, 0)
c.flashNodeTopo.flashNodeMap.Range(func(addr, node interface{}) bool {
flashNode := node.(*FlashNode)
isWritable := flashNode.isWriteable()
flashNode.RLock()
flashNodes = append(flashNodes, proto.NodeView{
ID: flashNode.ID,
Addr: flashNode.Addr,
Status: flashNode.IsActive,
IsWritable: flashNode.isWriteable(),
IsWritable: isWritable,
})
flashNode.RUnlock()
return true