aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorsnaury <snaury@ydb.tech>2023-03-03 09:50:55 +0300
committersnaury <snaury@ydb.tech>2023-03-03 09:50:55 +0300
commit5f92e28da94623bf77457128d29720bb545aceae (patch)
tree34ad803183fab199840a19a31ffa34e2d29c398a
parentabfca1b53fa9b0a4bd67a60fc117ab3af735bc78 (diff)
downloadydb-5f92e28da94623bf77457128d29720bb545aceae.tar.gz
Use postfix increments for NextTieBreakerIndex
-rw-r--r--ydb/core/tx/datashard/cdc_stream_scan.cpp2
-rw-r--r--ydb/core/tx/datashard/datashard__conditional_erase_rows.cpp2
2 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/tx/datashard/cdc_stream_scan.cpp b/ydb/core/tx/datashard/cdc_stream_scan.cpp
index 8d65d8ba5d1..2b27c0e2d3b 100644
--- a/ydb/core/tx/datashard/cdc_stream_scan.cpp
+++ b/ydb/core/tx/datashard/cdc_stream_scan.cpp
@@ -643,7 +643,7 @@ public:
// Note: cdc stream is added with a schema transaction and those wait for volatile txs
Y_VERIFY(!Self->GetVolatileTxManager().HasVolatileTxsAtSnapshot(snapshotVersion));
- const ui64 localTxId = ++Self->NextTieBreakerIndex;
+ const ui64 localTxId = Self->NextTieBreakerIndex++;
auto scan = MakeHolder<TCdcStreamScan>(Self, Request->Sender, localTxId,
tablePathId, streamPathId, snapshotVersion, valueTags, info->LastKey, info->Stats, record.GetLimits());
const ui64 scanId = Self->QueueScan(table->LocalTid, scan.Release(), localTxId,
diff --git a/ydb/core/tx/datashard/datashard__conditional_erase_rows.cpp b/ydb/core/tx/datashard/datashard__conditional_erase_rows.cpp
index 8860e32f54a..7e1bca7c3a1 100644
--- a/ydb/core/tx/datashard/datashard__conditional_erase_rows.cpp
+++ b/ydb/core/tx/datashard/datashard__conditional_erase_rows.cpp
@@ -556,7 +556,7 @@ void TDataShard::Handle(TEvDataShard::TEvConditionalEraseRowsRequest::TPtr& ev,
if (column != userTable->Columns.end()) {
TString error;
if (CheckUnit(column->second.Type, record.GetExpiration().GetColumnUnit(), error)) {
- localTxId = ++NextTieBreakerIndex;
+ localTxId = NextTieBreakerIndex++;
const auto tableId = TTableId(PathOwnerId, localPathId, record.GetSchemaVersion());
scan.Reset(CreateCondEraseScan(this, ev->Sender, tableId, localTxId,
THolder(CreateEraseRowsCondition(record)), record.GetLimits(), GetIndexes(record)));