// Check the COMMIT messages, for given `periodCheckPoint` consecutive
// sequence numbers, are enough including the messages for the current node.
Check the COMMIT messages, for given `periodCheckPoint` consecutive
sequence numbers, are enough including the messages for the current node.
// Check the COMMIT messages for given ` periodCheckPoint ` consecutive // sequence numbers are enough including the messages for the current node .
func (node *Node) CheckPointMissCheck(sequenceID int64) bool {
	for i := (sequenceID + 1); i <= (sequenceID + periodCheckPoint); i++ {
		state, _ := node.getState(i)
		if state == nil {
			return false
		}
		if len(state.GetCommitMsgs()) < (2*state.GetF() + 1) &&
		   state.GetCommitMsgs()[node.MyInfo.NodeID] == nil {
			return false
		}
	}
	return true
}
func ( node * Node ) CheckPointMissCheck ( sequenceID int64 ) bool { for i := ( sequenceID + 1 ) ; i <= ( sequenceID + periodCheckPoint ) ; i ++ { state , _ := node . getState ( i ) if state == nil { return false } if len ( state . GetCommitMsgs ( ) ) < ( 2 * state . GetF ( ) + 1 ) && state . GetCommitMsgs ( ) [ node . MyInfo . NodeID ] == nil { return false } } return true }
Check the COMMIT messages, for given `periodCheckPoint` consecutive
sequence numbers, are enough including the messages for the current node.
Check the COMMIT messages for given ` periodCheckPoint ` consecutive sequence numbers are enough including the messages for the current node .