import akka.actor.ActorRef;
import akka.actor.Cancellable;
+import com.google.common.base.Preconditions;
import java.util.Random;
import java.util.concurrent.TimeUnit;
import org.opendaylight.controller.cluster.raft.ClientRequestTracker;
private final RaftState state;
- protected AbstractRaftActorBehavior(RaftActorContext context, RaftState state) {
- this.context = context;
- this.state = state;
+ AbstractRaftActorBehavior(final RaftActorContext context, final RaftState state) {
+ this.context = Preconditions.checkNotNull(context);
+ this.state = Preconditions.checkNotNull(state);
this.LOG = context.getLogger();
logName = String.format("%s (%s)", context.getId(), state);
}
+ public static RaftActorBehavior createBehavior(final RaftActorContext context, final RaftState state) {
+ switch (state) {
+ case Candidate:
+ return new Candidate(context);
+ case Follower:
+ return new Follower(context);
+ case IsolatedLeader:
+ return new IsolatedLeader(context);
+ case Leader:
+ return new Leader(context);
+ default:
+ throw new IllegalArgumentException("Unhandled state " + state);
+ }
+ }
+
@Override
- public RaftState state() {
+ public final RaftState state() {
return state;
}
return this;
}
- @Override public String getLeaderId() {
+ @Override
+ public String getLeaderId() {
return leaderId;
}
protected RaftActorBehavior internalSwitchBehavior(RaftState newState) {
if(context.getRaftPolicy().automaticElectionsEnabled()){
- return internalSwitchBehavior(newState.createBehavior(context));
+ return internalSwitchBehavior(createBehavior(context, newState));
}
return this;
}
* @param snapshotCapturedIndex
*/
protected void performSnapshotWithoutCapture(final long snapshotCapturedIndex) {
- long actualIndex = context.getSnapshotManager().trimLog(snapshotCapturedIndex, this);
+ long actualIndex = context.getSnapshotManager().trimLog(snapshotCapturedIndex);
if(actualIndex != -1){
setReplicatedToAllIndex(actualIndex);