From 1a5f1977c4a682417cdab3b3660770839f920406 Mon Sep 17 00:00:00 2001 From: Emile Vauge Date: Fri, 9 Dec 2016 14:26:33 +0100 Subject: [PATCH] Fix safe panic --- cluster/leadership.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/cluster/leadership.go b/cluster/leadership.go index 8b6a66802..5173dd421 100644 --- a/cluster/leadership.go +++ b/cluster/leadership.go @@ -16,7 +16,7 @@ type Leadership struct { *safe.Pool *types.Cluster candidate *leadership.Candidate - leader safe.Safe + leader *safe.Safe listeners []LeaderListener } @@ -27,6 +27,7 @@ func NewLeadership(ctx context.Context, cluster *types.Cluster) *Leadership { Cluster: cluster, candidate: leadership.NewCandidate(cluster.Store, cluster.Store.Prefix+"/leader", cluster.Node, 20*time.Second), listeners: []LeaderListener{}, + leader: safe.New(false), } }