/*
 * Copyright (c) 2003, 2012, 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 4295885 6824141
 * @summary rmid should be startable from inetd
 * @author Ann Wollrath
 *
 * @library ../../testlibrary
 * @build TestLibrary RMID ActivationLibrary
 * @run main/othervm/timeout=240 RmidViaInheritedChannel
 */

import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.ProtocolFamily;
import java.nio.channels.*;
import java.nio.channels.spi.*;
import java.rmi.Remote;
import java.rmi.NotBoundException;
import java.rmi.activation.ActivationGroup;
import java.rmi.activation.ActivationSystem;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.rmi.server.UnicastRemoteObject;

public class RmidViaInheritedChannel implements Callback {
    private static final Object lock = new Object();
    private static boolean notified = false;

    private RmidViaInheritedChannel() {}

    public void notifyTest() {
        synchronized (lock) {
            notified = true;
            System.err.println("notification received.");
            lock.notifyAll();
        }
    }

    public static void main(String[] args) throws Exception {
        System.setProperty("java.rmi.activation.port",
                           Integer.toString(TestLibrary.RMIDVIAINHERITEDCHANNEL_ACTIVATION_PORT));
        RMID rmid = null;
        Callback obj = null;

        try {
            /*
             * Export callback object and bind in registry.
             */
            System.err.println("export callback object and bind in registry");
            obj = new RmidViaInheritedChannel();
            Callback proxy = (Callback)
                UnicastRemoteObject.exportObject(obj, 0);
            Registry registry =
                LocateRegistry.createRegistry(
                    TestLibrary.RMIDVIAINHERITEDCHANNEL_REGISTRY_PORT);
            registry.bind("Callback", proxy);

            /*
             * Start rmid.
             */
            System.err.println("start rmid with inherited channel");
            RMID.removeLog();
            rmid = RMID.createRMID(System.out, System.err, true, false,
                                   TestLibrary.RMIDVIAINHERITEDCHANNEL_ACTIVATION_PORT);
            rmid.addOptions(new String[]{
                "-Djava.nio.channels.spi.SelectorProvider=RmidViaInheritedChannel$RmidSelectorProvider"});
            if (System.getProperty("os.name").startsWith("Windows") &&
                System.getProperty("os.version").startsWith("5."))
            {
                /* Windows XP/2003 or older
                 * Need to expand ephemeral range to include RMI test ports
                 */
                rmid.addOptions(new String[]{
                    "-Djdk.net.ephemeralPortRange.low=1024",
                    "-Djdk.net.ephemeralPortRange.high=64000"
                });
            }
            rmid.start();

            /*
             * Get activation system and wait to be notified via callback
             * from rmid's selector provider.
             */
            System.err.println("get activation system");
            ActivationSystem system = ActivationGroup.getSystem();
            System.err.println("ActivationSystem = " + system);
            synchronized (lock) {
                while (!notified) {
                    lock.wait();
                }
            }
            System.err.println("TEST PASSED");

        } finally {
            if (obj != null) {
                UnicastRemoteObject.unexportObject(obj, true);
            }
            ActivationLibrary.rmidCleanup(rmid);
        }
    }

    public static class RmidSelectorProvider extends SelectorProvider {

        private final SelectorProvider provider;
        private ServerSocketChannel channel = null;

        public RmidSelectorProvider() {
            provider =  sun.nio.ch.DefaultSelectorProvider.create();
        }

        public DatagramChannel openDatagramChannel()
            throws IOException
        {
            return provider.openDatagramChannel();
        }

        public DatagramChannel openDatagramChannel(ProtocolFamily family)
            throws IOException
        {
            return provider.openDatagramChannel(family);
        }

        public Pipe openPipe()
            throws IOException
        {
            return provider.openPipe();
        }

        public AbstractSelector openSelector()
            throws IOException
        {
            return provider.openSelector();
        }

        public ServerSocketChannel openServerSocketChannel()
            throws IOException
        {
            return provider.openServerSocketChannel();
        }

        public SocketChannel openSocketChannel()
             throws IOException
        {
            return provider.openSocketChannel();
        }

        public synchronized Channel inheritedChannel() throws IOException {
            System.err.println("RmidSelectorProvider.inheritedChannel");
            if (channel == null) {
                /*
                 * Create server socket channel and bind server socket.
                 */
                channel = ServerSocketChannel.open();
                ServerSocket serverSocket = channel.socket();
                serverSocket.bind(
                     new InetSocketAddress(InetAddress.getLocalHost(),
                     TestLibrary.RMIDVIAINHERITEDCHANNEL_ACTIVATION_PORT));
                System.err.println("serverSocket = " + serverSocket);

                /*
                 * Notify test that inherited channel was created.
                 */
                try {
                    System.err.println("notify test...");
                    Registry registry =
                        LocateRegistry.getRegistry(TestLibrary.RMIDVIAINHERITEDCHANNEL_REGISTRY_PORT);
                    Callback obj = (Callback) registry.lookup("Callback");
                    obj.notifyTest();
                } catch (NotBoundException nbe) {
                    throw (IOException)
                        new IOException("callback object not bound").
                            initCause(nbe);
                }
            }
            return channel;
        }
    }
}

interface Callback extends Remote {
    void notifyTest() throws IOException;
}