From 1c654a076f322cceed3fb5403d810b23a818f1d7 Mon Sep 17 00:00:00 2001 From: kkolinko Date: Tue, 26 Jul 2011 02:39:35 +0000 Subject: [PATCH] Converted tribes tests to JUnit 4. git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@1150974 13f79535-47bb-0310-9956-ffa450edef68 --- .../group/TestGroupChannelMemberArrival.java | 20 ++++++----- .../tribes/group/TestGroupChannelOptionFlag.java | 31 +++++++++------- .../group/TestGroupChannelSenderConnections.java | 20 ++++++----- .../tribes/group/TestGroupChannelStartStop.java | 29 +++++++++------ .../interceptors/TestDomainFilterInterceptor.java | 20 ++++++----- .../group/interceptors/TestGzipInterceptor.java | 13 +++++-- .../interceptors/TestNonBlockingCoordinator.java | 41 ++++++++++----------- .../group/interceptors/TestOrderInterceptor.java | 41 ++++++++++----------- .../group/interceptors/TestTcpFailureDetector.java | 32 ++++++++++------- .../apache/catalina/tribes/io/TestXByteBuffer.java | 10 ++++-- .../membership/TestMemberImplSerialization.java | 33 ++++++++++------- .../catalina/tribes/test/TribesTestSuite.java | 42 ++++++++-------------- 12 files changed, 184 insertions(+), 148 deletions(-) diff --git a/test/org/apache/catalina/tribes/group/TestGroupChannelMemberArrival.java b/test/org/apache/catalina/tribes/group/TestGroupChannelMemberArrival.java index aa6f9a642..9ee22aec0 100644 --- a/test/org/apache/catalina/tribes/group/TestGroupChannelMemberArrival.java +++ b/test/org/apache/catalina/tribes/group/TestGroupChannelMemberArrival.java @@ -18,22 +18,24 @@ package org.apache.catalina.tribes.group; import java.util.ArrayList; -import junit.framework.TestCase; +import static org.junit.Assert.assertEquals; + +import org.junit.After; +import org.junit.Before; +import org.junit.Test; import org.apache.catalina.tribes.Channel; import org.apache.catalina.tribes.ManagedChannel; import org.apache.catalina.tribes.Member; import org.apache.catalina.tribes.MembershipListener; -public class TestGroupChannelMemberArrival - extends TestCase { +public class TestGroupChannelMemberArrival { private static int count = 10; private ManagedChannel[] channels = new ManagedChannel[count]; private TestMbrListener[] listeners = new TestMbrListener[count]; - @Override - protected void setUp() throws Exception { - super.setUp(); + @Before + public void setUp() throws Exception { for (int i = 0; i < channels.length; i++) { channels[i] = new GroupChannel(); channels[i].getMembershipService().setPayload( ("Channel-" + (i + 1)).getBytes("ASCII")); @@ -49,6 +51,7 @@ public class TestGroupChannelMemberArrival } } + @Test public void testMemberArrival() throws Exception { //purpose of this test is to make sure that we have received all the members //that we can expect before the start method returns @@ -74,8 +77,8 @@ public class TestGroupChannelMemberArrival for (int i=listeners.length-1; i>=0; i-- ) assertEquals("Checking member arrival length",channels.length-1,listeners[i].members.size()); } - @Override - protected void tearDown() throws Exception { + @After + public void tearDown() throws Exception { for (int i = 0; i < channels.length; i++) { try { @@ -84,7 +87,6 @@ public class TestGroupChannelMemberArrival // Ignore } } - super.tearDown(); } public static class TestMbrListener diff --git a/test/org/apache/catalina/tribes/group/TestGroupChannelOptionFlag.java b/test/org/apache/catalina/tribes/group/TestGroupChannelOptionFlag.java index dc855e833..8f554ce48 100644 --- a/test/org/apache/catalina/tribes/group/TestGroupChannelOptionFlag.java +++ b/test/org/apache/catalina/tribes/group/TestGroupChannelOptionFlag.java @@ -16,7 +16,12 @@ */ package org.apache.catalina.tribes.group; -import junit.framework.TestCase; +import static org.junit.Assert.assertFalse; +import static org.junit.Assert.assertTrue; + +import org.junit.After; +import org.junit.Before; +import org.junit.Test; import org.apache.catalina.tribes.Channel; import org.apache.catalina.tribes.ChannelException; @@ -32,22 +37,21 @@ import org.apache.catalina.tribes.ChannelInterceptor; * @author not attributable * @version 1.0 */ -public class TestGroupChannelOptionFlag extends TestCase { - GroupChannel channel = null; - @Override - protected void setUp() throws Exception { - super.setUp(); +public class TestGroupChannelOptionFlag { + private GroupChannel channel = null; + + @Before + public void setUp() throws Exception { channel = new GroupChannel(); } - @Override - protected void tearDown() throws Exception { - super.tearDown(); + @After + public void tearDown() throws Exception { if ( channel != null ) try {channel.stop(Channel.DEFAULT);}catch ( Exception ignore) { /* Ignore */ } channel = null; } - - + + @Test public void testOptionConflict() throws Exception { boolean error = false; channel.setOptionCheck(true); @@ -62,9 +66,10 @@ public class TestGroupChannelOptionFlag extends TestCase { }catch ( ChannelException x ) { if ( x.getMessage().indexOf("option flag conflict") >= 0 ) error = true; } - assertEquals(true,error); + assertTrue(error); } + @Test public void testOptionNoConflict() throws Exception { boolean error = false; channel.setOptionCheck(true); @@ -82,7 +87,7 @@ public class TestGroupChannelOptionFlag extends TestCase { }catch ( ChannelException x ) { if ( x.getMessage().indexOf("option flag conflict") >= 0 ) error = true; } - assertEquals(false,error); + assertFalse(error); } public static class TestInterceptor extends ChannelInterceptorBase { diff --git a/test/org/apache/catalina/tribes/group/TestGroupChannelSenderConnections.java b/test/org/apache/catalina/tribes/group/TestGroupChannelSenderConnections.java index d32411de9..ea9d5ef95 100644 --- a/test/org/apache/catalina/tribes/group/TestGroupChannelSenderConnections.java +++ b/test/org/apache/catalina/tribes/group/TestGroupChannelSenderConnections.java @@ -21,7 +21,9 @@ import java.util.ArrayList; import java.util.HashMap; import java.util.Random; -import junit.framework.TestCase; +import org.junit.After; +import org.junit.Before; +import org.junit.Test; import org.apache.catalina.tribes.Channel; import org.apache.catalina.tribes.ChannelListener; @@ -29,14 +31,13 @@ import org.apache.catalina.tribes.ManagedChannel; import org.apache.catalina.tribes.Member; import org.apache.catalina.tribes.transport.ReplicationTransmitter; -public class TestGroupChannelSenderConnections extends TestCase { +public class TestGroupChannelSenderConnections { private static int count = 2; private ManagedChannel[] channels = new ManagedChannel[count]; private TestMsgListener[] listeners = new TestMsgListener[count]; - @Override - protected void setUp() throws Exception { - super.setUp(); + @Before + public void setUp() throws Exception { for (int i = 0; i < channels.length; i++) { channels[i] = new GroupChannel(); channels[i].getMembershipService().setPayload( ("Channel-" + (i + 1)).getBytes("ASCII")); @@ -65,10 +66,12 @@ public class TestGroupChannelSenderConnections extends TestCase { } + @Test public void testConnectionLinger() throws Exception { sendMessages(0,15000); } - + + @Test public void testKeepAliveCount() throws Exception { System.out.println("Setting keep alive count to 0"); for (int i = 0; i < channels.length; i++) { @@ -78,6 +81,7 @@ public class TestGroupChannelSenderConnections extends TestCase { sendMessages(1000,15000); } + @Test public void testKeepAliveTime() throws Exception { System.out.println("Setting keep alive count to 1 second"); for (int i = 0; i < channels.length; i++) { @@ -87,8 +91,8 @@ public class TestGroupChannelSenderConnections extends TestCase { sendMessages(2000,15000); } - @Override - protected void tearDown() throws Exception { + @After + public void tearDown() throws Exception { for (int i = 0; i < channels.length; i++) { channels[i].stop(Channel.DEFAULT); } diff --git a/test/org/apache/catalina/tribes/group/TestGroupChannelStartStop.java b/test/org/apache/catalina/tribes/group/TestGroupChannelStartStop.java index 070126dbc..46bde88d4 100644 --- a/test/org/apache/catalina/tribes/group/TestGroupChannelStartStop.java +++ b/test/org/apache/catalina/tribes/group/TestGroupChannelStartStop.java @@ -16,7 +16,11 @@ */ package org.apache.catalina.tribes.group; -import junit.framework.TestCase; +import static org.junit.Assert.assertEquals; + +import org.junit.After; +import org.junit.Before; +import org.junit.Test; import org.apache.catalina.tribes.Channel; import org.apache.catalina.tribes.transport.ReceiverBase; @@ -25,21 +29,21 @@ import org.apache.catalina.tribes.transport.ReceiverBase; * @author Filip Hanik * @version 1.0 */ -public class TestGroupChannelStartStop extends TestCase { - GroupChannel channel = null; - int udpPort = 45543; - @Override - protected void setUp() throws Exception { - super.setUp(); +public class TestGroupChannelStartStop { + private GroupChannel channel = null; + private int udpPort = 45543; + + @Before + public void setUp() throws Exception { channel = new GroupChannel(); } - @Override - protected void tearDown() throws Exception { - super.tearDown(); + @After + public void tearDown() throws Exception { try {channel.stop(Channel.DEFAULT);}catch (Exception ignore){ /* Ignore */ } } + @Test public void testDoubleFullStart() throws Exception { int count = 0; try { @@ -54,12 +58,13 @@ public class TestGroupChannelStartStop extends TestCase { channel.stop(Channel.DEFAULT); } + @Test public void testScrap() throws Exception { System.out.println(channel.getChannelReceiver().getClass()); ((ReceiverBase)channel.getChannelReceiver()).setMaxThreads(1); } - + @Test public void testDoublePartialStart() throws Exception { //try to double start the RX int count = 0; @@ -113,6 +118,7 @@ public class TestGroupChannelStartStop extends TestCase { channel.stop(Channel.DEFAULT); } + @Test public void testFalseOption() throws Exception { int flag = 0xFFF0;//should get ignored by the underlying components int count = 0; @@ -128,6 +134,7 @@ public class TestGroupChannelStartStop extends TestCase { channel.stop(Channel.DEFAULT); } + @Test public void testUdpReceiverStart() throws Exception { ReceiverBase rb = (ReceiverBase)channel.getChannelReceiver(); rb.setUdpPort(udpPort); diff --git a/test/org/apache/catalina/tribes/group/interceptors/TestDomainFilterInterceptor.java b/test/org/apache/catalina/tribes/group/interceptors/TestDomainFilterInterceptor.java index fbf2c472d..f6f422d9f 100644 --- a/test/org/apache/catalina/tribes/group/interceptors/TestDomainFilterInterceptor.java +++ b/test/org/apache/catalina/tribes/group/interceptors/TestDomainFilterInterceptor.java @@ -18,7 +18,11 @@ package org.apache.catalina.tribes.group.interceptors; import java.util.ArrayList; -import junit.framework.TestCase; +import static org.junit.Assert.assertEquals; + +import org.junit.After; +import org.junit.Before; +import org.junit.Test; import org.apache.catalina.tribes.Channel; import org.apache.catalina.tribes.ManagedChannel; @@ -27,15 +31,13 @@ import org.apache.catalina.tribes.MembershipListener; import org.apache.catalina.tribes.group.GroupChannel; import org.apache.catalina.tribes.util.UUIDGenerator; -public class TestDomainFilterInterceptor - extends TestCase { +public class TestDomainFilterInterceptor { private static int count = 10; private ManagedChannel[] channels = new ManagedChannel[count]; private TestMbrListener[] listeners = new TestMbrListener[count]; - @Override - protected void setUp() throws Exception { - super.setUp(); + @Before + public void setUp() throws Exception { for (int i = 0; i < channels.length; i++) { channels[i] = new GroupChannel(); channels[i].getMembershipService().setPayload( ("Channel-" + (i + 1)).getBytes("ASCII")); @@ -53,6 +55,7 @@ public class TestDomainFilterInterceptor } } + @Test public void testMemberArrival() throws Exception { //purpose of this test is to make sure that we have received all the members //that we can expect before the start method returns @@ -77,8 +80,8 @@ public class TestDomainFilterInterceptor for (int i=listeners.length-1; i>=0; i-- ) assertEquals("Checking member arrival length",0,listeners[i].members.size()); } - @Override - protected void tearDown() throws Exception { + @After + public void tearDown() throws Exception { for (int i = 0; i < channels.length; i++) { try { @@ -87,7 +90,6 @@ public class TestDomainFilterInterceptor // Ignore } } - super.tearDown(); } public static class TestMbrListener diff --git a/test/org/apache/catalina/tribes/group/interceptors/TestGzipInterceptor.java b/test/org/apache/catalina/tribes/group/interceptors/TestGzipInterceptor.java index e8e561614..11060e7a4 100644 --- a/test/org/apache/catalina/tribes/group/interceptors/TestGzipInterceptor.java +++ b/test/org/apache/catalina/tribes/group/interceptors/TestGzipInterceptor.java @@ -18,34 +18,43 @@ package org.apache.catalina.tribes.group.interceptors; import java.util.Arrays; -import junit.framework.TestCase; +import static org.junit.Assert.assertTrue; -public class TestGzipInterceptor extends TestCase { +import org.junit.Test; +public class TestGzipInterceptor { + + @Test public void testSmallerThanBufferSize() throws Exception { doCompressDecompress(GzipInterceptor.DEFAULT_BUFFER_SIZE / 2); } + @Test public void testJustSmallerThanBufferSize() throws Exception { doCompressDecompress(GzipInterceptor.DEFAULT_BUFFER_SIZE -1); } + @Test public void testExactBufferSize() throws Exception { doCompressDecompress(GzipInterceptor.DEFAULT_BUFFER_SIZE); } + @Test public void testJustLargerThanBufferSize() throws Exception { doCompressDecompress(GzipInterceptor.DEFAULT_BUFFER_SIZE + 1); } + @Test public void testFactor2BufferSize() throws Exception { doCompressDecompress(GzipInterceptor.DEFAULT_BUFFER_SIZE * 2); } + @Test public void testFactor4BufferSize() throws Exception { doCompressDecompress(GzipInterceptor.DEFAULT_BUFFER_SIZE * 4); } + @Test public void testMuchLargerThanBufferSize() throws Exception { doCompressDecompress(GzipInterceptor.DEFAULT_BUFFER_SIZE * 10 + 1000); } diff --git a/test/org/apache/catalina/tribes/group/interceptors/TestNonBlockingCoordinator.java b/test/org/apache/catalina/tribes/group/interceptors/TestNonBlockingCoordinator.java index 828b95cd1..3ce3a4bb4 100644 --- a/test/org/apache/catalina/tribes/group/interceptors/TestNonBlockingCoordinator.java +++ b/test/org/apache/catalina/tribes/group/interceptors/TestNonBlockingCoordinator.java @@ -16,24 +16,26 @@ */ package org.apache.catalina.tribes.group.interceptors; -import junit.framework.TestCase; -import junit.framework.TestResult; -import junit.framework.TestSuite; +import static org.junit.Assert.assertEquals; + +import org.junit.After; +import org.junit.Before; +import org.junit.Test; import org.apache.catalina.tribes.Channel; import org.apache.catalina.tribes.Member; import org.apache.catalina.tribes.group.GroupChannel; -public class TestNonBlockingCoordinator extends TestCase { +public class TestNonBlockingCoordinator { + + private GroupChannel[] channels = null; + private NonBlockingCoordinator[] coordinators = null; + private int channelCount = 10; + private Thread[] threads = null; - GroupChannel[] channels = null; - NonBlockingCoordinator[] coordinators = null; - int channelCount = 10; - Thread[] threads = null; - @Override - protected void setUp() throws Exception { + @Before + public void setUp() throws Exception { System.out.println("Setup"); - super.setUp(); channels = new GroupChannel[channelCount]; coordinators = new NonBlockingCoordinator[channelCount]; threads = new Thread[channelCount]; @@ -59,7 +61,8 @@ public class TestNonBlockingCoordinator extends TestCase { for ( int i=0; iTitle:

@@ -30,13 +34,13 @@ import junit.framework.TestCase; * @author not attributable * @version 1.0 */ -public class TestMemberImplSerialization extends TestCase { - MemberImpl m1, m2, p1,p2; - byte[] payload = null; - int udpPort = 3445; - @Override - protected void setUp() throws Exception { - super.setUp(); +public class TestMemberImplSerialization { + private MemberImpl m1, m2, p1,p2; + private byte[] payload = null; + private int udpPort = 3445; + + @Before + public void setUp() throws Exception { payload = new byte[333]; Arrays.fill(payload,(byte)1); m1 = new MemberImpl("localhost",3333,1,payload); @@ -52,7 +56,8 @@ public class TestMemberImplSerialization extends TestCase { m1.setUdpPort(udpPort); m2.setUdpPort(m1.getUdpPort()); } - + + @Test public void testCompare() throws Exception { assertTrue(m1.equals(m2)); assertTrue(m2.equals(m1)); @@ -62,7 +67,8 @@ public class TestMemberImplSerialization extends TestCase { assertFalse(m2.equals(p2)); assertFalse(p1.equals(p2)); } - + + @Test public void testUdpPort() throws Exception { byte[] md1 = m1.getData(); byte[] md2 = m2.getData(); @@ -70,10 +76,11 @@ public class TestMemberImplSerialization extends TestCase { MemberImpl a1 = MemberImpl.getMember(md1); MemberImpl a2 = MemberImpl.getMember(md2); - assertEquals(true, a1.getUdpPort()==a2.getUdpPort()); - assertEquals(true,a1.getUdpPort()==udpPort); + assertTrue(a1.getUdpPort()==a2.getUdpPort()); + assertTrue(a1.getUdpPort()==udpPort); } - + + @Test public void testSerializationOne() throws Exception { MemberImpl m = m1; byte[] md1 = m.getData(false,true); diff --git a/test/org/apache/catalina/tribes/test/TribesTestSuite.java b/test/org/apache/catalina/tribes/test/TribesTestSuite.java index f9bce6591..a626300be 100644 --- a/test/org/apache/catalina/tribes/test/TribesTestSuite.java +++ b/test/org/apache/catalina/tribes/test/TribesTestSuite.java @@ -16,9 +16,9 @@ */ package org.apache.catalina.tribes.test; -import junit.framework.Test; -import junit.framework.TestCase; -import junit.framework.TestSuite; +import org.junit.runner.RunWith; +import org.junit.runners.Suite; +import org.junit.runners.Suite.SuiteClasses; import org.apache.catalina.tribes.group.TestGroupChannelMemberArrival; import org.apache.catalina.tribes.group.TestGroupChannelOptionFlag; @@ -35,33 +35,19 @@ import org.apache.catalina.tribes.test.channel.TestMulticastPackages; import org.apache.catalina.tribes.test.channel.TestRemoteProcessException; import org.apache.catalina.tribes.test.channel.TestUdpPackages; -public class TribesTestSuite - extends TestCase { - - public TribesTestSuite(String s) { - super(s); - } - - public static Test suite() { - TestSuite suite = new TestSuite(); +@RunWith(Suite.class) +@SuiteClasses({ // o.a.catalina.tribes.test.channel - suite.addTestSuite(TestGroupChannelStartStop.class); - suite.addTestSuite(TestGroupChannelOptionFlag.class); - suite.addTestSuite(TestDataIntegrity.class); - suite.addTestSuite(TestMulticastPackages.class); - suite.addTestSuite(TestRemoteProcessException.class); - suite.addTestSuite(TestUdpPackages.class); + TestGroupChannelStartStop.class, TestGroupChannelOptionFlag.class, + TestDataIntegrity.class, TestMulticastPackages.class, + TestRemoteProcessException.class, TestUdpPackages.class, // o.a.catalina.tribes.test.interceptors - suite.addTestSuite(TestNonBlockingCoordinator.class); - suite.addTestSuite(TestOrderInterceptor.class); + TestNonBlockingCoordinator.class, TestOrderInterceptor.class, // o.a.catalina.tribes.test.io - suite.addTestSuite(TestGroupChannelSenderConnections.class); - suite.addTestSuite(TestXByteBuffer.class); + TestGroupChannelSenderConnections.class, TestXByteBuffer.class, // o.a.catalina.tribes.test.membership - suite.addTestSuite(TestMemberImplSerialization.class); - suite.addTestSuite(TestDomainFilterInterceptor.class); - suite.addTestSuite(TestGroupChannelMemberArrival.class); - suite.addTestSuite(TestTcpFailureDetector.class); - return suite; - } + TestMemberImplSerialization.class, TestDomainFilterInterceptor.class, + TestGroupChannelMemberArrival.class, TestTcpFailureDetector.class }) +public class TribesTestSuite { + } -- 2.11.0