org.mule.transport.tcp.issues

Class LingerExperimentMule2067TestCase

java.lang.Object

org.mule.tck.junit4.AbstractMuleTestCase

org.mule.transport.tcp.issues.LingerExperimentMule2067TestCase

public class LingerExperimentMule2067TestCase
extends AbstractMuleTestCase

Are the "address already in use" errors coming from lingering sockets? We see "address already in use" errors when trying to re-use sockets very quickly, but the tests below don't give much information, except that: - data needs to be sent - explicitly setting or disabling the SO_LINGER value has little effect

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	LingerExperimentMule2067TestCase.Server

Field Summary

Fields inherited from class org.mule.tck.junit4.AbstractMuleTestCase

DEFAULT_TEST_TIMEOUT_SECS, globalTimeout, name, TEST_TIMEOUT_SYSTEM_PROPERTY, TESTING_MODE_PROPERTY_NAME

Constructor Summary

Constructors

Constructor and Description
LingerExperimentMule2067TestCase()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	openCloseClientServer(int numberOfConnections, int port, int clientLinger, int serverLinger)
protected void	openCloseServer(int numberOfSockets, int port)
protected void	repeatOpenCloseClientServer(int numberOfRepeats, int numberOfConnections, int port, long pause)
protected void	repeatOpenCloseClientServer(int numberOfRepeats, int numberOfConnections, int port, long pause, int clientLinger)
protected void	repeatOpenCloseClientServer(int numberOfRepeats, int numberOfConnections, int port, long pause, int clientLinger, int serverLinger)
void	testHardClose()
void	testInoffensive()
void	testThisShowsTheProblem()
void	testWithClientLinger()
void	testWithServerLinger()

Methods inherited from class org.mule.tck.junit4.AbstractMuleTestCase

clearExcludedFlag, clearRequestContext, clearTestCaseName, createTestTimeoutRule, dumpFilteredThreadsInTest, getTestHeader, getTestTimeoutSecs, getTimeoutSystemProperty, initializeMuleTest, isDisabledInThisEnvironment, isDisabledInThisEnvironment, isExcluded, isFailOnTimeout, isOffline, isTestIncludedInExclusionFile, takeTestCaseName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LingerExperimentMule2067TestCase

public LingerExperimentMule2067TestCase()

Method Detail

testInoffensive

public void testInoffensive()
                     throws IOException

Throws:

IOException

testThisShowsTheProblem

public void testThisShowsTheProblem()
                             throws IOException

Throws:

IOException

testWithClientLinger

public void testWithClientLinger()
                          throws IOException

Throws:

IOException

testWithServerLinger

public void testWithServerLinger()
                          throws IOException

Throws:

IOException

testHardClose

public void testHardClose()
                   throws IOException

Throws:

IOException

openCloseServer

protected void openCloseServer(int numberOfSockets,
                   int port)
                        throws IOException

Throws:

IOException

repeatOpenCloseClientServer

protected void repeatOpenCloseClientServer(int numberOfRepeats,
                               int numberOfConnections,
                               int port,
                               long pause)
                                    throws IOException

Throws:

IOException

repeatOpenCloseClientServer

protected void repeatOpenCloseClientServer(int numberOfRepeats,
                               int numberOfConnections,
                               int port,
                               long pause,
                               int clientLinger)
                                    throws IOException

Throws:

IOException

repeatOpenCloseClientServer

protected void repeatOpenCloseClientServer(int numberOfRepeats,
                               int numberOfConnections,
                               int port,
                               long pause,
                               int clientLinger,
                               int serverLinger)
                                    throws IOException

Throws:

IOException

openCloseClientServer

protected void openCloseClientServer(int numberOfConnections,
                         int port,
                         int clientLinger,
                         int serverLinger)
                              throws IOException

Throws:

IOException