(reqId string)
| 264 | } |
| 265 | |
| 266 | func (w *WshRpc) cancelRequest(reqId string) { |
| 267 | if reqId == "" { |
| 268 | return |
| 269 | } |
| 270 | w.Lock.Lock() |
| 271 | defer w.Lock.Unlock() |
| 272 | handler := w.ResponseHandlerMap[reqId] |
| 273 | if handler != nil { |
| 274 | handler.canceled.Store(true) |
| 275 | } |
| 276 | |
| 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) { |