X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FShardTestKit.java;h=2c0f5631c05e11b84df45b05548cbff165a1dfc7;hb=a6af137c30470b86d4bc624d4c48cb686495a182;hp=d08258a2a026ec890ddb736f1456c6682e2a3c5c;hpb=846b5ae74588943cc5bd176e219809ced07104d6;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardTestKit.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardTestKit.java index d08258a2a0..2c0f5631c0 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardTestKit.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardTestKit.java @@ -7,64 +7,96 @@ */ package org.opendaylight.controller.cluster.datastore; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.fail; + +import akka.actor.ActorRef; +import akka.actor.ActorSystem; +import akka.pattern.Patterns; +import akka.testkit.javadsl.EventFilter; +import akka.testkit.javadsl.TestKit; +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; -import com.google.common.util.concurrent.Uninterruptibles; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import scala.concurrent.Await; import scala.concurrent.Future; import scala.concurrent.duration.Duration; import scala.concurrent.duration.FiniteDuration; -import akka.actor.ActorRef; -import akka.actor.ActorSystem; -import akka.pattern.Patterns; -import akka.testkit.JavaTestKit; -import akka.util.Timeout; -class ShardTestKit extends JavaTestKit { +public class ShardTestKit extends TestKit { + private static final Logger LOG = LoggerFactory.getLogger(ShardTestKit.class); - ShardTestKit(ActorSystem actorSystem) { + public ShardTestKit(final ActorSystem actorSystem) { super(actorSystem); } - protected void waitForLogMessage(final Class logLevel, ActorRef subject, String logMessage){ + public void waitForLogMessage(final Class logLevel, final ActorRef subject, final String logMessage) { // Wait for a specific log message to show up - final boolean result = - new JavaTestKit.EventFilter(logLevel - ) { - @Override - protected Boolean run() { - return true; + final Boolean result = new EventFilter(logLevel, getSystem()).from(subject.path().toString()) + .message(logMessage).occurrences(1).intercept(() -> Boolean.TRUE); + assertEquals(Boolean.TRUE, result); + } + + @SuppressWarnings("checkstyle:IllegalCatch") + public static String waitUntilLeader(final ActorRef shard) { + FiniteDuration duration = Duration.create(100, TimeUnit.MILLISECONDS); + for (int i = 0; i < 20 * 5; i++) { + Future future = Patterns.ask(shard, FindLeader.INSTANCE, new Timeout(duration)); + try { + final Optional maybeLeader = ((FindLeaderReply) Await.result(future, duration)) + .getLeaderActor(); + if (maybeLeader.isPresent()) { + return maybeLeader.get(); } - }.from(subject.path().toString()) - .message(logMessage) - .occurrences(1).exec(); + } catch (TimeoutException e) { + LOG.trace("FindLeader timed out", e); + } catch (Exception e) { + LOG.error("FindLeader failed", e); + } - Assert.assertEquals(true, result); + Uninterruptibles.sleepUninterruptibly(50, TimeUnit.MILLISECONDS); + } + fail("Leader not found for shard " + shard.path()); + return null; } - protected void waitUntilLeader(ActorRef shard) { + @SuppressWarnings("checkstyle:IllegalCatch") + public void waitUntilNoLeader(final ActorRef shard) { FiniteDuration duration = Duration.create(100, TimeUnit.MILLISECONDS); - for(int i = 0; i < 20 * 5; i++) { - Future future = Patterns.ask(shard, new FindLeader(), new Timeout(duration)); + Object lastResponse = null; + for (int i = 0; i < 20 * 5; i++) { + Future future = Patterns.ask(shard, FindLeader.INSTANCE, new Timeout(duration)); try { - FindLeaderReply resp = (FindLeaderReply)Await.result(future, duration); - if(resp.getLeaderActor() != null) { + final Optional maybeLeader = ((FindLeaderReply) Await.result(future, duration)) + .getLeaderActor(); + if (!maybeLeader.isPresent()) { return; } - } catch(TimeoutException e) { - } catch(Exception e) { - System.err.println("FindLeader threw ex"); - e.printStackTrace(); - } + lastResponse = maybeLeader.get(); + } catch (TimeoutException e) { + lastResponse = e; + } catch (Exception e) { + LOG.error("FindLeader failed", e); + lastResponse = e; + } Uninterruptibles.sleepUninterruptibly(50, TimeUnit.MILLISECONDS); } - Assert.fail("Leader not found for shard " + shard.path()); + if (lastResponse instanceof Throwable) { + throw (AssertionError)new AssertionError( + String.format("Unexpected error occurred from FindLeader for shard %s", shard.path())) + .initCause((Throwable)lastResponse); + } + + fail(String.format("Unexpected leader %s found for shard %s", lastResponse, shard.path())); } -} \ No newline at end of file +}