aboutsummaryrefslogtreecommitdiffstats
path: root/ydb/core/persqueue/read_balancer.cpp
diff options
context:
space:
mode:
authorzhenyok <zhenyok@yandex-team.ru>2022-02-10 16:50:32 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:32 +0300
commitae11a371d50c25e7fff450f692a12cba03ceaf4f (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /ydb/core/persqueue/read_balancer.cpp
parentb4b9936f4dce18fb9da09a1e46342c289d19663b (diff)
downloadydb-ae11a371d50c25e7fff450f692a12cba03ceaf4f.tar.gz
Restoring authorship annotation for <zhenyok@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'ydb/core/persqueue/read_balancer.cpp')
-rw-r--r--ydb/core/persqueue/read_balancer.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/ydb/core/persqueue/read_balancer.cpp b/ydb/core/persqueue/read_balancer.cpp
index 79995ee314..4eb9c7206d 100644
--- a/ydb/core/persqueue/read_balancer.cpp
+++ b/ydb/core/persqueue/read_balancer.cpp
@@ -740,7 +740,7 @@ TPersQueueReadBalancer::TClientGroupInfo& TPersQueueReadBalancer::TClientInfo::A
clientInfo.ClientId = ClientId;
clientInfo.Topic = Topic;
clientInfo.TabletId = TabletId;
- clientInfo.Path = Path;
+ clientInfo.Path = Path;
clientInfo.Generation = Generation;
clientInfo.Step = &Step;
@@ -833,7 +833,7 @@ void TPersQueueReadBalancer::Handle(TEvPersQueue::TEvRegisterReadSession::TPtr&
it->second.ClientId = record.GetClientId();
it->second.Topic = Topic;
it->second.TabletId = TabletID();
- it->second.Path = Path;
+ it->second.Path = Path;
it->second.Generation = Generation;
it->second.Step = 0;
}
@@ -1142,7 +1142,7 @@ void TPersQueueReadBalancer::TClientGroupInfo::LockPartition(const TActorId pipe
res->Record.SetSession(pipeInfo.Session);
res->Record.SetPartition(partition);
res->Record.SetTopic(Topic);
- res->Record.SetPath(Path);
+ res->Record.SetPath(Path);
res->Record.SetGeneration(Generation);
res->Record.SetStep(++(*Step));
res->Record.SetClientId(ClientId);
@@ -1166,7 +1166,7 @@ void TPersQueueReadBalancer::TClientGroupInfo::ReleasePartition(const TActorId p
THolder<TEvPersQueue::TEvReleasePartition> res{new TEvPersQueue::TEvReleasePartition};
res->Record.SetSession(sessionInfo.Session);
res->Record.SetTopic(Topic);
- res->Record.SetPath(Path);
+ res->Record.SetPath(Path);
res->Record.SetGeneration(Generation);
res->Record.SetClientId(ClientId);
res->Record.SetCount(count);