113 lines
3.8 KiB
Java
113 lines
3.8 KiB
Java
/*
|
|
* Copyright (c) 2012, 2015, Oracle and/or its affiliates. All rights reserved.
|
|
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
|
|
*
|
|
* This code is free software; you can redistribute it and/or modify it
|
|
* under the terms of the GNU General Public License version 2 only, as
|
|
* published by the Free Software Foundation.
|
|
*
|
|
* This code is distributed in the hope that it will be useful, but WITHOUT
|
|
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
|
|
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
|
|
* version 2 for more details (a copy is included in the LICENSE file that
|
|
* accompanied this code).
|
|
*
|
|
* You should have received a copy of the GNU General Public License version
|
|
* 2 along with this work; if not, write to the Free Software Foundation,
|
|
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
|
|
*
|
|
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
|
|
* or visit www.oracle.com if you need additional information or have any
|
|
* questions.
|
|
*/
|
|
|
|
/*
|
|
* @test
|
|
* @bug 7009998
|
|
* @summary Tests the correct processing of concurrent ClientComunicatorAdmin reconnect requests.
|
|
* @author Jaroslav Bachorik
|
|
* @modules java.management/com.sun.jmx.remote.internal
|
|
* @run clean CCAdminReconnectTest
|
|
* @run build CCAdminReconnectTest
|
|
* @run main CCAdminReconnectTest
|
|
*/
|
|
|
|
import com.sun.jmx.remote.internal.ClientCommunicatorAdmin;
|
|
import java.io.*;
|
|
import java.util.Collection;
|
|
import java.util.LinkedList;
|
|
import java.util.concurrent.ExecutorService;
|
|
import java.util.concurrent.Executors;
|
|
import java.util.concurrent.TimeUnit;
|
|
import java.util.concurrent.atomic.AtomicBoolean;
|
|
|
|
public class CCAdminReconnectTest {
|
|
final private static int THREAD_COUNT = 3;
|
|
|
|
public static void main(String ... args) throws Exception {
|
|
final ExecutorService e = Executors.newFixedThreadPool(THREAD_COUNT);
|
|
final AtomicBoolean beingReconnected = new AtomicBoolean();
|
|
final Collection<Exception> thrownExceptions = new LinkedList<>();
|
|
|
|
System.out.println(": Testing concurrent restart of ClientCommunicatorAdmin");
|
|
|
|
final ClientCommunicatorAdmin cca = new ClientCommunicatorAdmin(50) {
|
|
|
|
@Override
|
|
protected void checkConnection() throws IOException {
|
|
// empty
|
|
}
|
|
|
|
@Override
|
|
protected void doStart() throws IOException {
|
|
if (!beingReconnected.compareAndSet(false, true)) {
|
|
IOException e = new IOException("Detected overlayed reconnect requests");
|
|
thrownExceptions.add(e);
|
|
throw e;
|
|
}
|
|
try {
|
|
Thread.sleep(800); // simulating a workload
|
|
beingReconnected.set(false);
|
|
} catch (InterruptedException e) {
|
|
}
|
|
}
|
|
|
|
@Override
|
|
protected void doStop() {
|
|
// empty
|
|
}
|
|
};
|
|
|
|
Runnable r = new Runnable() {
|
|
final private IOException e = new IOException("Forced reconnect");
|
|
@Override
|
|
public void run() {
|
|
try {
|
|
// forcing the reconnect request
|
|
cca.gotIOException(e);
|
|
} catch (Exception ex) {
|
|
ex.printStackTrace();
|
|
}
|
|
}
|
|
};
|
|
|
|
System.out.println(": Spawning " + THREAD_COUNT + " concurrent reconnect requests");
|
|
|
|
for(int i=0;i<THREAD_COUNT;i++) {
|
|
e.execute(r);
|
|
}
|
|
|
|
Thread.sleep(THREAD_COUNT * 1000);
|
|
e.shutdown();
|
|
e.awaitTermination(10, TimeUnit.SECONDS);
|
|
|
|
cca.terminate();
|
|
|
|
for(Exception thrown : thrownExceptions) {
|
|
throw thrown;
|
|
}
|
|
System.out.println(": Requests processed successfully");
|
|
}
|
|
}
|
|
|