unistack-org/micro
4
0
Fork 3
Code Issues 19 Pull Requests 2 Actions 2 Packages Projects Releases 262 Wiki Activity

Move Debug to Trace in router

Browse Source
This commit is contained in:
Asim Aslam 2019-12-09 09:32:17 +00:00
parent e2b2a30668
commit 59c1680594
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
router/default.go
View File

@ -717,13 +717,15 @@ func (r *router) Process(a *Advert) error {
for _, event := range events { for _, event := range events {
// skip if the router is the origin of this route // skip if the router is the origin of this route
if event.Route.Router == r.options.Id { if event.Route.Router == r.options.Id {
log.Debugf("Router skipping processing its own route: %s", r.options.Id) log.Tracef("Router skipping processing its own route: %s", r.options.Id)
continue continue
} }
// create a copy of the route // create a copy of the route
route := event.Route route := event.Route
action := event.Type action := event.Type
log.Debugf("Router %s applying %s from router %s for service %s %s", r.options.Id, action, route.Router, route.Service, route.Address)
log.Tracef("Router %s applying %s from router %s for service %s %s", r.options.Id, action, route.Router, route.Service, route.Address)
if err := r.manageRoute(route, action.String()); err != nil { if err := r.manageRoute(route, action.String()); err != nil {
return fmt.Errorf("failed applying action %s to routing table: %s", action, err) return fmt.Errorf("failed applying action %s to routing table: %s", action, err)
} }
@ -874,7 +876,7 @@ func (r *router) Stop() error {
} }
r.Unlock() r.Unlock()
log.Debugf("Router waiting for all goroutines to finish") log.Tracef("Router waiting for all goroutines to finish")
// wait for all goroutines to finish // wait for all goroutines to finish
r.wg.Wait() r.wg.Wait()