diff options
author | snaury <snaury@ydb.tech> | 2023-03-03 09:50:55 +0300 |
---|---|---|
committer | snaury <snaury@ydb.tech> | 2023-03-03 09:50:55 +0300 |
commit | 5f92e28da94623bf77457128d29720bb545aceae (patch) | |
tree | 34ad803183fab199840a19a31ffa34e2d29c398a | |
parent | abfca1b53fa9b0a4bd67a60fc117ab3af735bc78 (diff) | |
download | ydb-5f92e28da94623bf77457128d29720bb545aceae.tar.gz |
Use postfix increments for NextTieBreakerIndex
-rw-r--r-- | ydb/core/tx/datashard/cdc_stream_scan.cpp | 2 | ||||
-rw-r--r-- | ydb/core/tx/datashard/datashard__conditional_erase_rows.cpp | 2 |
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))); |