starter/server/XuluServerStarter.java

package appl.parallel.starter.server;

import java.awt.AWTException;
import java.awt.Image;
import java.awt.MenuItem;
import java.awt.PopupMenu;
import java.awt.SystemTray;
import java.awt.Toolkit;
import java.awt.TrayIcon;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.MouseAdapter;
import java.awt.event.MouseEvent;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.SequenceInputStream;
import java.rmi.AccessException;
import java.rmi.Naming;
import java.rmi.NotBoundException;
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.rmi.server.UnicastRemoteObject;

import javax.swing.JOptionPane;

import appl.ext.XuluConfig;
import appl.parallel.ComputingResource;
import appl.parallel.server.XuluServer;
import appl.parallel.starter.Starter;
import appl.parallel.util.Helper;
import de.schmitzm.swing.TextAreaPrintStream;

/**
 * A running instance of the XuluServerStarter waits for a signal to start a
 * {@link XuluServer}. When {@link #start()} is called the Server is started.
 * All output from the new Serverprocess are forwarded to the actual screen (if
 * any). The Server can also be {@link #restart() restarted} or
 * {@link #stop() stopped}. <br>
 * <br>
 * For configuration of the XuluServer the {@link XuluConfig} is used. The
 * following configuration entries are supported <TABLE border="1"
 * <tr>
 * <th>Entry</th>
 * <th>Default</th>
 * <th>Description</th>
 * </tr>
 * <tr>
 * <td>XuluServerStarter.port</td>
 * <td>1099</td>
 * <td> The port which is used for the registry creation (if none is running)</td>
 * </tr>
 * <tr>
 * <td>XuluServerStarter.javaprogram</td>
 * <td>java</td>
 * <td> The path to the java program</td>
 * </tr>
 * <tr>
 * <td>XuluServerStarter.codebasedir</td>
 * <td></td>
 * <td> The absolute path to the codebase directory (should be the path to the
 * binaries)</td>
 * </tr>
 * <tr>
 * <td>XuluServerStarter.securitypolicy</td>
 * <td></td>
 * <td> The path to the security policy</td>
 * </tr>
 * <tr>
 * <td>XuluServerStarter.furtherjavaarguments</td>
 * <td></td>
 * <td> further JVM arguments</td>
 * </tr>
 * <tr>
 * <td>XuluServerStarter.classpath</td>
 * <td></td>
 * <td> The libaries needed</td>
 * </tr>
 * <tr>
 * <td>XuluServerStarter.memorymax</td>
 * <td>64</td>
 * <td> The maximum memory the XuluSever attempts to use (-xmx)</td>
 * </tr>
 * <tr>
 * <td>XuluServerStarter.memorymin</td>
 * <td>4</td>
 * <td> The inital memory the XuluServer uses (-xms)</td>
 * </tr>
 * </TABLE>
 * 
 * @author Dominik Appl
 */
public class XuluServerStarter extends UnicastRemoteObject implements Starter,
                ActionListener {

        private enum Status {
                /** server is not started */
                serverOff,
                /** * Server is started */
                serverStarted,
                /** A client is connected */
                serverActive
        }

        private String bindingName = "XuluServerStarter";

        private int port = 1099;

        private String javaprogram = "java";

        private String codebase = "";

        private String securitypolicy = "";

        private String furtherjavaarguments = "";

        private String xuluserverarguments = "";

        private String classpath = "";

        private String XuluServerString = "appl.parallel.server.XuluServer";

        private Process p;

        // private BufferedReader input;

        private SimpleConsoleOutputThread thread;

        private int xms = 64;

        private int xmx = 128;

        private SequenceInputStream twoStreams;

        private XuluStarterServerGUI starterServerGUI;

        private TextAreaPrintStream textAreaOutput;

        private MenuItem menu_exit;

        private MenuItem menu_start;

        private MenuItem menu_stop;

        private MenuItem menu_showConsole;

        private TrayIcon trayIcon;

        private ComputingResource xuluServer;

        private Image redIcon;

        private Image greenIcon;

        private Image yellowIcon;

        private String cmd;

        /**
         * @param cmd
         *            the command to be executed by the starter. If null, the
         *            XuluConfig is used to create the commandline
         * @param showGUI
         *            if false, no GUI/Tray is shown
         * @throws RemoteException
         */
        private XuluServerStarter(String cmd, boolean showGUI)
                        throws RemoteException {
                super();
                this.cmd = cmd;
                this.bind(bindingName, this, port);
                if (showGUI) {
                        redIcon = Toolkit.getDefaultToolkit().getImage(
                                        "resource/xulu_icon_red.gif");
                        greenIcon = Toolkit.getDefaultToolkit().getImage(
                                        "resource/xulu_icon_green.gif");
                        yellowIcon = Toolkit.getDefaultToolkit().getImage(
                                        "resource/xulu_icon_yellow.gif");
                        createGUI();
                        createTray();
                        setStatus(Status.serverOff);
                }
        }

        /**
         * Should be called if the status has changed (changes tray icon)
         * 
         * @param newStatus
         *            the new status
         */
        private void setStatus(Status newStatus) {
                // if tray disabled: return
                if (trayIcon == null)
                        return;
                switch (newStatus) {
                case serverOff:
                        trayIcon.setImage(redIcon);
                        trayIcon.setToolTip("XuluServer is disabled");
                        break;
                case serverStarted:
                        trayIcon.setImage(greenIcon);
                        trayIcon.setToolTip("Xulu Server is ready and waiting for tasks");
                        break;
                case serverActive:
                        trayIcon.setImage(yellowIcon);
                        trayIcon.setToolTip("A client is connected to the XuluServer");
                        break;
                }
        }

        /**
         * creates and inits the tray icon.
         */
        private void createTray() {

                if (SystemTray.isSupported()) {

                        SystemTray tray = SystemTray.getSystemTray();
                        Image image = Toolkit.getDefaultToolkit().getImage(
                                        "temp/xulu_icon.gif");

                        // create menu entries
                        PopupMenu popup = new PopupMenu();
                        menu_exit = new MenuItem("Exit");
                        menu_start = new MenuItem("Start Server");
                        menu_stop = new MenuItem("Stop Server");
                        menu_showConsole = new MenuItem("Show contol window");
                        menu_exit.addActionListener(this);
                        menu_start.addActionListener(this);
                        menu_stop.addActionListener(this);
                        menu_showConsole.addActionListener(this);

                        popup.add(menu_start);
                        popup.add(menu_stop);
                        popup.add(menu_showConsole);
                        popup.add(menu_exit);
                        trayIcon = new TrayIcon(image, "Xulu Server", popup);
                        trayIcon.setImageAutoSize(true);
                        trayIcon.addMouseListener(new MouseAdapter() {
                                // on doubleclick popup the control-window
                                public void mouseClicked(MouseEvent e) {
                                        if (e.getClickCount() > 1) {
                                                starterServerGUI.setVisible(!starterServerGUI
                                                                .isVisible());
                                        }
                                }
                        });

                        try {
                                tray.add(trayIcon);
                        } catch (AWTException e) {
                                System.err.println("TrayIcon could not be added.");
                                tray = null;
                        }

                } else {
                        // System Tray is not supported
                        System.out.println("System Tray not supported"); 
                        trayIcon = null;
                }

        }

        /**
         * creates the GUI for the Starter
         */
        private void createGUI() {
                // create new GUI
                starterServerGUI = new XuluStarterServerGUI();
                // register this instance as button listener
                starterServerGUI.button_exit.addActionListener(this);
                starterServerGUI.button_start.addActionListener(this);
                starterServerGUI.button_stop.addActionListener(this);

                // register TextArea as OutputStream
                textAreaOutput = new TextAreaPrintStream(starterServerGUI.consoleArea);
                System.setErr(textAreaOutput);
                System.setOut(textAreaOutput);

        }

        /**
         * reads the configuration out of the {@link XuluConfig}
         */
        private void loadConfig() {
                XuluConfig config = XuluConfig.getXuluConfig();
                if (config.getIntProperty("XuluServerStarter.port") != 0)
                        port = config.getIntProperty("XuluServerStarter.port");
                if (config.getProperty("XuluServerStarter.javaprogram") != null)
                        javaprogram = config.getProperty("XuluServerStarter.javaprogram");
                if (config.getProperty("XuluServerStarter.codebasedir") != null)
                        codebase = config.getProperty("XuluServerStarter.codebasedir");
                if (config.getProperty("XuluServerStarter.securitypolicy") != null)
                        securitypolicy = config
                                        .getProperty("XuluServerStarter.securitypolicy");
                if (config.getProperty("XuluServerStarter.furtherjavaarguments") != null)
                        furtherjavaarguments = config
                                        .getProperty("XuluServerStarter.furtherjavaarguments");
                if (config.getProperty("XuluServerStarter.classpath") != null)
                        classpath = config.getProperty("XuluServerStarter.classpath");
                if (config.getProperty("XuluServerStarter.memorymax") != null)
                        xmx = config.getIntProperty("XuluServerStarter.memorymax");
                if (config.getProperty("XuluServerStarter.memorymin") != null)
                        xms = config.getIntProperty("XuluServerStarter.memorymin");
        }

        /*
         * (non-Javadoc)
         * 
         * @see appl.parallel.starter.Starter#restart()
         */
        public void restart() throws RemoteException {
                this.stop();
                this.start();
        }

        /**
         * Creates the Java commandline and starts the {@link XuluServer}
         * 
         * @see appl.parallel.starter.Starter#start()
         */
        public void start() throws RemoteException {
                loadConfig();
                try {
                        if (p != null) {
                                System.out
                                                .println("Process is already running. Stop process first");
                                return;
                        }
                        String commandline = "\"" + javaprogram + "\"" + " -cp \""
                                        + codebase;
                        if (!(classpath.equals("")))
                                commandline += (";" + classpath);
                        commandline += "\" ";
                        if (xms != 0)
                                commandline += (" -Xms" + xms + "M ");
                        if (xmx != 0)
                                commandline += (" -Xmx" + xmx + "M ");

                        commandline += (" -Djava.rmi.server.codebase=file:///" + codebase
                                        + " -Djava.security.policy=" + securitypolicy + " "
                                        + furtherjavaarguments + " " + XuluServerString + " " + xuluserverarguments);
                        // if there is a user commandline, use this instead
                        if (cmd != null)
                                commandline = cmd;
                        System.out.println("Executing commandline: " + commandline);
                        p = Runtime.getRuntime().exec(commandline);
                        xuluServer = null;
                        // forward the inputstream of the new process to the
                        // console/textarea
                        InputStream standardInput = p.getInputStream();
                        InputStream errorInput = p.getErrorStream();
                        thread = new SimpleConsoleOutputThread(standardInput, errorInput);
                        thread.startThread();
                        // wait until the server is bound to the registry
                        Thread.sleep(5000);
                        // lookup the new Server
                        xuluServer = (ComputingResource) Naming
                                        .lookup("rmi://localhost/XuluServer");
                        setStatus(Status.serverStarted);
                        System.out
                                        .println("The Starter has successfully discovered the XuluServer instance");

                } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                } catch (NotBoundException e) {
                        System.out
                                        .println("Could not find the Xulu server instance(NotBoundException).\n Creation of the XuluServer failed..please correct the commandline...");

                } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        }

        /*
         * (non-Javadoc)
         * 
         * @see appl.parallel.starter.Starter#stop()
         */
        public void stop() throws RemoteException {
                try {
                        if (twoStreams != null)
                                twoStreams.close();
                        if (thread != null)
                                thread.stopThread();
                        // if (input != null)
                        // input.close();
                        if (p != null)
                                p.destroy();
                        p = null;
                        System.out.println("Process stopped");
                        this.setStatus(Status.serverOff);
                } catch (IOException e) {
                        e.printStackTrace();
                }
        }

        /**
         * Starts the XuluServerStarter <br/> The parameter -start can be used to
         * start the Server at launch of the Starter. <br>
         * The parameter -cmd <command> will use the given command to try to start
         * the server. Else the XuluConfig will be used. <br>
         * The parameter -noGUI forces the starter to not use any GUI functionality.
         */
        public static void main(String[] args) {
                try {
                        System.out
                                        .println("Use the parameter -help to see all available commandline options");
                        String cmd = null;
                        boolean noGUI = false;
                        boolean start = false;
                        // search for command parameter
                        for (int i = 0; i < args.length; i++) {
                                if (args[i].toLowerCase().equals("-cmd") && i < args.length)
                                        cmd = args[i + 1];
                                if (args[i].toLowerCase().equals("-nogui") && i < args.length)
                                        noGUI = true;
                                if (args[i].toLowerCase().equals("-start"))
                                        start = true;
                                if (args[i].toLowerCase().equals("-help"))
                                        printHelp();
                        }
                        XuluServerStarter starter = new XuluServerStarter(cmd, !noGUI);
                        System.out.println("XuluServerStarter initialized .... ");
                        if (start) {
                                starter.start();
                        }
                        if (!starter.isRunning()) {
                                System.out
                                                .println("Hint: use parameter '-start' to start the server directly");
                        }
                } catch (RemoteException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        }

        /**
         * 
         */
        private static void printHelp() {
                System.out
                                .println("The following commands can be used: \n\n"
                                                + "-start can be used to start the Server at launch of the Starter.\n"
                                                + "-cmd <command> will use the given command to try to start the server."
                                                + " Else the XuluConfig will be used.\n"
                                                + "-noGUI doesn't use any GUI functionality.\n"
                                                + "-help displays this help");

        }

        public boolean isRunning() throws RemoteException {
                return (p != null);

        }

        /**
         * Copied from {@link Helper} and modified so that it does not depend on
         * log4j. Binds the remote object's stub in the registry. Creates a registry
         * if no running registry is found.
         * 
         * @param bindingName
         *            the name to be used for binding
         * @param bindingInstance
         *            an instance of the type to bind to the registry
         * @param defaultPort
         *            the default registry port
         * @throws RemoteException
         *             if something goes wrong
         */
        public void bind(String bindingName, Remote bindingInstance, int defaultPort)
                        throws RemoteException {
                boolean failed = true;
                Registry registry;
                try {
                        registry = LocateRegistry.getRegistry();
                        registry.rebind(bindingName, bindingInstance);
                        failed = false;
                } catch (AccessException e) {
                        System.err.println("Not enough permissions to bind" + bindingName
                                        + "to the registry! Adjust your security permission file!");
                        e.printStackTrace();
                } catch (RemoteException e) {
                        if (e instanceof java.rmi.ConnectException) {
                                System.out
                                                .println("Could not connect to registry! Trying to create new one...");
                                try {
                                        registry = LocateRegistry.createRegistry(defaultPort);
                                        registry.rebind(bindingName, bindingInstance);
                                        System.out.println("Registry successfully created at port "
                                                        + defaultPort);
                                        failed = false;
                                } catch (RemoteException e1) {
                                        // TODO Auto-generated catch block
                                        e1.printStackTrace();
                                }
                        } else
                                e.printStackTrace();
                }
                if (failed)
                        throw new RemoteException("Could not find or create registry!");
        }

        /**
         * The Thread is used to direct the output of the process to System.out.
         * Notice that this stream may be redirected to a
         * {@link TextAreaPrintStream} or any other printstream using
         * {@link System#setOut(java.io.PrintStream)}
         * 
         * @author appl
         */
        class SimpleConsoleOutputThread implements Runnable {
                private volatile Thread outputThread;

                private boolean exit;

                private final InputStream standardInput;

                private final InputStream errorInput;

                private final BufferedReader input;

                private final SequenceInputStream twoStreams;

                private boolean availableLastTime = false;

                /**
                 * Creates a new thread. The parmeters are the inputstreams which should
                 * be forwarded to System.out
                 * 
                 * @param standardInput
                 * @param errorInput
                 */
                public SimpleConsoleOutputThread(InputStream standardInput,
                                InputStream errorInput) {
                        this.standardInput = standardInput;
                        this.errorInput = errorInput;
                        // combine the streams
                        twoStreams = new SequenceInputStream(standardInput, errorInput);
                        input = new BufferedReader(new InputStreamReader(twoStreams));
                }

                public void startThread() {
                        exit = false;
                        if (outputThread == null)
                                outputThread = new Thread(this);
                        outputThread.start();
                }

                public void stopThread() {
                        exit = true;
                        outputThread.interrupt();
                        try {
                                input.close();
                        } catch (IOException e) {
                                System.out.println("Input closed");
                                e.printStackTrace();
                        }
                }

                public void run() {
                        String line;
                        while (exit == false) {
                                try {
                                        while (input.ready()) {
                                                line = input.readLine();
                                                System.out.println(line);
                                        }
                                        Thread.sleep(1000);
                                        // check if server is active for tray icon change
                                        if (xuluServer != null)
                                                if (availableLastTime != xuluServer.isAvailable()) {
                                                        if (availableLastTime)
                                                                setStatus(Status.serverActive);
                                                        else
                                                                setStatus(Status.serverStarted);
                                                        availableLastTime = (!availableLastTime);
                                                }

                                } catch (IOException e) {
                                        System.out
                                                        .println("Connection to server failed. Input closed");
                                        e.printStackTrace();
                                        exit = true;
                                } catch (InterruptedException e) {
                                        if (exit == true)
                                                System.out.println("Stopped output thread...");
                                }
                        }
                }
        }

        /*
         * (non-Javadoc)
         * 
         * @see java.awt.event.ActionListener#actionPerformed(java.awt.event.ActionEvent)
         */
        public void actionPerformed(ActionEvent e) {
                if (e.getSource() == starterServerGUI.button_stop
                                || e.getSource() == menu_stop) {
                        try {
                                this.stop();
                        } catch (Exception e1) {
                                System.out
                                                .println("Could not stop the Server. Reason follows: ");
                                e1.printStackTrace();
                        }
                } else if (e.getSource() == starterServerGUI.button_exit
                                || e.getSource() == menu_exit) {
                        // if user does not confirm: return.
                        if (JOptionPane
                                        .showConfirmDialog(
                                                        starterServerGUI,
                                                        "Are you sure that you want to exit the Starter-Application?",
                                                        "Confirm exit", JOptionPane.OK_CANCEL_OPTION) != JOptionPane.OK_OPTION)
                                return;
                        try {
                                this.stop();
                        } catch (RemoteException e1) {
                        }
                        System.exit(1);

                } else if (e.getSource() == starterServerGUI.button_start
                                || e.getSource() == menu_start) {
                        try {
                                this.start();
                        } catch (Exception e1) {
                                System.out
                                                .println("Could not start the Server. Reason follows: ");
                                e1.printStackTrace();
                        }
                } else if (e.getSource() == menu_showConsole) {
                        starterServerGUI.setVisible(true);
                }

        }
}
1	package appl.parallel.starter.server;
2
3	import java.awt.AWTException;
4	import java.awt.Image;
5	import java.awt.MenuItem;
6	import java.awt.PopupMenu;
7	import java.awt.SystemTray;
8	import java.awt.Toolkit;
9	import java.awt.TrayIcon;
10	import java.awt.event.ActionEvent;
11	import java.awt.event.ActionListener;
12	import java.awt.event.MouseAdapter;
13	import java.awt.event.MouseEvent;
14	import java.io.BufferedReader;
15	import java.io.IOException;
16	import java.io.InputStream;
17	import java.io.InputStreamReader;
18	import java.io.SequenceInputStream;
19	import java.rmi.AccessException;
20	import java.rmi.Naming;
21	import java.rmi.NotBoundException;
22	import java.rmi.Remote;
23	import java.rmi.RemoteException;
24	import java.rmi.registry.LocateRegistry;
25	import java.rmi.registry.Registry;
26	import java.rmi.server.UnicastRemoteObject;
27
28	import javax.swing.JOptionPane;
29
30	import appl.ext.XuluConfig;
31	import appl.parallel.ComputingResource;
32	import appl.parallel.server.XuluServer;
33	import appl.parallel.starter.Starter;
34	import appl.parallel.util.Helper;
35	import de.schmitzm.swing.TextAreaPrintStream;
36
37	/**
38	* A running instance of the XuluServerStarter waits for a signal to start a
39	* {@link XuluServer}. When {@link #start()} is called the Server is started.
40	* All output from the new Serverprocess are forwarded to the actual screen (if
41	* any). The Server can also be {@link #restart() restarted} or
42	* {@link #stop() stopped}. <br>
43	* <br>
44	* For configuration of the XuluServer the {@link XuluConfig} is used. The
45	* following configuration entries are supported <TABLE border="1"
46	* <tr>
47	* <th>Entry</th>
48	* <th>Default</th>
49	* <th>Description</th>
50	* </tr>
51	* <tr>
52	* <td>XuluServerStarter.port</td>
53	* <td>1099</td>
54	* <td> The port which is used for the registry creation (if none is running)</td>
55	* </tr>
56	* <tr>
57	* <td>XuluServerStarter.javaprogram</td>
58	* <td>java</td>
59	* <td> The path to the java program</td>
60	* </tr>
61	* <tr>
62	* <td>XuluServerStarter.codebasedir</td>
63	* <td></td>
64	* <td> The absolute path to the codebase directory (should be the path to the
65	* binaries)</td>
66	* </tr>
67	* <tr>
68	* <td>XuluServerStarter.securitypolicy</td>
69	* <td></td>
70	* <td> The path to the security policy</td>
71	* </tr>
72	* <tr>
73	* <td>XuluServerStarter.furtherjavaarguments</td>
74	* <td></td>
75	* <td> further JVM arguments</td>
76	* </tr>
77	* <tr>
78	* <td>XuluServerStarter.classpath</td>
79	* <td></td>
80	* <td> The libaries needed</td>
81	* </tr>
82	* <tr>
83	* <td>XuluServerStarter.memorymax</td>
84	* <td>64</td>
85	* <td> The maximum memory the XuluSever attempts to use (-xmx)</td>
86	* </tr>
87	* <tr>
88	* <td>XuluServerStarter.memorymin</td>
89	* <td>4</td>
90	* <td> The inital memory the XuluServer uses (-xms)</td>
91	* </tr>
92	* </TABLE>
93	*
94	* @author Dominik Appl
95	*/
96	public class XuluServerStarter extends UnicastRemoteObject implements Starter,
97	ActionListener {
98
99	private enum Status {
100	/** server is not started */
101	serverOff,
102	/** * Server is started */
103	serverStarted,
104	/** A client is connected */
105	serverActive
106	}
107
108	private String bindingName = "XuluServerStarter";
109
110	private int port = 1099;
111
112	private String javaprogram = "java";
113
114	private String codebase = "";
115
116	private String securitypolicy = "";
117
118	private String furtherjavaarguments = "";
119
120	private String xuluserverarguments = "";
121
122	private String classpath = "";
123
124	private String XuluServerString = "appl.parallel.server.XuluServer";
125
126	private Process p;
127
128	// private BufferedReader input;
129
130	private SimpleConsoleOutputThread thread;
131
132	private int xms = 64;
133
134	private int xmx = 128;
135
136	private SequenceInputStream twoStreams;
137
138	private XuluStarterServerGUI starterServerGUI;
139
140	private TextAreaPrintStream textAreaOutput;
141
142	private MenuItem menu_exit;
143
144	private MenuItem menu_start;
145
146	private MenuItem menu_stop;
147
148	private MenuItem menu_showConsole;
149
150	private TrayIcon trayIcon;
151
152	private ComputingResource xuluServer;
153
154	private Image redIcon;
155
156	private Image greenIcon;
157
158	private Image yellowIcon;
159
160	private String cmd;
161
162	/**
163	* @param cmd
164	* the command to be executed by the starter. If null, the
165	* XuluConfig is used to create the commandline
166	* @param showGUI
167	* if false, no GUI/Tray is shown
168	* @throws RemoteException
169	*/
170	private XuluServerStarter(String cmd, boolean showGUI)
171	throws RemoteException {
172	super();
173	this.cmd = cmd;
174	this.bind(bindingName, this, port);
175	if (showGUI) {
176	redIcon = Toolkit.getDefaultToolkit().getImage(
177	"resource/xulu_icon_red.gif");
178	greenIcon = Toolkit.getDefaultToolkit().getImage(
179	"resource/xulu_icon_green.gif");
180	yellowIcon = Toolkit.getDefaultToolkit().getImage(
181	"resource/xulu_icon_yellow.gif");
182	createGUI();
183	createTray();
184	setStatus(Status.serverOff);
185	}
186	}
187
188	/**
189	* Should be called if the status has changed (changes tray icon)
190	*
191	* @param newStatus
192	* the new status
193	*/
194	private void setStatus(Status newStatus) {
195	// if tray disabled: return
196	if (trayIcon == null)
197	return;
198	switch (newStatus) {
199	case serverOff:
200	trayIcon.setImage(redIcon);
201	trayIcon.setToolTip("XuluServer is disabled");
202	break;
203	case serverStarted:
204	trayIcon.setImage(greenIcon);
205	trayIcon.setToolTip("Xulu Server is ready and waiting for tasks");
206	break;
207	case serverActive:
208	trayIcon.setImage(yellowIcon);
209	trayIcon.setToolTip("A client is connected to the XuluServer");
210	break;
211	}
212	}
213
214	/**
215	* creates and inits the tray icon.
216	*/
217	private void createTray() {
218
219	if (SystemTray.isSupported()) {
220
221	SystemTray tray = SystemTray.getSystemTray();
222	Image image = Toolkit.getDefaultToolkit().getImage(
223	"temp/xulu_icon.gif");
224
225	// create menu entries
226	PopupMenu popup = new PopupMenu();
227	menu_exit = new MenuItem("Exit");
228	menu_start = new MenuItem("Start Server");
229	menu_stop = new MenuItem("Stop Server");
230	menu_showConsole = new MenuItem("Show contol window");
231	menu_exit.addActionListener(this);
232	menu_start.addActionListener(this);
233	menu_stop.addActionListener(this);
234	menu_showConsole.addActionListener(this);
235
236	popup.add(menu_start);
237	popup.add(menu_stop);
238	popup.add(menu_showConsole);
239	popup.add(menu_exit);
240	trayIcon = new TrayIcon(image, "Xulu Server", popup);
241	trayIcon.setImageAutoSize(true);
242	trayIcon.addMouseListener(new MouseAdapter() {
243	// on doubleclick popup the control-window
244	public void mouseClicked(MouseEvent e) {
245	if (e.getClickCount() > 1) {
246	starterServerGUI.setVisible(!starterServerGUI
247	.isVisible());
248	}
249	}
250	});
251
252	try {
253	tray.add(trayIcon);
254	} catch (AWTException e) {
255	System.err.println("TrayIcon could not be added.");
256	tray = null;
257	}
258
259	} else {
260	// System Tray is not supported
261	System.out.println("System Tray not supported");
262	trayIcon = null;
263	}
264
265	}
266
267	/**
268	* creates the GUI for the Starter
269	*/
270	private void createGUI() {
271	// create new GUI
272	starterServerGUI = new XuluStarterServerGUI();
273	// register this instance as button listener
274	starterServerGUI.button_exit.addActionListener(this);
275	starterServerGUI.button_start.addActionListener(this);
276	starterServerGUI.button_stop.addActionListener(this);
277
278	// register TextArea as OutputStream
279	textAreaOutput = new TextAreaPrintStream(starterServerGUI.consoleArea);
280	System.setErr(textAreaOutput);
281	System.setOut(textAreaOutput);
282
283	}
284
285	/**
286	* reads the configuration out of the {@link XuluConfig}
287	*/
288	private void loadConfig() {
289	XuluConfig config = XuluConfig.getXuluConfig();
290	if (config.getIntProperty("XuluServerStarter.port") != 0)
291	port = config.getIntProperty("XuluServerStarter.port");
292	if (config.getProperty("XuluServerStarter.javaprogram") != null)
293	javaprogram = config.getProperty("XuluServerStarter.javaprogram");
294	if (config.getProperty("XuluServerStarter.codebasedir") != null)
295	codebase = config.getProperty("XuluServerStarter.codebasedir");
296	if (config.getProperty("XuluServerStarter.securitypolicy") != null)
297	securitypolicy = config
298	.getProperty("XuluServerStarter.securitypolicy");
299	if (config.getProperty("XuluServerStarter.furtherjavaarguments") != null)
300	furtherjavaarguments = config
301	.getProperty("XuluServerStarter.furtherjavaarguments");
302	if (config.getProperty("XuluServerStarter.classpath") != null)
303	classpath = config.getProperty("XuluServerStarter.classpath");
304	if (config.getProperty("XuluServerStarter.memorymax") != null)
305	xmx = config.getIntProperty("XuluServerStarter.memorymax");
306	if (config.getProperty("XuluServerStarter.memorymin") != null)
307	xms = config.getIntProperty("XuluServerStarter.memorymin");
308	}
309
310	/*
311	* (non-Javadoc)
312	*
313	* @see appl.parallel.starter.Starter#restart()
314	*/
315	public void restart() throws RemoteException {
316	this.stop();
317	this.start();
318	}
319
320	/**
321	* Creates the Java commandline and starts the {@link XuluServer}
322	*
323	* @see appl.parallel.starter.Starter#start()
324	*/
325	public void start() throws RemoteException {
326	loadConfig();
327	try {
328	if (p != null) {
329	System.out
330	.println("Process is already running. Stop process first");
331	return;
332	}
333	String commandline = "\"" + javaprogram + "\"" + " -cp \""
334	+ codebase;
335	if (!(classpath.equals("")))
336	commandline += (";" + classpath);
337	commandline += "\" ";
338	if (xms != 0)
339	commandline += (" -Xms" + xms + "M ");
340	if (xmx != 0)
341	commandline += (" -Xmx" + xmx + "M ");
342
343	commandline += (" -Djava.rmi.server.codebase=file:///" + codebase
344	+ " -Djava.security.policy=" + securitypolicy + " "
345	+ furtherjavaarguments + " " + XuluServerString + " " + xuluserverarguments);
346	// if there is a user commandline, use this instead
347	if (cmd != null)
348	commandline = cmd;
349	System.out.println("Executing commandline: " + commandline);
350	p = Runtime.getRuntime().exec(commandline);
351	xuluServer = null;
352	// forward the inputstream of the new process to the
353	// console/textarea
354	InputStream standardInput = p.getInputStream();
355	InputStream errorInput = p.getErrorStream();
356	thread = new SimpleConsoleOutputThread(standardInput, errorInput);
357	thread.startThread();
358	// wait until the server is bound to the registry
359	Thread.sleep(5000);
360	// lookup the new Server
361	xuluServer = (ComputingResource) Naming
362	.lookup("rmi://localhost/XuluServer");
363	setStatus(Status.serverStarted);
364	System.out
365	.println("The Starter has successfully discovered the XuluServer instance");
366
367	} catch (IOException e) {
368	// TODO Auto-generated catch block
369	e.printStackTrace();
370	} catch (NotBoundException e) {
371	System.out
372	.println("Could not find the Xulu server instance(NotBoundException).\n Creation of the XuluServer failed..please correct the commandline...");
373
374	} catch (InterruptedException e) {
375	// TODO Auto-generated catch block
376	e.printStackTrace();
377	}
378	}
379
380	/*
381	* (non-Javadoc)
382	*
383	* @see appl.parallel.starter.Starter#stop()
384	*/
385	public void stop() throws RemoteException {
386	try {
387	if (twoStreams != null)
388	twoStreams.close();
389	if (thread != null)
390	thread.stopThread();
391	// if (input != null)
392	// input.close();
393	if (p != null)
394	p.destroy();
395	p = null;
396	System.out.println("Process stopped");
397	this.setStatus(Status.serverOff);
398	} catch (IOException e) {
399	e.printStackTrace();
400	}
401	}
402
403	/**
404	* Starts the XuluServerStarter <br/> The parameter -start can be used to
405	* start the Server at launch of the Starter. <br>
406	* The parameter -cmd <command> will use the given command to try to start
407	* the server. Else the XuluConfig will be used. <br>
408	* The parameter -noGUI forces the starter to not use any GUI functionality.
409	*/
410	public static void main(String[] args) {
411	try {
412	System.out
413	.println("Use the parameter -help to see all available commandline options");
414	String cmd = null;
415	boolean noGUI = false;
416	boolean start = false;
417	// search for command parameter
418	for (int i = 0; i < args.length; i++) {
419	if (args[i].toLowerCase().equals("-cmd") && i < args.length)
420	cmd = args[i + 1];
421	if (args[i].toLowerCase().equals("-nogui") && i < args.length)
422	noGUI = true;
423	if (args[i].toLowerCase().equals("-start"))
424	start = true;
425	if (args[i].toLowerCase().equals("-help"))
426	printHelp();
427	}
428	XuluServerStarter starter = new XuluServerStarter(cmd, !noGUI);
429	System.out.println("XuluServerStarter initialized .... ");
430	if (start) {
431	starter.start();
432	}
433	if (!starter.isRunning()) {
434	System.out
435	.println("Hint: use parameter '-start' to start the server directly");
436	}
437	} catch (RemoteException e) {
438	// TODO Auto-generated catch block
439	e.printStackTrace();
440	}
441	}
442
443	/**
444	*
445	*/
446	private static void printHelp() {
447	System.out
448	.println("The following commands can be used: \n\n"
449	+ "-start can be used to start the Server at launch of the Starter.\n"
450	+ "-cmd <command> will use the given command to try to start the server."
451	+ " Else the XuluConfig will be used.\n"
452	+ "-noGUI doesn't use any GUI functionality.\n"
453	+ "-help displays this help");
454
455	}
456
457	public boolean isRunning() throws RemoteException {
458	return (p != null);
459
460	}
461
462	/**
463	* Copied from {@link Helper} and modified so that it does not depend on
464	* log4j. Binds the remote object's stub in the registry. Creates a registry
465	* if no running registry is found.
466	*
467	* @param bindingName
468	* the name to be used for binding
469	* @param bindingInstance
470	* an instance of the type to bind to the registry
471	* @param defaultPort
472	* the default registry port
473	* @throws RemoteException
474	* if something goes wrong
475	*/
476	public void bind(String bindingName, Remote bindingInstance, int defaultPort)
477	throws RemoteException {
478	boolean failed = true;
479	Registry registry;
480	try {
481	registry = LocateRegistry.getRegistry();
482	registry.rebind(bindingName, bindingInstance);
483	failed = false;
484	} catch (AccessException e) {
485	System.err.println("Not enough permissions to bind" + bindingName
486	+ "to the registry! Adjust your security permission file!");
487	e.printStackTrace();
488	} catch (RemoteException e) {
489	if (e instanceof java.rmi.ConnectException) {
490	System.out
491	.println("Could not connect to registry! Trying to create new one...");
492	try {
493	registry = LocateRegistry.createRegistry(defaultPort);
494	registry.rebind(bindingName, bindingInstance);
495	System.out.println("Registry successfully created at port "
496	+ defaultPort);
497	failed = false;
498	} catch (RemoteException e1) {
499	// TODO Auto-generated catch block
500	e1.printStackTrace();
501	}
502	} else
503	e.printStackTrace();
504	}
505	if (failed)
506	throw new RemoteException("Could not find or create registry!");
507	}
508
509	/**
510	* The Thread is used to direct the output of the process to System.out.
511	* Notice that this stream may be redirected to a
512	* {@link TextAreaPrintStream} or any other printstream using
513	* {@link System#setOut(java.io.PrintStream)}
514	*
515	* @author appl
516	*/
517	class SimpleConsoleOutputThread implements Runnable {
518	private volatile Thread outputThread;
519
520	private boolean exit;
521
522	private final InputStream standardInput;
523
524	private final InputStream errorInput;
525
526	private final BufferedReader input;
527
528	private final SequenceInputStream twoStreams;
529
530	private boolean availableLastTime = false;
531
532	/**
533	* Creates a new thread. The parmeters are the inputstreams which should
534	* be forwarded to System.out
535	*
536	* @param standardInput
537	* @param errorInput
538	*/
539	public SimpleConsoleOutputThread(InputStream standardInput,
540	InputStream errorInput) {
541	this.standardInput = standardInput;
542	this.errorInput = errorInput;
543	// combine the streams
544	twoStreams = new SequenceInputStream(standardInput, errorInput);
545	input = new BufferedReader(new InputStreamReader(twoStreams));
546	}
547
548	public void startThread() {
549	exit = false;
550	if (outputThread == null)
551	outputThread = new Thread(this);
552	outputThread.start();
553	}
554
555	public void stopThread() {
556	exit = true;
557	outputThread.interrupt();
558	try {
559	input.close();
560	} catch (IOException e) {
561	System.out.println("Input closed");
562	e.printStackTrace();
563	}
564	}
565
566	public void run() {
567	String line;
568	while (exit == false) {
569	try {
570	while (input.ready()) {
571	line = input.readLine();
572	System.out.println(line);
573	}
574	Thread.sleep(1000);
575	// check if server is active for tray icon change
576	if (xuluServer != null)
577	if (availableLastTime != xuluServer.isAvailable()) {
578	if (availableLastTime)
579	setStatus(Status.serverActive);
580	else
581	setStatus(Status.serverStarted);
582	availableLastTime = (!availableLastTime);
583	}
584
585	} catch (IOException e) {
586	System.out
587	.println("Connection to server failed. Input closed");
588	e.printStackTrace();
589	exit = true;
590	} catch (InterruptedException e) {
591	if (exit == true)
592	System.out.println("Stopped output thread...");
593	}
594	}
595	}
596	}
597
598	/*
599	* (non-Javadoc)
600	*
601	* @see java.awt.event.ActionListener#actionPerformed(java.awt.event.ActionEvent)
602	*/
603	public void actionPerformed(ActionEvent e) {
604	if (e.getSource() == starterServerGUI.button_stop
605	\|\| e.getSource() == menu_stop) {
606	try {
607	this.stop();
608	} catch (Exception e1) {
609	System.out
610	.println("Could not stop the Server. Reason follows: ");
611	e1.printStackTrace();
612	}
613	} else if (e.getSource() == starterServerGUI.button_exit
614	\|\| e.getSource() == menu_exit) {
615	// if user does not confirm: return.
616	if (JOptionPane
617	.showConfirmDialog(
618	starterServerGUI,
619	"Are you sure that you want to exit the Starter-Application?",
620	"Confirm exit", JOptionPane.OK_CANCEL_OPTION) != JOptionPane.OK_OPTION)
621	return;
622	try {
623	this.stop();
624	} catch (RemoteException e1) {
625	}
626	System.exit(1);
627
628	} else if (e.getSource() == starterServerGUI.button_start
629	\|\| e.getSource() == menu_start) {
630	try {
631	this.start();
632	} catch (Exception e1) {
633	System.out
634	.println("Could not start the Server. Reason follows: ");
635	e1.printStackTrace();
636	}
637	} else if (e.getSource() == menu_showConsole) {
638	starterServerGUI.setVisible(true);
639	}
640
641	}
642	}