X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fmessages%2FRequestVote.java;h=6ef2a06285fedb85997f79b3763d367d46ceb663;hb=1729cc44de83f56b0bc52d44783c6753fb3ce31b;hp=981da17ce143389b75e8303b4bde9fd9fd582ad1;hpb=26cd54f2cbe0737db6e82aa96cd31671c6f6bf7e;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/RequestVote.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/RequestVote.java index 981da17ce1..6ef2a06285 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/RequestVote.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/RequestVote.java @@ -11,16 +11,16 @@ package org.opendaylight.controller.cluster.raft.messages; /** * Invoked by candidates to gather votes (§5.2). */ -public class RequestVote extends AbstractRaftRPC{ +public class RequestVote extends AbstractRaftRPC { // candidate requesting vote - private final String candidateId; + private String candidateId; // index of candidate’s last log entry (§5.4) - private final long lastLogIndex; + private long lastLogIndex; // term of candidate’s last log entry (§5.4) - private final long lastLogTerm; + private long lastLogTerm; public RequestVote(long term, String candidateId, long lastLogIndex, long lastLogTerm) { @@ -30,6 +30,10 @@ public class RequestVote extends AbstractRaftRPC{ this.lastLogTerm = lastLogTerm; } + // added for testing while serialize-messages=on + public RequestVote() { + } + public long getTerm() { return term; } @@ -45,4 +49,27 @@ public class RequestVote extends AbstractRaftRPC{ public long getLastLogTerm() { return lastLogTerm; } + + public void setCandidateId(String candidateId) { + this.candidateId = candidateId; + } + + public void setLastLogIndex(long lastLogIndex) { + this.lastLogIndex = lastLogIndex; + } + + public void setLastLogTerm(long lastLogTerm) { + this.lastLogTerm = lastLogTerm; + } + + @Override public String toString() { + final StringBuilder sb = + new StringBuilder("RequestVote{"); + sb.append("term='").append(getTerm()).append('\''); + sb.append("candidateId='").append(candidateId).append('\''); + sb.append(", lastLogIndex=").append(lastLogIndex); + sb.append(", lastLogTerm=").append(lastLogTerm); + sb.append('}'); + return sb.toString(); + } }