aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorsavnik <savnik@yandex-team.com>2023-11-23 13:36:19 +0300
committersavnik <savnik@yandex-team.com>2023-11-23 14:55:51 +0300
commitd905ff543932f12524a619ef99d858a170d353e6 (patch)
tree9acc816390b6b2209ef3bdd347ed9ec3eeec31ea
parent8fd572daa8ce37d33f2b87ee14f11fb740f77526 (diff)
downloadydb-d905ff543932f12524a619ef99d858a170d353e6.tar.gz
Fix use after move
-rw-r--r--ydb/core/persqueue/read_quoter.cpp3
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;