1 /*

     2  * Copyright (c) 2005, 2016, 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 /* @test

    25  * @bug 4457683

    26  * @summary After all of the remote objects (including a registry, if

    27  * applicable) that had been exported with a given

    28  * RMIServerSocketFactory value (including null) have been unexported,

    29  * the server socket created for the exports should be closed (so that

    30  * the local port is released).

    31  * @author Peter Jones

    32  *

    33  * @library ../../testlibrary

    34  * @modules java.rmi/sun.rmi.registry

    35  *          java.rmi/sun.rmi.server

    36  *          java.rmi/sun.rmi.transport

    37  *          java.rmi/sun.rmi.transport.tcp

    38  * @build TestLibrary

    39  * @run main/othervm CloseServerSocket

    40  * @key intermittent

    41  */

    42 

    43 import java.io.IOException;

    44 import java.net.BindException;

    45 import java.net.ServerSocket;

    46 import java.rmi.Remote;

    47 import java.rmi.registry.LocateRegistry;

    48 import java.rmi.registry.Registry;

    49 import java.rmi.server.RMIServerSocketFactory;

    50 import java.rmi.server.UnicastRemoteObject;

    51 

    52 public class CloseServerSocket implements Remote {

    53     private static final int PORT = TestLibrary.getUnusedRandomPort();

    54 

    55     private CloseServerSocket() { }

    56 

    57     public static void main(String[] args) throws Exception {

    58         System.err.println("\nRegression test for bug 4457683\n");

    59 

    60         verifyPortFree(PORT);

    61         Registry registry = LocateRegistry.createRegistry(PORT);

    62         System.err.println("- exported registry: " + registry);

    63         verifyPortInUse(PORT);

    64         UnicastRemoteObject.unexportObject(registry, true);

    65         System.err.println("- unexported registry");

    66         Thread.sleep(1000);        // work around BindException (bug?)

    67         verifyPortFree(PORT);

    68 

    69         /*

    70          * The follow portion of this test is disabled temporarily

    71          * because 4457683 was partially backed out because of

    72          * 6269166; for now, only server sockets originally opened for

    73          * exports on non-anonymous ports will be closed when all of

    74          * the corresponding remote objects have been exported.  A

    75          * separate bug will be filed to represent the remainder of

    76          * 4457683 for anonymous-port exports.

    77          */

    78 

    79 //      SSF ssf = new SSF();

    80 //      Remote impl = new CloseServerSocket();

    81 //      Remote stub = UnicastRemoteObject.exportObject(impl, 0, null, ssf);

    82 //      System.err.println("- exported object: " + stub);

    83 //      UnicastRemoteObject.unexportObject(impl, true);

    84 //      System.err.println("- unexported object");

    85 //      synchronized (ssf) {

    86 //          if (!ssf.serverSocketClosed) {

    87 //              throw new RuntimeException("TEST FAILED: " +

    88 //                                         "server socket not closed");

    89 //          }

    90 //      }

    91 

    92         System.err.println("TEST PASSED");

    93     }

    94 

    95     private static void verifyPortFree(int port) throws IOException {

    96         ServerSocket ss = new ServerSocket(port);

    97         ss.close();

    98         System.err.println("- port " + port + " is free");

    99     }

   100 

   101     private static void verifyPortInUse(int port) throws IOException {

   102         try {

   103             verifyPortFree(port);

   104         } catch (BindException e) {

   105             System.err.println("- port " + port + " is in use");

   106             return;

   107         }

   108     }

   109 

   110     private static class SSF implements RMIServerSocketFactory {

   111         boolean serverSocketClosed = false;

   112         SSF() { };

   113 

   114         public ServerSocket createServerSocket(int port) throws IOException {

   115             return new SS(port);

   116         }

   117 

   118         private class SS extends ServerSocket {

   119             SS(int port) throws IOException {

   120                 super(port);

   121                 System.err.println("- created server socket: " + this);

   122             };

   123 

   124             public void close() throws IOException {

   125                 synchronized (SSF.this) {

   126                     serverSocketClosed = true;

   127                     SSF.this.notifyAll();

   128                 }

   129                 System.err.println("- closing server socket: " + this);

   130                 super.close();

   131             }

   132         }

   133     }

   134 }