(request *RequestInfo, signal bool)
| 314 | } |
| 315 | |
| 316 | func (info *RuntimeInfo) InvokeDone(request *RequestInfo, signal bool) { |
| 317 | if _, load := info.requestMap.Load(request.RequestID); !load { |
| 318 | return |
| 319 | } |
| 320 | |
| 321 | if signal { |
| 322 | request.Notify() |
| 323 | } |
| 324 | |
| 325 | if request.Status == StatusSuccess { |
| 326 | info.AcceptReqCnt++ |
| 327 | } else if request.Status == StatusFailed { |
| 328 | info.RejectReqCnt++ |
| 329 | } |
| 330 | |
| 331 | info.requestMap.Delete(request.RequestID) |
| 332 | } |
| 333 | |
| 334 | // Wait |
| 335 | func (info *RuntimeInfo) Wait(timeout int) bool { |
no test coverage detected