scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-10-07 11:27:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add comment to listenForJoins

Browse source
This commit is contained in:
Cody Soyland 2018-03-06 15:13:24 -06:00
parent d28a30ebd4
commit b7b92913d9
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
cluster.go
View file

@ -1002,7 +1002,13 @@ func (c *Cluster) ListenForJoins() {
}
func (c *Cluster) listenForJoins() {
var uriJoined bool
// When a cluster starts, the state is STARTING.
// We first want to wait for at least one node to join.
// Then we want to clear out the joiningLeavingNodes queue (buffered channel).
// Then we want to set the cluster state to NORMAL and resume processing of joiningLeavingNodes events.
// We use a bool `setNormal` to indicate when at least one node has joined.
var setNormal bool
for {
@ -1014,13 +1020,13 @@ func (c *Cluster) listenForJoins() {
c.logger().Printf("handleNodeAction error: err=%s", err)
continue
}
uriJoined = true
setNormal = true
continue
default:
}
// Only change state to NORMAL if we have successfully added at least one host.
if uriJoined {
if setNormal {
// Put the cluster back to state NORMAL and broadcast.
if err := c.setStateAndBroadcast(ClusterStateNormal); err != nil {
c.logger().Printf("setStateAndBroadcast error: err=%s", err)
@ -1037,7 +1043,7 @@ func (c *Cluster) listenForJoins() {
c.logger().Printf("handleNodeAction error: err=%s", err)
continue
}
uriJoined = true
setNormal = true
continue
}
}