Mercurial > lbo > hg > clusterconsensus

changeset 35:b0c0254f4368

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Improvements to StartParticipation
author Lewin Bormann <lbo@spheniscida.de>
date Wed, 24 Jul 2019 15:10:59 +0200
parents 8fa310d9bb1d
children c95f50810bcd
files participant_impl.go
diffstat 1 files changed, 3 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- a/participant_impl.go	Wed Jul 24 15:10:36 2019 +0200
+++ b/participant_impl.go	Wed Jul 24 15:10:59 2019 +0200
@@ -306,16 +306,17 @@
 	p.sequence = s
 	p.state.Install(snapshot)
 
-	if len(members) == 1 && members[0] == master {
+	if self == master {
 		// Bootstrapped externally
 		p.participantState = state_MASTER
+		p.eventHandler.OnBecomeMaster(p)
 	} else {
 		p.participantState = state_PARTICIPANT_CLEAN
 	}
 
 	for _, member := range members {
 		// Try connecting already.
-		p.getConnectedClient(member)
+		go p.getConnectedClient(member)
 	}
 
 	return nil