fix timer

sunny2022da · Aug 21, 2024 · c0fc7cf · c0fc7cf
1 parent 7ca80e3
commit c0fc7cf
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/core/parallel_state_processor.go b/core/parallel_state_processor.go
@@ -494,9 +494,10 @@ func (p *ParallelStateProcessor) runSlotLoop(slotIndex int, slotType int32) {
 
 	for {
 		loopBeginTime := time.Now()
+		startTime := time.Now()
 		select {
 		case <-stopChan:
-			totalRunSlotLoopDur = time.Since(loopBeginTime)
+			totalRunSlotLoopDur = time.Since(startTime)
 			log.Warn("RunSlotLoopTimer", "slotIndex", slotIndex, "slotType", slotType,
 				"totalTime", common.PrettyDuration(totalRunSlotLoopDur),
 				"totalWaitChanDur", common.PrettyDuration(totalWaitChanDur),
@@ -506,6 +507,8 @@ func (p *ParallelStateProcessor) runSlotLoop(slotIndex int, slotType int32) {
 			totalTryRunTxDur = 0
 			totalExecuteTxDur = 0
 			totalRunSlotLoopDur = 0
+			startTime = time.Now()
+			loopBeginTime = time.Now()
 			p.stopSlotChan <- struct{}{}
 			continue
 		case <-wakeupChan:

diff --git a/core/state/parallel_statedb.go b/core/state/parallel_statedb.go
@@ -1348,7 +1348,7 @@ func (slotDB *ParallelStateDB) IsParallelReadsValid(isStage2 bool) bool {
 			if hasKvConflict(slotDB, unit.addr, unit.key, unit.val, isStage2) {
 				return false
 			}
-		}
+		}:wq
 	} else {
 		msgHandledNum := 0
 		msgSendNum := 0