/*

 * Created on Aug 21, 2003

 */

package isac.bridge;

/**

 * @author rgradisc

 */

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

import org.apache.log4j.Logger;

/**

 * Clients2KernelServer: runs in its own thread and handles the communication

 * from clients to the kernel

 * 

 * @author rgradisc

 */

public class Clients2KernelServer implements Runnable {

    private ServerSocket server_ = null;

    private BridgeMain bridge_;

    static Logger logger_ = Logger.getLogger(Clients2KernelServer.class

            .getName());

    /**

     * Constructor: create a new Clients2KernelServer

     * 

     * @param bridge_

     */

    public Clients2KernelServer(BridgeMain bridge) {

        logger_.warn("Clients2KernelServer: bridge_=" + bridge);

        this.bridge_ = bridge;

    }

    /**

     * Listen on socket: Wait for clients to connect to bridge_, and once the

     * connect, start a new ClientOutputWorker that sends the XML-output back to

     * the client

     */

    public void listenSocket() {

        ClientOutputWorker w;

        Socket socket;

        try {

            server_ = new ServerSocket(bridge_.getSocketPort());

        } catch (IOException e) {

            bridge_.log(1, "Could not listen on port "

                    + bridge_.getSocketPort());

            System.out.println("Could not listen on port "

                    + bridge_.getSocketPort());

            System.exit(-1);

        }

        while (true) {

            try {

                //TODO id should be fetched from the BridgeMain:

                //smallestFreeBridgeRmiID

                //(so far: only one BridgeRMI)

                int id = 1;

                socket = server_.accept(); // wait for client connections

                bridge_.log(1, "connection received");

                w = new ClientOutputWorker(id, socket, bridge_);

                Thread t = new Thread(w, "java_bridge_clientworker" + id);

                t.setDaemon(true);

                t.start();

                bridge_.log(1, "new Client accepted, id=" + id);

                //TODO if to much load, start new kernel: e.g.

                // bridge_.startNewKernel();

            } catch (IOException e) {

                bridge_.log(1, "Accept failed on port"

                        + bridge_.getSocketPort());

                System.out.println("Accept failed on port"

                        + bridge_.getSocketPort());

                //Quit program: could not connect to port

                System.exit(-1);

            }

        }

    }

    /**

     * This starts the Client2KernelServer thread

     */

    public void run() {

        listenSocket();

        try {

            bridge_.log(1, "Clients2KernelServer: Cleaning up...");

            server_.close();

        } catch (IOException e) {

            bridge_.log(1, "Could not close socket");

            System.exit(-1);

        }

        bridge_.log(1, "Done cleaning up");

    }

}