scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix unlocked access to cluster.nodes

Browse source
This commit is contained in:
Matt Jaffee 2019-04-05 14:50:26 -05:00
parent d5cfe880f7
commit 79968e5d2f
No known key found for this signature in database
GPG key ID: 08A3DFFF987B11BF
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
cluster.go
View file

@ -296,16 +296,16 @@ func (c *cluster) unprotectedIsCoordinator() bool {
// nodes with its version of Cluster.Status.
func (c *cluster) setCoordinator(n *Node) error {
c.mu.Lock()
defer c.mu.Unlock()
// Verify that the new Coordinator value matches
// this node.
if c.Node.ID != n.ID {
c.mu.Unlock()
return fmt.Errorf("coordinator node does not match this node")
}
// Update IsCoordinator on all nodes (locally).
_ = c.unprotectedUpdateCoordinator(n)
c.mu.Unlock()
// Send the update coordinator message to all nodes.
err := c.unprotectedSendSync(
&UpdateCoordinatorMessage{
@ -316,7 +316,7 @@ func (c *cluster) setCoordinator(n *Node) error {
}
// Broadcast cluster status.
return c.unprotectedSendSync(c.status())
return c.unprotectedSendSync(c.unprotectedStatus())
}
// unprotectedSendSync is used in place of c.broadcaster.SendSync (which is