neoris/core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use RLock instead of Lock

Browse Source
This commit is contained in:
Ingo Oppermann 2023-07-26 11:28:22 +02:00
parent ceb2144da5
commit 80feb0b565
No known key found for this signature in database
GPG Key ID: 2AB32426E9DD229E
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cluster/cluster.go
View File

@ -686,9 +686,9 @@ func (c *cluster) IsClusterDegraded() (bool, error) {
return true, err
}
c.nodesLock.Lock()
c.nodesLock.RLock()
nodes := len(c.nodes)
c.nodesLock.Unlock()
c.nodesLock.RUnlock()
if len(servers) != nodes {
return true, fmt.Errorf("not all nodes are connected")
@ -1391,7 +1391,7 @@ func (c *cluster) About() (ClusterAbout, error) {
serversMap[s.ID] = s
}
c.nodesLock.Lock()
c.nodesLock.RLock()
for id, node := range c.nodes {
nodeAbout := node.About()
@ -1435,7 +1435,7 @@ func (c *cluster) About() (ClusterAbout, error) {
about.Nodes = append(about.Nodes, node)
}
c.nodesLock.Unlock()
c.nodesLock.RUnlock()
return about, nil
}