summaryrefslogtreecommitdiff
path: root/src/mongo/db/storage/flow_control.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/storage/flow_control.cpp')
-rw-r--r--src/mongo/db/storage/flow_control.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/storage/flow_control.cpp b/src/mongo/db/storage/flow_control.cpp
index e811f87d4f5..ac010f891ae 100644
--- a/src/mongo/db/storage/flow_control.cpp
+++ b/src/mongo/db/storage/flow_control.cpp
@@ -294,8 +294,8 @@ int FlowControl::getNumTickets() {
// Flow Control is only enabled on nodes that can accept writes.
const bool canAcceptWrites = _replCoord->canAcceptNonLocalWrites();
- MONGO_FAIL_POINT_BLOCK(flowControlTicketOverride, failpointObj) {
- int numTickets = failpointObj.getData().getIntField("numTickets");
+ if (auto sfp = flowControlTicketOverride.scoped(); MONGO_unlikely(sfp.isActive())) {
+ int numTickets = sfp.getData().getIntField("numTickets");
if (numTickets > 0 && canAcceptWrites) {
return numTickets;
}