diff options
author | Alexey Bogolyubskiy <i@bogolyubskiyalexey.ru> | 2022-05-20 18:48:41 +0300 |
---|---|---|
committer | Alexey Bogolyubskiy <i@bogolyubskiyalexey.ru> | 2022-05-20 18:48:41 +0300 |
commit | 1c96c3345be1820c6be4f4f307e12e6c20b2b384 (patch) | |
tree | dd03c4aab0ba03d16ef5dc4c6a1b263a9e93cb05 | |
parent | bd647416fc1f87644c0d8391b53d22254edfdfdd (diff) | |
download | ydb-1c96c3345be1820c6be4f4f307e12e6c20b2b384.tar.gz |
correct processing read-quota counters if read-rule removed/recreated
init
ref:63a6b76f3815d5c6c7ca2e4ce51c2d1dc4dd713e
-rw-r--r-- | ydb/core/persqueue/partition.cpp | 4 |
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); |