X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FRaftActorTestKit.java;h=d2a0dc8802b0e45f39923c5f2cd603f59a9faa81;hb=917283d6f5633ad981bebb6dfc6d6e0245876ab5;hp=ac9f8da34ee6365d5bdc66dcb67a512cf449dfae;hpb=2ea38dabb91b086e91b74573e0ec4a2834b152ab;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorTestKit.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorTestKit.java index ac9f8da34e..d2a0dc8802 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorTestKit.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorTestKit.java @@ -15,7 +15,6 @@ import akka.util.Timeout; import com.google.common.util.concurrent.Uninterruptibles; import java.util.Optional; import java.util.concurrent.TimeUnit; -import java.util.concurrent.TimeoutException; import org.junit.Assert; import org.opendaylight.controller.cluster.raft.client.messages.FindLeader; import org.opendaylight.controller.cluster.raft.client.messages.FindLeaderReply; @@ -42,7 +41,7 @@ public class RaftActorTestKit extends JavaTestKit { return raftActor; } - public boolean waitForLogMessage(final Class logEventClass, String message){ + public boolean waitForLogMessage(final Class logEventClass, String message) { // Wait for a specific log message to show up return new JavaTestKit.EventFilter(logEventClass @@ -58,21 +57,21 @@ public class RaftActorTestKit extends JavaTestKit { } - protected void waitUntilLeader(){ + protected void waitUntilLeader() { waitUntilLeader(raftActor); } + @SuppressWarnings("checkstyle:IllegalCatch") public static void waitUntilLeader(ActorRef actorRef) { FiniteDuration duration = Duration.create(100, TimeUnit.MILLISECONDS); - for(int i = 0; i < 20 * 5; i++) { + for (int i = 0; i < 20 * 5; i++) { Future future = Patterns.ask(actorRef, FindLeader.INSTANCE, new Timeout(duration)); try { final Optional maybeLeader = ((FindLeaderReply)Await.result(future, duration)).getLeaderActor(); if (maybeLeader.isPresent()) { return; } - } catch(TimeoutException e) { - } catch(Exception e) { + } catch (Exception e) { LOG.error("FindLeader failed", e); } @@ -82,4 +81,4 @@ public class RaftActorTestKit extends JavaTestKit { Assert.fail("Leader not found for actorRef " + actorRef.path()); } -} \ No newline at end of file +}