(msgBytes []byte, linkId baseds.LinkId, ingressLinkId baseds.LinkId)
| 305 | } |
| 306 | |
| 307 | func (router *WshRouter) sendMessageToLink(msgBytes []byte, linkId baseds.LinkId, ingressLinkId baseds.LinkId) bool { |
| 308 | lm := router.getLinkMeta(linkId) |
| 309 | if lm == nil { |
| 310 | return false |
| 311 | } |
| 312 | router.sendRpcMessageToLink(lm.linkId, lm.client, msgBytes, ingressLinkId, "link") |
| 313 | return true |
| 314 | } |
| 315 | |
| 316 | func (router *WshRouter) addToBacklog_withlock(linkId baseds.LinkId, msgBytes []byte, ingressLinkId baseds.LinkId, debugStr string) { |
| 317 | mapWasEmpty := len(router.linkMsgBacklog) == 0 |
no test coverage detected