(rpc AbstractRpcClient)
| 651 | } |
| 652 | |
| 653 | func (router *WshRouter) RegisterUpstream(rpc AbstractRpcClient) baseds.LinkId { |
| 654 | if router.IsRootRouter() { |
| 655 | panic("cannot register upstream for root router") |
| 656 | } |
| 657 | linkId := router.RegisterUntrustedLink(rpc) |
| 658 | router.trustLink(linkId, LinkKind_Router) |
| 659 | router.lock.Lock() |
| 660 | defer router.lock.Unlock() |
| 661 | router.upstreamLinkId = linkId |
| 662 | return linkId |
| 663 | } |
| 664 | |
| 665 | func (router *WshRouter) registerControlPlane() { |
| 666 | controlImpl := &WshRouterControlImpl{Router: router} |
no test coverage detected