Skip to content

Commit

Permalink
Avoiding unnecessary copying (ydb-platform#2413)
Browse files Browse the repository at this point in the history
  • Loading branch information
nshestakov authored Mar 6, 2024
1 parent 2d2ceb9 commit c8ffbe2
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions ydb/core/persqueue/partition.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1832,7 +1832,7 @@ void TPartition::OnProcessTxsAndUserActsWriteComplete(ui64 cookie, const TActorC
Y_ABORT_UNLESS(cookie == SET_OFFSET_COOKIE);

if (ChangeConfig) {
EndChangePartitionConfig(ChangeConfig->Config,
EndChangePartitionConfig(std::move(ChangeConfig->Config),
ChangeConfig->TopicConverter,
ctx);
}
Expand Down Expand Up @@ -1906,11 +1906,11 @@ void TPartition::OnProcessTxsAndUserActsWriteComplete(ui64 cookie, const TActorC
}
}

void TPartition::EndChangePartitionConfig(const NKikimrPQ::TPQTabletConfig& config,
void TPartition::EndChangePartitionConfig(NKikimrPQ::TPQTabletConfig&& config,
NPersQueue::TTopicConverterPtr topicConverter,
const TActorContext& ctx)
{
Config = config;
Config = std::move(config);
PartitionConfig = GetPartitionConfig(Config);
PartitionGraph = MakePartitionGraph(Config);
TopicConverter = topicConverter;
Expand Down
2 changes: 1 addition & 1 deletion ydb/core/persqueue/partition.h
Original file line number Diff line number Diff line change
Expand Up @@ -318,7 +318,7 @@ class TPartition : public TActorBootstrapped<TPartition> {
void BeginChangePartitionConfig(const NKikimrPQ::TPQTabletConfig& config,
const TActorContext& ctx);
void OnProcessTxsAndUserActsWriteComplete(ui64 cookie, const TActorContext& ctx);
void EndChangePartitionConfig(const NKikimrPQ::TPQTabletConfig& config,
void EndChangePartitionConfig(NKikimrPQ::TPQTabletConfig&& config,
NPersQueue::TTopicConverterPtr topicConverter,
const TActorContext& ctx);
TString GetKeyConfig() const;
Expand Down

0 comments on commit c8ffbe2

Please sign in to comment.