(linkId baseds.LinkId)
| 713 | } |
| 714 | |
| 715 | func (router *WshRouter) UnregisterLink(linkId baseds.LinkId) { |
| 716 | routes := router.getRoutesForLink(linkId) |
| 717 | for _, routeId := range routes { |
| 718 | router.unbindRoute(linkId, routeId) |
| 719 | } |
| 720 | router.lock.Lock() |
| 721 | defer router.lock.Unlock() |
| 722 | lm := router.linkMap[linkId] |
| 723 | if lm != nil { |
| 724 | log.Printf("wshrouter unregister link %s", lm.Name()) |
| 725 | } |
| 726 | delete(router.linkMap, linkId) |
| 727 | if router.upstreamLinkId == linkId { |
| 728 | router.upstreamLinkId = baseds.NoLinkId |
| 729 | } |
| 730 | } |
| 731 | |
| 732 | func isBindableRouteId(routeId string) bool { |
| 733 | if routeId == "" || strings.HasPrefix(routeId, ControlPrefix) || strings.HasPrefix(routeId, RoutePrefix_Link) { |
no test coverage detected