Method stateMachine

tests/upgrade/upgrade_test.go:1009–1107

()

}

func (l *validator) stateMachine() error {
	defer l.cancel()

	var err error

	var sub pubsub.Subscriber

	sub, err = l.pubsub.Subscribe()
	if err != nil {
		return err
	}

	blocksCount := 0
	replayDone := false
	stage := nodeTestStagePreUpgrade

	wdCtrl := func(ctx context.Context, ctrl watchdogCtrl) {
		resp := make(chan struct{}, 1)
		_ = l.pubsub.Publish(wdReq{
			event: ctrl,
			resp:  resp,
		})

		select {
		case <-ctx.Done():
		case <-resp:
		}
	}

loop:
	for {
		select {
		case <-l.ctx.Done():
			err = l.ctx.Err()
			break loop
		case ev := <-sub.Events():
			switch evt := ev.(type) {
			case event:
				switch evt.id {
				case nodeEventStart:
					l.t.Logf("[%s][%s]: node started", l.params.name, nodeTestStageMapStr[stage])
					if stage == nodeTestStageUpgrade {
						stage = nodeTestStagePostUpgrade1
						blocksCount = 0
						replayDone = false
					}
				case nodeEventReplayBlocksStart:
					l.t.Logf("[%s][%s]: node started replaying blocks", l.params.name, nodeTestStageMapStr[stage])
				case nodeEventReplayBlocksDone:
					l.t.Logf("[%s][%s]: node done replaying blocks", l.params.name, nodeTestStageMapStr[stage])
					wdCtrl(l.ctx, watchdogCtrlStart)
					replayDone = true
				case nodeEventBlockCommited:
					// ignore index events until replay done
					if !replayDone {
						break
					}