()
| 817 | } |
| 818 | |
| 819 | func (router *WshRouter) getUpstreamClient() (baseds.LinkId, AbstractRpcClient) { |
| 820 | router.lock.Lock() |
| 821 | defer router.lock.Unlock() |
| 822 | if router.upstreamLinkId == baseds.NoLinkId { |
| 823 | return baseds.NoLinkId, nil |
| 824 | } |
| 825 | lm := router.linkMap[router.upstreamLinkId] |
| 826 | if lm == nil { |
| 827 | return baseds.NoLinkId, nil |
| 828 | } |
| 829 | return router.upstreamLinkId, lm.client |
| 830 | } |
| 831 | |
| 832 | func (router *WshRouter) publishRouteToBroker(routeId string) { |
| 833 | defer func() { |
no outgoing calls
no test coverage detected