From 81d0f25ba14201b5a178c08f255b6845cfef3958 Mon Sep 17 00:00:00 2001 From: Matthew Jaffee Date: Mon, 21 Aug 2017 17:08:57 -0500 Subject: [PATCH] re-arrange GossipNodeSet.Open to hopefully avoid race --- gossip/gossip.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/gossip/gossip.go b/gossip/gossip.go index a967079cb..e2e43a00b 100644 --- a/gossip/gossip.go +++ b/gossip/gossip.go @@ -69,6 +69,12 @@ func (g *GossipNodeSet) Open() error { return err } g.memberlist = ml + g.broadcasts = &memberlist.TransmitLimitedQueue{ + NumNodes: func() int { + return ml.NumMembers() + }, + RetransmitMult: 3, + } // attach to gossip seed node nodes := []*pilosa.Node{&pilosa.Node{Host: g.config.gossipSeed}} //TODO: support a list of seeds @@ -76,12 +82,6 @@ func (g *GossipNodeSet) Open() error { if err != nil { return err } - g.broadcasts = &memberlist.TransmitLimitedQueue{ - NumNodes: func() int { - return ml.NumMembers() - }, - RetransmitMult: 3, - } return nil }