1/*
2 * Copyright (c) 2015, 2017, Oracle and/or its affiliates. All rights reserved.
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4 *
5 * This code is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License version 2 only, as
7 * published by the Free Software Foundation.
8 *
9 * This code is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
12 * version 2 for more details (a copy is included in the LICENSE file that
13 * accompanied this code).
14 *
15 * You should have received a copy of the GNU General Public License version
16 * 2 along with this work; if not, write to the Free Software Foundation,
17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18 *
19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20 * or visit www.oracle.com if you need additional information or have any
21 * questions.
22 */
23
24/*
25 * @test
26 * @bug 8068721
27 * @summary test RMI-IIOP call with ConcurrentHashMap as an argument
28 * @library /lib/testlibrary
29 * @modules java.corba
30 *          java.naming
31 *          java.rmi
32 * @build jdk.testlibrary.*
33 * @compile Test.java HelloInterface.java HelloServer.java HelloClient.java
34 *    HelloImpl.java _HelloImpl_Tie.java _HelloInterface_Stub.java ConcurrentHashMapTest.java
35 * @run main/othervm -Djava.naming.provider.url=iiop://localhost:1050
36 *    -Djava.naming.factory.initial=com.sun.jndi.cosnaming.CNCtxFactory ConcurrentHashMapTest
37 * @run main/othervm/secure=java.lang.SecurityManager/policy=jtreg.test.policy
38 *    -Djava.naming.provider.url=iiop://localhost:1050
39 *    -Djava.naming.factory.initial=com.sun.jndi.cosnaming.CNCtxFactory ConcurrentHashMapTest
40 * @key intermittent
41 */
42
43
44import java.util.ArrayList;
45import java.util.Arrays;
46import java.util.List;
47import jdk.testlibrary.JDKToolFinder;
48import jdk.testlibrary.JDKToolLauncher;
49
50public class ConcurrentHashMapTest {
51
52    static final String ORBD = JDKToolFinder.getTestJDKTool("orbd");
53    static final String JAVA = JDKToolFinder.getTestJDKTool("java");
54    static final JDKToolLauncher orbdLauncher = JDKToolLauncher.createUsingTestJDK("orbd");
55    static final String CLASSPATH = System.getProperty("java.class.path");
56    static final int FIVE_SECONDS = 5000;
57
58    private static Exception clientException;
59    private static boolean exceptionInClient;
60    private static Process orbdProcess;
61    private static Process rmiServerProcess;
62
63    public static void main(String[] args) throws Exception {
64        try {
65            startTestComponents();
66        } finally {
67            stopTestComponents();
68        }
69        System.err.println("Test completed OK ");
70    }
71
72    static void startTestComponents () throws Exception {
73        startOrbd();
74        Thread.sleep(FIVE_SECONDS);
75        startRmiIiopServer();
76        Thread.sleep(FIVE_SECONDS);
77        executeRmiIiopClient();
78    }
79
80    private static void stopTestComponents() throws Exception {
81        stopRmiIiopServer();
82        stopOrbd();
83        if (exceptionInClient) {
84            throw new RuntimeException(clientException);
85        } else if (!isResponseReceived()) {
86            throw new RuntimeException("Expected Response not received");
87        }
88    }
89
90    static void startOrbd() throws Exception {
91        System.out.println("\nStarting orbd with NS port 1050 ");
92
93        //orbd -ORBInitialHost localhost -ORBInitialPort 1050
94        orbdLauncher.addToolArg("-ORBInitialHost").addToolArg("localhost")
95            .addToolArg("-ORBInitialPort").addToolArg("1050");
96
97        System.out.println("ConcurrentHashMapTest: Executing: " + Arrays.asList(orbdLauncher.getCommand()));
98        ProcessBuilder pb = new ProcessBuilder(orbdLauncher.getCommand());
99        pb.redirectError(ProcessBuilder.Redirect.INHERIT);
100        orbdProcess = pb.start();
101    }
102
103
104    static void startRmiIiopServer() throws Exception {
105        System.out.println("\nStarting RmiServer");
106        // java -cp . --add-modules java.corba
107        // -Djava.naming.factory.initial=com.sun.jndi.cosnaming.CNCtxFactory
108        // -Djava.naming.provider.url=iiop://localhost:1050 HelloServer
109        List<String> commands = new ArrayList<>();
110        commands.add(ConcurrentHashMapTest.JAVA);
111        commands.add("--add-modules");
112        commands.add("java.corba");
113        commands.add("-Djava.naming.factory.initial=com.sun.jndi.cosnaming.CNCtxFactory");
114        commands.add("-Djava.naming.provider.url=iiop://localhost:1050");
115        commands.add("-cp");
116        commands.add(ConcurrentHashMapTest.CLASSPATH);
117        commands.add("HelloServer");
118
119        System.out.println("ConcurrentHashMapTest: Executing: " + commands);
120        ProcessBuilder pb = new ProcessBuilder(commands);
121        pb.redirectError(ProcessBuilder.Redirect.INHERIT);
122        rmiServerProcess = pb.start();
123    }
124
125    static boolean isResponseReceived() {
126        return HelloClient.isResponseReceived();
127    }
128
129    static void stopRmiIiopServer() throws Exception {
130        if (rmiServerProcess != null) {
131            rmiServerProcess.destroyForcibly();
132            rmiServerProcess.waitFor();
133            System.out.println("serverProcess exitCode:"
134                + rmiServerProcess.exitValue());
135        }
136    }
137
138    static void stopOrbd() throws Exception {
139        if (orbdProcess != null) {
140            orbdProcess.destroyForcibly();
141            orbdProcess.waitFor();
142            System.out.println("orbd exitCode:"
143                + orbdProcess.exitValue());
144        }
145    }
146
147    static void executeRmiIiopClient() throws Exception {
148        try {
149            HelloClient.executeRmiClientCall();
150        } catch (Exception ex) {
151            clientException = ex;
152            exceptionInClient = true;
153        }
154    }
155}
156