Method sendRespWithBlockMessage

pkg/wshutil/wshrpc.go:847–875

(msg RpcMessage)

}

func (w *WshRpc) sendRespWithBlockMessage(msg RpcMessage) {
	respCh, rd := w.getResponseCh(msg.ResId)
	if respCh == nil {
		return
	}
	select {
	case respCh <- &msg:
		// normal case, message got sent, just return!
		return
	default:
		// channel is full, we would block...
	}
	// log the fact that we're blocking
	_, noLog := blockingExpMap.Get(msg.ResId)
	if !noLog {
		log.Printf("[rpc:%s] blocking on response command:%s route:%s resid:%s\n", w.DebugName, rd.Command, rd.Route, msg.ResId)
		blockingExpMap.Set(msg.ResId, true, time.Now().Add(time.Second))
	}
	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
	defer cancel()
	select {
	case respCh <- &msg:
		// message got sent, just return!
		return
	case <-ctx.Done():
	}
	log.Printf("[rpc:%s] failed to clear response channel (waited 1s), will fail RPC command:%s route:%s resid:%s\n", w.DebugName, rd.Command, rd.Route, msg.ResId)
	w.unregisterRpc(msg.ResId, nil) // we don't pass an error because the channel is full, it won't work anyway...
}