@@ -171,10 +171,9 @@ void TimestampOrderingTransactionManager::YieldOwnership(
171
171
tile_group_header->SetTransactionId (tuple_id, INITIAL_TXN_ID);
172
172
}
173
173
174
- bool TimestampOrderingTransactionManager::PerformRead (TransactionContext *const current_txn,
175
- const ItemPointer &read_location,
176
- storage::TileGroupHeader *tile_group_header,
177
- bool acquire_ownership) {
174
+ bool TimestampOrderingTransactionManager::PerformRead (
175
+ TransactionContext *const current_txn, const ItemPointer &read_location,
176
+ storage::TileGroupHeader *tile_group_header, bool acquire_ownership) {
178
177
ItemPointer location = read_location;
179
178
180
179
// ////////////////////////////////////////////////////////
@@ -374,7 +373,8 @@ void TimestampOrderingTransactionManager::PerformInsert(
374
373
oid_t tuple_id = location.offset ;
375
374
376
375
auto storage_manager = storage::StorageManager::GetInstance ();
377
- auto tile_group_header = storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
376
+ auto tile_group_header =
377
+ storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
378
378
auto transaction_id = current_txn->GetTransactionId ();
379
379
380
380
// check MVCC info
@@ -420,9 +420,8 @@ void TimestampOrderingTransactionManager::PerformUpdate(
420
420
// version.
421
421
PELOTON_ASSERT (tile_group_header->GetTransactionId (old_location.offset ) ==
422
422
transaction_id);
423
- PELOTON_ASSERT (
424
- tile_group_header->GetPrevItemPointer (old_location.offset ).IsNull () ==
425
- true );
423
+ PELOTON_ASSERT (tile_group_header->GetPrevItemPointer (old_location.offset )
424
+ .IsNull () == true );
426
425
427
426
// check whether the new version is empty.
428
427
PELOTON_ASSERT (new_tile_group_header->GetTransactionId (new_location.offset ) ==
@@ -529,9 +528,8 @@ void TimestampOrderingTransactionManager::PerformDelete(
529
528
PELOTON_ASSERT (tile_group_header->GetTransactionId (old_location.offset ) ==
530
529
transaction_id);
531
530
// we must be deleting the latest version.
532
- PELOTON_ASSERT (
533
- tile_group_header->GetPrevItemPointer (old_location.offset ).IsNull () ==
534
- true );
531
+ PELOTON_ASSERT (tile_group_header->GetPrevItemPointer (old_location.offset )
532
+ .IsNull () == true );
535
533
536
534
// check whether the new version is empty.
537
535
PELOTON_ASSERT (new_tile_group_header->GetTransactionId (new_location.offset ) ==
@@ -588,7 +586,8 @@ void TimestampOrderingTransactionManager::PerformDelete(
588
586
oid_t tuple_id = location.offset ;
589
587
590
588
auto storage_manager = storage::StorageManager::GetInstance ();
591
- auto tile_group_header = storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
589
+ auto tile_group_header =
590
+ storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
592
591
593
592
PELOTON_ASSERT (tile_group_header->GetTransactionId (tuple_id) ==
594
593
current_txn->GetTransactionId ());
@@ -660,7 +659,8 @@ ResultType TimestampOrderingTransactionManager::CommitTransaction(
660
659
oid_t tile_group_id = item_ptr.block ;
661
660
oid_t tuple_slot = item_ptr.offset ;
662
661
663
- auto tile_group_header = storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
662
+ auto tile_group_header =
663
+ storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
664
664
665
665
if (tuple_entry.second == RWType::READ_OWN) {
666
666
// A read operation has acquired ownership but hasn't done any further
@@ -811,7 +811,8 @@ ResultType TimestampOrderingTransactionManager::AbortTransaction(
811
811
ItemPointer item_ptr = tuple_entry.first ;
812
812
oid_t tile_group_id = item_ptr.block ;
813
813
oid_t tuple_slot = item_ptr.offset ;
814
- auto tile_group_header = storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
814
+ auto tile_group_header =
815
+ storage_manager->GetTileGroup (tile_group_id)->GetHeader ();
815
816
816
817
if (tuple_entry.second == RWType::READ_OWN) {
817
818
// A read operation has acquired ownership but hasn't done any further
0 commit comments