diff options
author | savnik <savnik@yandex-team.com> | 2023-11-23 13:36:19 +0300 |
---|---|---|
committer | savnik <savnik@yandex-team.com> | 2023-11-23 14:55:51 +0300 |
commit | d905ff543932f12524a619ef99d858a170d353e6 (patch) | |
tree | 9acc816390b6b2209ef3bdd347ed9ec3eeec31ea | |
parent | 8fd572daa8ce37d33f2b87ee14f11fb740f77526 (diff) | |
download | ydb-d905ff543932f12524a619ef99d858a170d353e6.tar.gz |
Fix use after move
-rw-r--r-- | ydb/core/persqueue/read_quoter.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/core/persqueue/read_quoter.cpp b/ydb/core/persqueue/read_quoter.cpp index d944477d85..1bfba7e68c 100644 --- a/ydb/core/persqueue/read_quoter.cpp +++ b/ydb/core/persqueue/read_quoter.cpp @@ -228,9 +228,10 @@ TConsumerReadQuota* TReadQuoter::GetOrCreateConsumerQuota(const TString& consume auto it = ConsumerQuotas.find(consumerStr); if (it == ConsumerQuotas.end()) { TConsumerReadQuota consumer(CreateAccountQuotaTracker(consumerStr), GetConsumerReadBurst(ctx), GetConsumerReadSpeed(ctx)); + Send(PartitionActor, new NReadQuoterEvents::TEvQuotaUpdated({{consumerStr, consumer.PartitionPerConsumerQuotaTracker.GetTotalSpeed()}}, PartitionTotalQuotaTracker.GetTotalSpeed())); + auto result = ConsumerQuotas.emplace(consumerStr, std::move(consumer)); Y_ABORT_UNLESS(result.second); - Send(PartitionActor, new NReadQuoterEvents::TEvQuotaUpdated({{consumerStr, consumer.PartitionPerConsumerQuotaTracker.GetTotalSpeed()}}, PartitionTotalQuotaTracker.GetTotalSpeed())); return &result.first->second; } return &it->second; |