Minor bug fix in TagThrottlerImpl::tryUpdateAutoThrottling

This commit is contained in:
sfc-gh-tclinkenbeard 2022-03-12 13:32:41 -04:00
parent cc52a44df5
commit 324a678e39

View File

@ -187,11 +187,14 @@ public:
auto storageDurabilityLag = ss.getDurabilityLag();
if (storageQueue > SERVER_KNOBS->AUTO_TAG_THROTTLE_STORAGE_QUEUE_BYTES ||
storageDurabilityLag > SERVER_KNOBS->AUTO_TAG_THROTTLE_DURABILITY_LAG_VERSIONS) {
// TODO: Update once size is potentially > 1
ASSERT_WE_THINK(ss.busiestWriteTags.size() <= 1);
ASSERT_WE_THINK(ss.busiestReadTags.size() <= 1);
for (const auto& busyWriteTag : ss.busiestWriteTags) {
return tryUpdateAutoThrottling(busyWriteTag.tag,
busyWriteTag.rate,
busyWriteTag.fractionalBusyness,
TagThrottledReason::BUSY_READ);
TagThrottledReason::BUSY_WRITE);
}
for (const auto& busyReadTag : ss.busiestReadTags) {
return tryUpdateAutoThrottling(