(linkId baseds.LinkId, lm *linkMeta, backlog []backlogMessageWrap)
| 447 | } |
| 448 | |
| 449 | func (router *WshRouter) drainLinkBacklog_withLock(linkId baseds.LinkId, lm *linkMeta, backlog []backlogMessageWrap) []backlogMessageWrap { |
| 450 | for len(backlog) > 0 { |
| 451 | msg := backlog[0] |
| 452 | sent := lm.client.SendRpcMessage(msg.msgBytes, msg.ingressLinkId, msg.debugStr) |
| 453 | if !sent { |
| 454 | return backlog |
| 455 | } |
| 456 | backlog = backlog[1:] |
| 457 | } |
| 458 | return backlog |
| 459 | } |
| 460 | |
| 461 | func (router *WshRouter) processOneBacklogRound() { |
| 462 | router.lock.Lock() |
no test coverage detected