@@ -148,9 +148,10 @@ void TimestampOrderingTransactionManager::YieldOwnership(
148
148
tile_group_header->SetTransactionId (tuple_id, INITIAL_TXN_ID);
149
149
}
150
150
151
- bool TimestampOrderingTransactionManager::PerformRead (
152
- TransactionContext *const current_txn, const ItemPointer &read_location,
153
- storage::TileGroupHeader *tile_group_header, bool acquire_ownership) {
151
+ bool TimestampOrderingTransactionManager::PerformRead (TransactionContext *const current_txn,
152
+ const ItemPointer &read_location,
153
+ storage::TileGroupHeader *tile_group_header,
154
+ bool acquire_ownership) {
154
155
ItemPointer location = read_location;
155
156
156
157
// ////////////////////////////////////////////////////////
@@ -346,8 +347,7 @@ void TimestampOrderingTransactionManager::PerformInsert(
346
347
oid_t tuple_id = location.offset ;
347
348
348
349
auto storage_manager = storage::StorageManager::GetInstance ();
349
- auto tile_group_header =
350
- storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
350
+ auto tile_group_header = storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
351
351
auto transaction_id = current_txn->GetTransactionId ();
352
352
353
353
// check MVCC info
@@ -391,8 +391,9 @@ void TimestampOrderingTransactionManager::PerformUpdate(
391
391
// version.
392
392
PELOTON_ASSERT (tile_group_header->GetTransactionId (old_location.offset ) ==
393
393
transaction_id);
394
- PELOTON_ASSERT (tile_group_header->GetPrevItemPointer (old_location.offset )
395
- .IsNull () == true );
394
+ PELOTON_ASSERT (
395
+ tile_group_header->GetPrevItemPointer (old_location.offset ).IsNull () ==
396
+ true );
396
397
397
398
// check whether the new version is empty.
398
399
PELOTON_ASSERT (new_tile_group_header->GetTransactionId (new_location.offset ) ==
@@ -496,8 +497,9 @@ void TimestampOrderingTransactionManager::PerformDelete(
496
497
PELOTON_ASSERT (tile_group_header->GetTransactionId (old_location.offset ) ==
497
498
transaction_id);
498
499
// we must be deleting the latest version.
499
- PELOTON_ASSERT (tile_group_header->GetPrevItemPointer (old_location.offset )
500
- .IsNull () == true );
500
+ PELOTON_ASSERT (
501
+ tile_group_header->GetPrevItemPointer (old_location.offset ).IsNull () ==
502
+ true );
501
503
502
504
// check whether the new version is empty.
503
505
PELOTON_ASSERT (new_tile_group_header->GetTransactionId (new_location.offset ) ==
@@ -552,8 +554,7 @@ void TimestampOrderingTransactionManager::PerformDelete(
552
554
oid_t tuple_id = location.offset ;
553
555
554
556
auto storage_manager = storage::StorageManager::GetInstance ();
555
- auto tile_group_header =
556
- storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
557
+ auto tile_group_header = storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
557
558
558
559
PELOTON_ASSERT (tile_group_header->GetTransactionId (tuple_id) ==
559
560
current_txn->GetTransactionId ());
@@ -595,8 +596,6 @@ ResultType TimestampOrderingTransactionManager::CommitTransaction(
595
596
return ResultType::SUCCESS;
596
597
}
597
598
598
- auto &rw_set = current_txn->GetReadWriteSet ();
599
-
600
599
auto storage_manager = storage::StorageManager::GetInstance ();
601
600
auto &log_manager = logging::LogManager::GetInstance ();
602
601
@@ -605,6 +604,7 @@ ResultType TimestampOrderingTransactionManager::CommitTransaction(
605
604
// generate transaction id.
606
605
cid_t end_commit_id = current_txn->GetCommitId ();
607
606
607
+ auto &rw_set = current_txn->GetReadWriteSet ();
608
608
auto &rw_object_set = current_txn->GetCreateDropSet ();
609
609
610
610
auto gc_set = current_txn->GetGCSetPtr ();
0 commit comments