From 472186c1be06b2e37f64a7a8a1c0e7bc2a85159a Mon Sep 17 00:00:00 2001 From: Milos Gajdos Date: Thu, 16 Jan 2020 17:04:04 +0000 Subject: [PATCH] Code consistency. Small bug fix. --- network/default.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/network/default.go b/network/default.go index 612f2b5c..160d3b21 100644 --- a/network/default.go +++ b/network/default.go @@ -854,7 +854,7 @@ func (n *network) processNetChan(listener tunnel.Listener) { q := []router.QueryOption{ router.QueryStrategy(n.router.Options().Advertise), } - routes, err := n.options.Router.Table().Query(q...) + routes, err := n.router.Table().Query(q...) switch err { case nil: // encode the routes to protobuf @@ -1051,7 +1051,7 @@ func (n *network) processNetChan(listener tunnel.Listener) { // unmarshal the routes received from remote peer route := pbUtil.ProtoToRoute(pbRoute) // continue if we are the originator of the route - if route.Router == n.options.Router.Options().Id { + if route.Router == n.router.Options().Id { log.Debugf("Network node %s skipping route addition: route already present", n.id) continue } @@ -1061,7 +1061,7 @@ func (n *network) processNetChan(listener tunnel.Listener) { router.QueryStrategy(n.router.Options().Advertise), } - routes, err := n.options.Router.Table().Query(q...) + routes, err := n.router.Table().Query(q...) if err != nil { log.Debugf("Network node %s failed listing best routes for %s: %v", n.id, route.Service, err) continue @@ -1075,6 +1075,7 @@ func (n *network) processNetChan(listener tunnel.Listener) { log.Debugf("Network node %s failed to add route: %v", n.id, err) continue } + continue } // find the best route for the given service @@ -1381,7 +1382,7 @@ func (n *network) manage() { q := []router.QueryOption{ router.QueryStrategy(n.router.Options().Advertise), } - routes, err := n.options.Router.Table().Query(q...) + routes, err := n.router.Table().Query(q...) switch err { case nil: // encode the routes to protobuf