Fix

ydb-platform · May 13, 2024 · 2413457 · 2413457
1 parent 09b5e2c
commit 2413457
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/ydb/core/persqueue/fetch_request_actor.cpp b/ydb/core/persqueue/fetch_request_actor.cpp
@@ -472,15 +472,15 @@ struct TEvPrivate {
         if (record.HasErrorReason())
             read->SetErrorReason(record.GetErrorReason());
 
-        ++FetchRequestReadsDone;
+        ++FetchRequestReadsDone;чч
 
         auto it = TopicInfo.find(CanonizePath(topic));
         Y_ABORT_UNLESS(it != TopicInfo.end());
 
         SetMeteringMode(it->second.PQInfo->Description.GetPQTabletConfig().GetMeteringMode());
 
         if (IsQuotaRequired()) {
-            PendingQuotaAmount = CalcRuConsumption(GetPayloadSize(record)) + Settings.ChargeExtraRU ? 1 : 0;
+            PendingQuotaAmount = CalcRuConsumption(GetPayloadSize(record)) + (Settings.ChargeExtraRU ? 1 : 0);
             Settings.ChargeExtraRU = false;
             RequestDataQuota(PendingQuotaAmount, ctx);
         } else {

diff --git a/ydb/core/persqueue/writer/writer.cpp b/ydb/core/persqueue/writer/writer.cpp
@@ -526,7 +526,7 @@ class TPartitionWriter: public TActorBootstrapped<TPartitionWriter>, private TRl
 
             if (needToRequestQuota) {
                 ++processed;
-                PendingQuotaAmount += CalcRuConsumption(it->second.ByteSize()) + it->second.GetPartitionRequest().HasChargeExtraRUCount() ? it->second.GetPartitionRequest().GetChargeExtraRUCount() : 0;
+                PendingQuotaAmount += CalcRuConsumption(it->second.ByteSize()) + (it->second.GetPartitionRequest().HasChargeExtraRUCount() ? it->second.GetPartitionRequest().GetChargeExtraRUCount() : 0);
                 PendingQuota.emplace_back(it->first);
             }