Issue256Test.java

/*
 * Copyright (c) 2010-2020 Nathan Rajlich
 *
 *  Permission is hereby granted, free of charge, to any person
 *  obtaining a copy of this software and associated documentation
 *  files (the "Software"), to deal in the Software without
 *  restriction, including without limitation the rights to use,
 *  copy, modify, merge, publish, distribute, sublicense, and/or sell
 *  copies of the Software, and to permit persons to whom the
 *  Software is furnished to do so, subject to the following
 *  conditions:
 *
 *  The above copyright notice and this permission notice shall be
 *  included in all copies or substantial portions of the Software.
 *
 *  THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
 *  EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
 *  OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
 *  NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 *  HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
 *  WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
 *  FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
 *  OTHER DEALINGS IN THE SOFTWARE.
 */

package org.java_websocket.issues;

import org.java_websocket.WebSocket;
import org.java_websocket.WebSocketImpl;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ClientHandshake;
import org.java_websocket.handshake.ServerHandshake;
import org.java_websocket.server.WebSocketServer;
import org.java_websocket.util.SocketUtil;
import org.java_websocket.util.ThreadCheck;
import org.junit.*;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.URI;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.CountDownLatch;

import static org.hamcrest.core.Is.is;
import static org.junit.Assume.assumeThat;

@Ignore
//@RunWith(Parameterized.class)
public class Issue256Test {

	private static final int NUMBER_OF_TESTS = 10;
	private static WebSocketServer ws;

	private static int port;
	static CountDownLatch countServerDownLatch = new CountDownLatch( 1 );
	@Rule
	public ThreadCheck zombies = new ThreadCheck();

	@Parameterized.Parameter
	public int count;

	@BeforeClass
	public static void startServer() throws Exception {
		port = SocketUtil.getAvailablePort();
		ws = new WebSocketServer( new InetSocketAddress( port ) , 16) {
			@Override
			public void onOpen( WebSocket conn, ClientHandshake handshake ) {

			}

			@Override
			public void onClose( WebSocket conn, int code, String reason, boolean remote ) {

			}

			@Override
			public void onMessage( WebSocket conn, String message ) {
				conn.send( message );
			}

			@Override
			public void onError( WebSocket conn, Exception ex ) {

				ex.printStackTrace(  );
				assumeThat(true, is(false));
				System.out.println("There should be no exception!");
			}

			@Override
			public void onStart() {
				countServerDownLatch.countDown();
			}
		};
		ws.setConnectionLostTimeout( 0 );
		ws.start();
	}

	private void runTestScenarioReconnect( boolean closeBlocking ) throws Exception {
		final CountDownLatch countDownLatch0 = new CountDownLatch( 1 );
		final CountDownLatch countDownLatch1 = new CountDownLatch( 2 );
		WebSocketClient clt = new WebSocketClient( new URI( "ws://localhost:" + port ) ) {
			@Override
			public void onOpen( ServerHandshake handshakedata ) {
				countDownLatch1.countDown();
			}

			@Override
			public void onMessage( String message ) {

			}

			@Override
			public void onClose( int code, String reason, boolean remote ) {
				countDownLatch0.countDown();
			}

			@Override
			public void onError( Exception ex ) {
				ex.printStackTrace(  );
				assumeThat(true, is(false));
				System.out.println("There should be no exception!");
			}
		};
		clt.connectBlocking();
		if( closeBlocking ) {
			clt.closeBlocking();
		} else {
			clt.getSocket().close();
		}
		countDownLatch0.await();
		clt.reconnectBlocking();
		clt.closeBlocking();
	}

	@AfterClass
	public static void successTests() throws InterruptedException, IOException {
		ws.stop();
	}

	@Parameterized.Parameters
	public static Collection<Integer[]> data() {
		List<Integer[]> ret = new ArrayList<Integer[]>(NUMBER_OF_TESTS);
		for (int i = 0; i < NUMBER_OF_TESTS; i++) ret.add(new Integer[]{i});
		return ret;
	}

	@Test(timeout = 5000)
	public void runReconnectSocketClose() throws Exception {
		runTestScenarioReconnect( false );
	}

	@Test(timeout = 5000)
	public void runReconnectCloseBlocking() throws Exception {
		runTestScenarioReconnect( true );
	}

}