001: /*BEGIN_COPYRIGHT_BLOCK
002: *
003: * Copyright (c) 2001-2007, JavaPLT group at Rice University (javaplt@rice.edu)
004: * All rights reserved.
005: *
006: * Redistribution and use in source and binary forms, with or without
007: * modification, are permitted provided that the following conditions are met:
008: * * Redistributions of source code must retain the above copyright
009: * notice, this list of conditions and the following disclaimer.
010: * * Redistributions in binary form must reproduce the above copyright
011: * notice, this list of conditions and the following disclaimer in the
012: * documentation and/or other materials provided with the distribution.
013: * * Neither the names of DrJava, the JavaPLT group, Rice University, nor the
014: * names of its contributors may be used to endorse or promote products
015: * derived from this software without specific prior written permission.
016: *
017: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
018: * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
019: * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
020: * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
021: * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
022: * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
023: * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
024: * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
025: * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
026: * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
027: * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
028: *
029: * This software is Open Source Initiative approved Open Source Software.
030: * Open Source Initative Approved is a trademark of the Open Source Initiative.
031: *
032: * This file is part of DrJava. Download the current version of this project
033: * from http://www.drjava.org/ or http://sourceforge.net/projects/drjava/
034: *
035: * END_COPYRIGHT_BLOCK*/
036:
037: package edu.rice.cs.drjava;
038:
039: import java.io.*;
040: import java.net.*;
041: import edu.rice.cs.drjava.config.OptionConstants;
042:
043: /**
044: * Client class to remote control an already running instance of DrJava.
045: */
046: public class RemoteControlClient {
047: /**
048: * true if a DrJava remote control server is running.
049: */
050: protected static boolean _serverRunning = false;
051:
052: /**
053: * Contains the name of the user running the server, or is null if no server is running.
054: */
055: protected static String _serverUser = null;
056:
057: /**
058: * Time in ms until the client decides the server is not running.
059: */
060: public static int REMOTE_CONTROL_TIMEOUT = 250;
061:
062: /**
063: * Return true if a DrJava remote control server is running.
064: * @return true if running
065: */
066: public static boolean isServerRunning() {
067: return _serverRunning;
068: }
069:
070: /**
071: * Return the name of the user running the server, or null if no server is running.
072: * @return user name or null
073: */
074: public static String getServerUser() {
075: return _serverUser;
076: }
077:
078: /**
079: * Tell the existing DrJava instance to open a file.
080: * @param f file, or null to just test if a server is running.
081: * @return true if file could be opened
082: */
083: public static boolean openFile(File f) throws IOException {
084: try {
085: // get a datagram socket
086: DatagramSocket socket = new DatagramSocket();
087: socket.setSoTimeout(REMOTE_CONTROL_TIMEOUT);
088:
089: // send request
090: String dString = RemoteControlServer.QUERY_PREFIX;
091: if (f != null) {
092: dString = dString + " " + f.getAbsolutePath();
093: }
094: byte[] buf = dString.getBytes();
095: InetAddress address = InetAddress.getByName("127.0.0.1");
096: DatagramPacket packet = new DatagramPacket(buf, buf.length,
097: address, DrJava.getConfig().getSetting(
098: OptionConstants.REMOTE_CONTROL_PORT));
099: socket.send(packet);
100:
101: // get response
102: buf = new byte[512];
103: packet = new DatagramPacket(buf, buf.length);
104: socket.receive(packet);
105:
106: // display response
107: String received = new String(packet.getData(), 0, packet
108: .getLength());
109: _serverRunning = received
110: .startsWith(RemoteControlServer.RESPONSE_PREFIX);
111: if (_serverRunning) {
112: int pos = received.indexOf('!');
113: _serverUser = received.substring(
114: RemoteControlServer.RESPONSE_PREFIX.length(),
115: pos);
116: } else {
117: _serverUser = null;
118: }
119: socket.close();
120:
121: return (received
122: .equals(RemoteControlServer.RESPONSE_PREFIX_WITH_USER));
123: } catch (SocketTimeoutException e) {
124: _serverRunning = false;
125: return false;
126: }
127: }
128:
129: /**
130: * Main method for test purposes.
131: */
132: public static void main(String[] args) {
133: for (int i = 0; i < args.length; ++i) {
134: try {
135: boolean ret = openFile(new File(args[i]));
136: System.out.println("openFile returned " + ret);
137: } catch (IOException ioe) {
138: ioe.printStackTrace();
139: }
140: }
141: }
142: }
|