diff options
author | zhenyok <zhenyok@yandex-team.ru> | 2022-02-10 16:50:32 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:32 +0300 |
commit | ae11a371d50c25e7fff450f692a12cba03ceaf4f (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /ydb/core/persqueue/read_balancer.cpp | |
parent | b4b9936f4dce18fb9da09a1e46342c289d19663b (diff) | |
download | ydb-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.cpp | 8 |
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); |