From b4656dc85fe215bf79eadedd868be0082fe70ab0 Mon Sep 17 00:00:00 2001 From: Jon Bratseth Date: Thu, 29 Sep 2016 16:36:21 +0200 Subject: Yahoo sets up mac wireless networks such that the local hostname points to an ip which does not resolve. This works around that problem by finding a resolvable address (while still falling back to localhost if we only get ipv6 addresses, as that causes other problems in docker containers). --- .../java/com/yahoo/messagebus/ChokeTestCase.java | 37 +++++++++------------- 1 file changed, 15 insertions(+), 22 deletions(-) (limited to 'messagebus/src/test') diff --git a/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java b/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java index cde801d81f2..5e0df7068b0 100755 --- a/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java +++ b/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java @@ -11,28 +11,30 @@ import com.yahoo.messagebus.test.Receptor; import com.yahoo.messagebus.test.SimpleMessage; import com.yahoo.messagebus.test.SimpleProtocol; import junit.framework.TestCase; +import org.junit.After; +import org.junit.Before; +import org.junit.Ignore; +import org.junit.Test; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.List; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertTrue; +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertFalse; /** - * @author Simon Thoresen + * @author Simon Thoresen */ -public class ChokeTestCase extends TestCase { - - //////////////////////////////////////////////////////////////////////////////// - // - // Setup - // - //////////////////////////////////////////////////////////////////////////////// +public class ChokeTestCase { Slobrok slobrok; TestServer srcServer, dstServer; SourceSession srcSession; DestinationSession dstSession; - @Override + @Before public void setUp() throws ListenFailedException, UnknownHostException { slobrok = new Slobrok(); dstServer = new TestServer(new MessageBusParams().addProtocol(new SimpleProtocol()), @@ -45,7 +47,7 @@ public class ChokeTestCase extends TestCase { assertTrue(srcServer.waitSlobrok("dst/session", 1)); } - @Override + @After public void tearDown() { slobrok.stop(); dstSession.destroy(); @@ -54,12 +56,7 @@ public class ChokeTestCase extends TestCase { srcServer.destroy(); } - //////////////////////////////////////////////////////////////////////////////// - // - // Tests - // - //////////////////////////////////////////////////////////////////////////////// - + @Test public void testMaxCount() { int max = 10; dstServer.mb.setMaxPendingCount(max); @@ -107,6 +104,7 @@ public class ChokeTestCase extends TestCase { assertEquals(0, dstServer.mb.getPendingCount()); } + @Test public void testMaxSize() { int size = createMessage("msg").getApproxSize(); int max = size * 10; @@ -155,15 +153,10 @@ public class ChokeTestCase extends TestCase { assertEquals(0, dstServer.mb.getPendingSize()); } - //////////////////////////////////////////////////////////////////////////////// - // - // Utilities - // - //////////////////////////////////////////////////////////////////////////////// - private static Message createMessage(String msg) { Message ret = new SimpleMessage(msg); ret.getTrace().setLevel(9); return ret; } + } -- cgit v1.2.3