return context;
}
- private int getElectionTimeoutCount(RaftActorBehavior follower){
+ private static int getElectionTimeoutCount(RaftActorBehavior follower){
if(follower instanceof TestFollower){
return ((TestFollower) follower).getElectionTimeoutCount();
}
// Send an append entry
AppendEntries appendEntries = mock(AppendEntries.class);
doReturn(context.getTermInformation().getCurrentTerm()).when(appendEntries).getTerm();
+ doReturn(null).when(appendEntries).getEntries();
follower.handleMessage(leaderActor, appendEntries);
MockRaftActorContext context = createActorContext();
follower = createBehavior(context);
follower.handleMessage(leaderActor, new RaftRPC() {
+ private static final long serialVersionUID = 1L;
+
@Override
public long getTerm() {
return 100;
}
- private ReplicatedLogEntry newReplicatedLogEntry(long term, long index, String data) {
+ private static ReplicatedLogEntry newReplicatedLogEntry(long term, long index, String data) {
return new MockRaftActorContext.MockReplicatedLogEntry(term, index,
new MockRaftActorContext.MockPayload(data));
}