@@ -52,7 +52,7 @@ const (
5252 nodeEventStart nodeEvent = iota
5353 nodeEventReplayBlocksStart
5454 nodeEventReplayBlocksDone
55- nodeEventBlockIndexed
55+ nodeEventBlockCommited
5656 nodeEventUpgradeDetected
5757 nodeEventAddedModule
5858 nodeEventRemovedModule
@@ -1027,7 +1027,7 @@ loop:
10271027 l .t .Logf ("[%s][%s]: node done replaying blocks" , l .params .name , nodeTestStageMapStr [stage ])
10281028 wdCtrl (l .ctx , watchdogCtrlStart )
10291029 replayDone = true
1030- case nodeEventBlockIndexed :
1030+ case nodeEventBlockCommited :
10311031 // ignore index events until replay done
10321032 if ! replayDone {
10331033 break
@@ -1263,6 +1263,7 @@ func (l *validator) scanner(stdout io.Reader, p publisher) error {
12631263 replayBlocksStart := "INF ABCI Replay Blocks appHeight"
12641264 replayBlocksDone := "INF Replay: Done module=consensus"
12651265 executedBlock := "INF indexed block "
1266+ executedBlock2 := "INF committed state block_app_hash="
12661267 upgradeNeeded := fmt .Sprintf (`ERR UPGRADE "%s" NEEDED at height:` , l .params .upgradeName )
12671268 addingNewModule := "INF adding a new module: "
12681269 migratingModule := "INF migrating module "
@@ -1291,8 +1292,8 @@ scan:
12911292 evt .id = nodeEventReplayBlocksStart
12921293 } else if strings .Contains (line , replayBlocksDone ) {
12931294 evt .id = nodeEventReplayBlocksDone
1294- } else if strings .Contains (line , executedBlock ) {
1295- evt .id = nodeEventBlockIndexed
1295+ } else if strings .Contains (line , executedBlock ) || strings . Contains ( line , executedBlock2 ) {
1296+ evt .id = nodeEventBlockCommited
12961297 } else if strings .Contains (line , addingNewModule ) {
12971298 evt .id = nodeEventAddedModule
12981299 res := rNewModule .FindAllStringSubmatch (line , - 1 )
0 commit comments