diff --git a/fdbserver/GlobalTagThrottler.actor.cpp b/fdbserver/GlobalTagThrottler.actor.cpp index 3aab77f5ac..398d6b6f78 100644 --- a/fdbserver/GlobalTagThrottler.actor.cpp +++ b/fdbserver/GlobalTagThrottler.actor.cpp @@ -704,7 +704,10 @@ public: std::vector const& storageServerIndices, OpType opType) { if (storageServerIndices.empty()) { - auto const costPerSS = CLIENT_KNOBS->TAG_THROTTLING_PAGE_SIZE * (pagesPerSecond / storageServers.size()); + auto costPerSS = CLIENT_KNOBS->TAG_THROTTLING_PAGE_SIZE * (pagesPerSecond / storageServers.size()); + if (opType == OpType::WRITE) { + costPerSS *= CLIENT_KNOBS->GLOBAL_TAG_THROTTLING_RW_FUNGIBILITY_RATIO; + } for (auto& storageServer : storageServers) { if (opType == OpType::READ) { storageServer.addReadCost(tag, costPerSS);