| 8416 | } |
| 8417 | __name(requeueUnsentRequest, "requeueUnsentRequest"); |
| 8418 | function completeRequest(client, request, resetPendingIdx = false) { |
| 8419 | const index = client[kQueue].indexOf(request, client[kRunningIdx]); |
| 8420 | if (index === -1 || index >= client[kPendingIdx]) { |
| 8421 | return; |
| 8422 | } |
| 8423 | client[kQueue].splice(index, 1); |
| 8424 | client[kPendingIdx]--; |
| 8425 | if (resetPendingIdx && client[kPendingIdx] < client[kRunningIdx]) { |
| 8426 | client[kPendingIdx] = client[kRunningIdx]; |
| 8427 | } |
| 8428 | } |
| 8429 | __name(completeRequest, "completeRequest"); |
| 8430 | function canRetryRequestAfterGoAway(request) { |
| 8431 | const { body } = request; |