FIXUP: attempt to fix travis-ci: use SO_LINGER

Author: Totktonada

src/test/java/org/tarantool/AbstractTarantoolConnectorIT.java

@@ -135,6 +135,10 @@ protected TarantoolClient makeClient() {
         return new TarantoolClientImpl(socketChannelProvider, makeClientConfig());
     }
 
+    protected TarantoolClient makeClient(SocketChannelProvider provider) {
+        return new TarantoolClientImpl(provider, makeClientConfig());
+    }
+
     protected static TarantoolClientConfig makeClientConfig() {
         return fillClientConfig(new TarantoolClientConfig());
     }

src/test/java/org/tarantool/ClientReconnectIT.java

@@ -217,19 +217,27 @@ public void run() {
 
     /**
      * Test concurrent operations, reconnects and close.
+     *
      * Expected situation is nothing gets stuck.
+     *
+     * The test sets SO_LINGER to 0 for outgoing connections to avoid producing
+     * many TIME_WAIT sockets, because an available port range can be
+     * exhausted.
      */
     @Test
     public void testLongParallelCloseReconnects() {
         int numThreads = 4;
         int numClients = 4;
         int timeBudget = 30*1000;
 
+        SocketChannelProvider provider = new TestSocketChannelProvider(host,
+            port, RESTART_TIMEOUT).setSoLinger(0);
+
         final AtomicReferenceArray<TarantoolClient> clients =
             new AtomicReferenceArray<TarantoolClient>(numClients);
 
         for (int idx = 0; idx < clients.length(); idx++) {
-            clients.set(idx, makeClient());
+            clients.set(idx, makeClient(provider));
         }
 
         final Random rnd = new Random();
@@ -258,7 +266,7 @@ public void run() {
 
                             cli.close();
 
-                            TarantoolClient next = makeClient();
+                            TarantoolClient next = makeClient(provider);
                             if (!clients.compareAndSet(idx, cli, next)) {
                                 next.close();
                             }
@@ -306,14 +314,17 @@ public void run() {
     }
 
     /**
-     * Verify that we don't exhaust a file descriptor limit (and so likely
-     * don't leak file descriptors) when trying to connect to a non existing
-     * node.
+     * Verify that we don't exceed a file descriptor limit (and so likely don't
+     * leak file descriptors) when trying to connect to a non existing node.
+     *
+     * The test sets SO_LINGER to 0 for outgoing connections to avoid producing
+     * many TIME_WAIT sockets, because an available port range can be
+     * exhausted.
      */
     @Test
     public void testReconnectNonExist() throws Exception {
         SocketChannelProvider provider = new TestSocketChannelProvider(host,
-            NON_EXIST_PORT, RESTART_TIMEOUT);
+            NON_EXIST_PORT, RESTART_TIMEOUT).setSoLinger(0);
         TarantoolClientConfig config = makeClientConfig();
         config.initTimeoutMillis = 100;
         TarantoolClientImpl client = null;
@@ -330,19 +341,25 @@ public void testReconnectNonExist() throws Exception {
     }
 
     /**
-     * Verify that we don't exhaust a file descriptor limit (and so likely
-     * don't leak file descriptors) when trying to connect to an existing node
-     * with wrong authentification credentials.
+     * Verify that we don't exceed a file descriptor limit (and so likely don't
+     * leak file descriptors) when trying to connect to an existing node with
+     * wrong authentification credentials.
+     *
+     * The test sets SO_LINGER to 0 for outgoing connections to avoid producing
+     * many TIME_WAIT sockets, because an available port range can be
+     * exhausted.
      */
     @Test
     public void testReconnectWrongAuth() throws Exception {
+        SocketChannelProvider provider = new TestSocketChannelProvider(host,
+            port, RESTART_TIMEOUT).setSoLinger(0);
         TarantoolClientConfig config = makeClientConfig();
         config.initTimeoutMillis = 100;
         config.password = config.password + 'x';
         TarantoolClientImpl client = null;
         for (int i = 0; i < 100; ++i) {
             try {
-                client = new TarantoolClientImpl(socketChannelProvider, config);
+                client = new TarantoolClientImpl(provider, config);
             } catch (Exception ignored) {
             }
             assertNull(client);

src/test/java/org/tarantool/TestSocketChannelProvider.java

@@ -2,27 +2,39 @@
 
 import java.net.InetSocketAddress;
 import java.nio.channels.SocketChannel;
+import static java.net.StandardSocketOptions.SO_LINGER;
 
 /**
  * Socket channel provider to be used throughout the tests.
  */
 public class TestSocketChannelProvider implements SocketChannelProvider {
     String host;
     int port;
-    int restart_timeout;
+    int restartTimeout;
+    int soLinger;
 
-    public TestSocketChannelProvider(String host, int port, int restart_timeout) {
+    public TestSocketChannelProvider(String host, int port, int restartTimeout) {
         this.host = host;
         this.port = port;
-        this.restart_timeout = restart_timeout;
+        this.restartTimeout = restartTimeout;
+        this.soLinger = -1;
+    }
+
+    public TestSocketChannelProvider setSoLinger(int soLinger) {
+        this.soLinger = soLinger;
+        return this;
     }
 
     @Override
     public SocketChannel get(int retryNumber, Throwable lastError) {
-        long budget = System.currentTimeMillis() + restart_timeout;
+        long budget = System.currentTimeMillis() + restartTimeout;
         while (!Thread.currentThread().isInterrupted()) {
             try {
-                return SocketChannel.open(new InetSocketAddress(host, port));
+                SocketChannel channel = SocketChannel.open();
+                if (soLinger >= 0)
+                    channel.setOption(SO_LINGER, soLinger);
+                channel.connect(new InetSocketAddress(host, port));
+                return channel;
             } catch (Exception e) {
                 if (budget < System.currentTimeMillis())
                     throw new RuntimeException(e);