aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAlexey Bogolyubskiy <i@bogolyubskiyalexey.ru>2022-05-20 18:48:41 +0300
committerAlexey Bogolyubskiy <i@bogolyubskiyalexey.ru>2022-05-20 18:48:41 +0300
commit1c96c3345be1820c6be4f4f307e12e6c20b2b384 (patch)
treedd03c4aab0ba03d16ef5dc4c6a1b263a9e93cb05
parentbd647416fc1f87644c0d8391b53d22254edfdfdd (diff)
downloadydb-1c96c3345be1820c6be4f4f307e12e6c20b2b384.tar.gz
correct processing read-quota counters if read-rule removed/recreated
init ref:63a6b76f3815d5c6c7ca2e4ce51c2d1dc4dd713e
-rw-r--r--ydb/core/persqueue/partition.cpp4
1 files changed, 1 insertions, 3 deletions
diff --git a/ydb/core/persqueue/partition.cpp b/ydb/core/persqueue/partition.cpp
index 76ad7b67523..728a8c70281 100644
--- a/ydb/core/persqueue/partition.cpp
+++ b/ydb/core/persqueue/partition.cpp
@@ -1238,9 +1238,7 @@ void TPartition::Handle(TEvPQ::TEvMirrorerCounters::TPtr& ev, const TActorContex
void TPartition::Handle(NReadSpeedLimiterEvents::TEvCounters::TPtr& ev, const TActorContext& /*ctx*/) {
auto userInfo = UsersInfoStorage.GetIfExists(ev->Get()->User);
- Y_VERIFY(userInfo);
- if (userInfo) {
- Y_VERIFY(userInfo->ReadSpeedLimiter);
+ if (userInfo && userInfo->ReadSpeedLimiter) {
auto diff = ev->Get()->Counters.MakeDiffForAggr(userInfo->ReadSpeedLimiter->Baseline);
Counters.Populate(*diff.Get());
ev->Get()->Counters.RememberCurrentStateAsBaseline(userInfo->ReadSpeedLimiter->Baseline);