(requestID string)
| 289 | } |
| 290 | |
| 291 | func (info *RuntimeInfo) loadRequest(requestID string) *RequestInfo { |
| 292 | if value, load := info.requestMap.Load(requestID); load { |
| 293 | return value.(*RequestInfo) |
| 294 | } |
| 295 | logs.Error(fmt.Sprintf("request not found in %s runtimeDispatcher", info.RuntimeID), |
| 296 | zap.String("request_id", requestID)) |
| 297 | return nil |
| 298 | } |
| 299 | |
| 300 | func (info *RuntimeInfo) handleInvokeDone(requestID string, params *url.Values, data string) bool { |
| 301 | if request := info.loadRequest(requestID); request != nil { |
no test coverage detected