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

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

Constructor Summary

LingerExperimentMule2067TestCase()

Method Summary

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, createTestTimeoutRule, getTestHeader, getTestTimeoutSecs, getTimeoutSystemProperty, initializeMuleTest, isDisabledInThisEnvironment, isDisabledInThisEnvironment, isExcluded, isFailOnTimeout, isOffline, isTestIncludedInExclusionFile

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