From 2415675c3d5eab6112d1a883e6cd51128c6edbc7 Mon Sep 17 00:00:00 2001 From: Conner Fromknecht Date: Fri, 31 Aug 2018 14:48:58 -0700 Subject: [PATCH] server: move gossip dispatch to peer See next commit msg for more detail. --- server.go | 27 --------------------------- 1 file changed, 27 deletions(-) diff --git a/server.go b/server.go index 3ed068387..2378010bc 100644 --- a/server.go +++ b/server.go @@ -2364,33 +2364,6 @@ func (s *server) peerInitializer(p *peer) { // was successful, and to begin watching the peer's wait group. close(ready) - switch { - // If the remote peer knows of the new gossip queries feature, then - // we'll create a new gossipSyncer in the AuthenticatedGossiper for it. - case p.remoteLocalFeatures.HasFeature(lnwire.GossipQueriesOptional): - srvrLog.Infof("Negotiated chan series queries with %x", - p.pubKeyBytes[:]) - - // We'll only request channel updates from the remote peer if - // its enabled in the config, or we're already getting updates - // from enough peers. - // - // TODO(roasbeef): craft s.t. we only get updates from a few - // peers - recvUpdates := !cfg.NoChanUpdates - go s.authGossiper.InitSyncState(p, recvUpdates) - - // If the remote peer has the initial sync feature bit set, then we'll - // being the synchronization protocol to exchange authenticated channel - // graph edges/vertexes, but only if they don't know of the new gossip - // queries. - case p.remoteLocalFeatures.HasFeature(lnwire.InitialRoutingSync): - srvrLog.Infof("Requesting full table sync with %x", - p.pubKeyBytes[:]) - - go s.authGossiper.SynchronizeNode(p) - } - pubStr := string(p.addr.IdentityKey.SerializeCompressed()) s.mu.Lock()