Method sendRpcMessageToLink

pkg/wshutil/wshrouter.go:338–349

(linkId baseds.LinkId, client AbstractRpcClient, msgBytes []byte, ingressLinkId baseds.LinkId, debugStr string)

}

func (router *WshRouter) sendRpcMessageToLink(linkId baseds.LinkId, client AbstractRpcClient, msgBytes []byte, ingressLinkId baseds.LinkId, debugStr string) {
	router.lock.Lock()
	defer router.lock.Unlock()
	sent := false
	backlog := router.linkMsgBacklog[linkId]
	if len(backlog) == 0 {
		sent = client.SendRpcMessage(msgBytes, ingressLinkId, debugStr)
	}
	if !sent {
		router.addToBacklog_withlock(linkId, msgBytes, ingressLinkId, debugStr)
	}
}

func (router *WshRouter) runServer() {
	for input := range router.inputCh {