File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -2419,10 +2419,10 @@ TPartition::EProcessResult TPartition::BeginTransaction(const TEvPQ::TEvTxCalcPr
2419
2419
return EProcessResult::Blocked;
2420
2420
}
2421
2421
2422
- auto [error, real ] = ValidatePartitionOperation (operation);
2422
+ auto [error, needCheckConsumer ] = ValidatePartitionOperation (operation);
2423
2423
result = error.empty ();
2424
2424
2425
- if (real ) {
2425
+ if (needCheckConsumer ) {
2426
2426
if (!result) {
2427
2427
bool isAffectedConsumer = AffectedUsers.contains (consumer);
2428
2428
@@ -2929,7 +2929,7 @@ TPartition::EProcessResult TPartition::PreProcessImmediateTx(const NKikimrPQ::TE
2929
2929
return EProcessResult::ContinueDrop;
2930
2930
}
2931
2931
2932
- auto [error, real ] = ValidatePartitionOperation (operation);
2932
+ auto [error, needCheckConsumer ] = ValidatePartitionOperation (operation);
2933
2933
if (!error.empty ()) {
2934
2934
ScheduleReplyPropose (tx,
2935
2935
NKikimrPQ::TEvProposeTransactionResult::BAD_REQUEST,
@@ -2938,7 +2938,7 @@ TPartition::EProcessResult TPartition::PreProcessImmediateTx(const NKikimrPQ::TE
2938
2938
return EProcessResult::ContinueDrop;
2939
2939
}
2940
2940
2941
- if (real ) {
2941
+ if (needCheckConsumer ) {
2942
2942
consumers.insert (user);
2943
2943
}
2944
2944
}
You can’t perform that action at this time.
0 commit comments