From d82985196c4d3efb63a7f16e713c3ba6f6ada2e5 Mon Sep 17 00:00:00 2001 From: Artem Barger Date: Sat, 1 Apr 2017 00:03:17 +0300 Subject: [PATCH] [FAB-2944]: Make leadership callback synchronous In order to make leader election test consistent and not to fail this commit makes switching leadership state synchronous. Change-Id: Ie04155bd089f0e7e8553bca9df33e14e0d332817 Signed-off-by: Artem Barger --- gossip/election/election.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/gossip/election/election.go b/gossip/election/election.go index b19437d3412..2fcb7eefdf5 100644 --- a/gossip/election/election.go +++ b/gossip/election/election.go @@ -361,13 +361,13 @@ func (le *leaderElectionSvcImpl) IsLeader() bool { func (le *leaderElectionSvcImpl) beLeader() { le.logger.Debug(le.id, ": Becoming a leader") atomic.StoreInt32(&le.isLeader, int32(1)) - go le.callback(true) + le.callback(true) } func (le *leaderElectionSvcImpl) stopBeingLeader() { le.logger.Debug(le.id, "Stopped being a leader") atomic.StoreInt32(&le.isLeader, int32(0)) - go le.callback(false) + le.callback(false) } func (le *leaderElectionSvcImpl) shouldStop() bool {