protected RaftState requestVote(ActorRef sender,
RequestVote requestVote) {
protected RaftState requestVote(ActorRef sender,
RequestVote requestVote) {
* @param index a log index that is known to be committed
*/
protected void applyLogToStateMachine(final long index) {
* @param index a log index that is known to be committed
*/
protected void applyLogToStateMachine(final long index) {
if (replicatedLogEntry != null) {
actor().tell(new ApplyState(clientActor, identifier,
replicatedLogEntry), actor());
if (replicatedLogEntry != null) {
actor().tell(new ApplyState(clientActor, identifier,
replicatedLogEntry), actor());
}
}
// Send a local message to the local RaftActor (it's derived class to be
// specific to apply the log to it's index)
}
}
// Send a local message to the local RaftActor (it's derived class to be
// specific to apply the log to it's index)
- context.getLogger().info("Setting last applied to {}", index);
- context.setLastApplied(index);
+ context.getLogger().debug("Setting last applied to {}", newLastApplied);
+ context.setLastApplied(newLastApplied);