Skip to content

Commit

Permalink
remove finalise
Browse files Browse the repository at this point in the history
  • Loading branch information
sunny2022da committed Aug 2, 2024
1 parent 99df4ae commit a43d724
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion core/parallel_state_processor.go
Original file line number Diff line number Diff line change
Expand Up @@ -365,7 +365,7 @@ func (p *ParallelStateProcessor) executeInSlot(slotIndex int, txReq *ParallelTxR
conflictIndex = txReq.conflictIndex.Load()
if conflictIndex < mIndex {
if txReq.conflictIndex.CompareAndSwap(conflictIndex, mIndex) {
log.Debug("Update conflictIndex in execution because of error, new conflictIndex: %d", conflictIndex)
log.Debug(fmt.Sprintf("Update conflictIndex in execution because of error: %s, new conflictIndex: %d", err.Error(), conflictIndex))
}
}
atomic.CompareAndSwapInt32(&txReq.runnable, 0, 1)
Expand Down
2 changes: 1 addition & 1 deletion core/state/parallel_statedb.go
Original file line number Diff line number Diff line change
Expand Up @@ -1558,7 +1558,7 @@ func (s *ParallelStateDB) FinaliseForParallel(deleteEmptyObjects bool, mainDB *S
obj.finalise(true) // Prefetch slots in the background
} else {
obj.fixUpOriginAndResetPendingStorage()
obj.finalise(false)
// obj.finalise(false)
}
}

Expand Down

0 comments on commit a43d724

Please sign in to comment.