Method queueUpstreamMessage

pkg/wshutil/wshrouter.go:414–427

this will never block, can be called while holding router.Lock

(msgBytes []byte, debugStr string)

// this will never block, can be called while holding router.Lock
func (router *WshRouter) queueUpstreamMessage(msgBytes []byte, debugStr string) {
	_, upstream := router.getUpstreamClient()
	if upstream == nil {
		return
	}
	router.upstreamBufLock.Lock()
	defer router.upstreamBufLock.Unlock()
	router.upstreamBuf = append(router.upstreamBuf, messageWrap{msgBytes: msgBytes, debugStr: debugStr})
	if !router.upstreamLoopStarted {
		router.upstreamLoopStarted = true
		go router.runUpstreamBufferLoop()
	}
	router.upstreamBufCond.Signal()
}

func (router *WshRouter) runUpstreamBufferLoop() {
	defer func() {