Respond with an error to the GetReadVersion request when the GRV limit is hit.
| 519 | |
| 520 | // Respond with an error to the GetReadVersion request when the GRV limit is hit. |
| 521 | void proxyGRVThresholdExceeded(const GetReadVersionRequest* req, GrvProxyStats* stats) { |
| 522 | ++stats->txnRequestErrors; |
| 523 | req->reply.sendError(grv_proxy_memory_limit_exceeded()); |
| 524 | if (req->priority == TransactionPriority::IMMEDIATE) { |
| 525 | TraceEvent(SevWarnAlways, "ProxyGRVThresholdExceededSystem").suppressFor(60); |
| 526 | } else if (req->priority == TransactionPriority::DEFAULT) { |
| 527 | TraceEvent(SevWarnAlways, "ProxyGRVThresholdExceededDefault").suppressFor(60); |
| 528 | } else { |
| 529 | TraceEvent(SevWarnAlways, "ProxyGRVThresholdExceededBatch").suppressFor(60); |
| 530 | } |
| 531 | } |
| 532 | |
| 533 | // Drop a GetReadVersion request from a queue, by responding an error to the request. |
| 534 | void dropRequestFromQueue(Deque<GetReadVersionRequest>* queue, GrvProxyStats* stats) { |
no test coverage detected