package lockstep

import (
	"time"
)

const syncFailsafeInterval = 1 * time.Minute

func (l *Lockstep) FailsafeSync() {
	for id, queue := range l.queues {
		if len(queue) == 0 {
			continue
		}
		if l.inTurn(id) {
			l.doTurn(id)
		} else {
			l.sendPullRequest(id)
		}
	}
}

func (l *Lockstep) RunFailsafe() {
        for {
			l.FailsafeCh <- struct{}{}
            time.Sleep(syncFailsafeInterval)
        }
}