Implement pauseLeader timeout for leadership transfer 42/31942/6
authorTom Pantelis <tpanteli@brocade.com>
Tue, 29 Dec 2015 11:52:45 +0000 (06:52 -0500)
committerAnil Vishnoi <vishnoianil@gmail.com>
Thu, 7 Jan 2016 02:39:38 +0000 (02:39 +0000)
commit135129e0cca66040fd512fab740d59b2ab1f8382
tree2de404854ed5f1eff381b985b680a3078f85d7ba
parent204f45f8b3233dbea87e2c8065914f0d2a0ded07
Implement pauseLeader timeout for leadership transfer

Added an abstract TimedRunnable class that implements a Runnable operation
with a timer such that if the run method isn't invoked within a timeout
period, the operation is cancelled. The
RaftActorLeadershipTransferCohort passes a TimedRunnable instance to
pauseLeader to abort the transfer if pauseLeader doesn't complete within
an election timeout period.

Change-Id: I773605117dc4e310f3ee5025c0131b9f1447c746
Signed-off-by: Tom Pantelis <tpanteli@brocade.com>
opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActor.java
opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorLeadershipTransferCohort.java
opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/TimedRunnable.java [new file with mode: 0644]
opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MockRaftActor.java
opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorLeadershipTransferCohortTest.java