(req *RpcMessage, ingressLinkId baseds.LinkId)
| 277 | } |
| 278 | |
| 279 | func (w *WshRpc) handleRequest(req *RpcMessage, ingressLinkId baseds.LinkId) { |
| 280 | pprof.Do(context.Background(), pprof.Labels("rpc", req.Command), func(pprofCtx context.Context) { |
| 281 | w.handleRequestInternal(req, ingressLinkId, pprofCtx) |
| 282 | }) |
| 283 | } |
| 284 | |
| 285 | func (w *WshRpc) handleEventRecv(req *RpcMessage) { |
| 286 | if req.Data == nil { |
no test coverage detected