Only check the router status if the lookup fails
This commit is contained in:
parent
cb4e376c64
commit
c0a676bfa9
@ -99,14 +99,14 @@ func (p *Proxy) getRoute(service string) ([]string, error) {
|
|||||||
p.Routes[service] = make(map[uint64]router.Route)
|
p.Routes[service] = make(map[uint64]router.Route)
|
||||||
p.Unlock()
|
p.Unlock()
|
||||||
|
|
||||||
// if the router is broken return error
|
|
||||||
if status := p.Router.Status(); status.Code == router.Error {
|
|
||||||
return nil, status.Error
|
|
||||||
}
|
|
||||||
|
|
||||||
// lookup the routes in the router
|
// lookup the routes in the router
|
||||||
results, err := p.Router.Lookup(router.NewQuery(router.QueryService(service)))
|
results, err := p.Router.Lookup(router.NewQuery(router.QueryService(service)))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
// check the status of the router
|
||||||
|
if status := p.Router.Status(); status.Code == router.Error {
|
||||||
|
return nil, status.Error
|
||||||
|
}
|
||||||
|
// otherwise return the error
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user