Reworked threads, shutdown hook, and exit process to ensure requests are cancelled if student logs/out without cancelling manually.

mark.george / democall3

Browse code Reworked threads, shutdown hook, and exit process to ensure requests are cancelled if student logs/out without cancelling manually. master
1 parent 13e01d9 commit d1a128e1d790cd1684b91d7e33c71ec877830b4d Mark authored on 2 Mar 2011

Patch

Showing 5 changed files

Ignore Space Show notes View nbproject/private/private.properties
compile.on.save=true do.depend=false do.jar=true javac.debug=true javadoc.preview=true user.properties.file=/home/mark/.netbeans/6.9/build.properties axis2.deploy.dir=C:\\Java\\Tomcat-6.0.24\\webapps compile.on.save=true do.depend=false do.jar=true javac.debug=true javadoc.preview=true user.properties.file=/home/mark/.netbeans/6.9/build.properties axis2.deploy.dir=C:\\Java\\Tomcat-6.0.24\\webapps

Ignore Space Show notes View src/client/Client.java
/* * To change this template, choose Tools \| Templates * and open the template in the editor. / package client; import constants.Constants; 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.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.Socket; import java.util.Timer; import java.util.logging.Level; import java.util.logging.Logger; /* * * @author geoma48p / public class Client { private String ip; private PopupMenu popup = new PopupMenu(); private Image image = Toolkit.getDefaultToolkit().getImage("icon.png"); private final TrayIcon trayIcon = new TrayIcon(image, "Request Help", popup); private String machine; private Thread shutDownHook = new Thread() { @Override public void run() { exit(); } }; public Client() { try { createTrayMenu(); shutDownHook.setDaemon(true); Runtime.getRuntime().addShutdownHook(shutDownHook); // String compName = System.getenv("COMPUTERNAME"); String compName = "SB303-13"; String[] nameBits = compName.split("-"); final String lab = nameBits[0]; machine = nameBits[1]; if (compName == null \|\| nameBits.length < 2) { trayIcon.displayMessage("Whoops", "COMPUTERNAME environment variable is not set or not in the correct format.", TrayIcon.MessageType.ERROR); } // create a timer to cause a timeout if server IP not found within 5 seconds Timer timer = new Timer(); timer.schedule(new TimeoutTask(trayIcon), 5000); ip = findServerIP(lab); // we received a response so cancel timer timer.cancel(); } catch (Exception ex) { Logger.getLogger(Client.class.getName()).log(Level.SEVERE, null, ex); } } private void createTrayMenu() { try { trayIcon.setImageAutoSize(true); MenuItem request = new MenuItem("Request Help"); request.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { makeRequest(); } }); final MenuItem cancel = new MenuItem("Cancel Request"); cancel.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { cancelRequest(); } }); MenuItem exit = new MenuItem("Exit"); exit.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { exit(); } }); popup.add(request); popup.add(cancel); popup.addSeparator(); popup.add(exit); SystemTray.getSystemTray().add(trayIcon); } catch (Exception ex) { Logger.getLogger(Client.class.getName()).log(Level.SEVERE, null, ex); } } private void sendRequest(String request) throws Exception { Socket socket = new Socket(ip, Constants.PORT); PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); writer.println(request); writer.flush(); writer.close(); socket.close(); } private String findServerIP(String lab) throws Exception { DatagramSocket socket = new DatagramSocket(); InetAddress address = InetAddress.getByName(Constants.BROADCAST_ADDRESS); byte[] data = lab.getBytes(); int port = Constants.PORT; socket.send(new DatagramPacket(data, data.length, address, port)); byte[] response = new byte[256]; DatagramPacket packet = new DatagramPacket(response, response.length); socket.receive(packet); String serverIp = new String(packet.getData()).trim(); socket.close(); return serverIp; } private void makeRequest() { try { sendRequest("request " + machine); trayIcon.displayMessage("Help is on the way", "Your request is now in the queue.", TrayIcon.MessageType.INFO); } catch (Exception ex) { trayIcon.displayMessage("Whoops", "Failed to make request", TrayIcon.MessageType.ERROR); Logger.getLogger(Client.class.getName()).log(Level.SEVERE, "Error making request", ex); } } private void cancelRequest() { try { sendRequest("cancel " + machine); trayIcon.displayMessage("Request removed", "Your request has been removed from the queue.", TrayIcon.MessageType.INFO); } catch (Exception ex) { trayIcon.displayMessage("Whoops", "Failed to cancel request", TrayIcon.MessageType.ERROR); Logger.getLogger(Client.class.getName()).log(Level.SEVERE, "Error cancelling request", ex); } } private void exit() { // cancel any requests the student has made cancelRequest(); // remove any shutdown hooks so we don't cause a deadlock when we call System.exit below Runtime.getRuntime().removeShutdownHook(shutDownHook); // remove the tray icon from the system tray SystemTray.getSystemTray().remove(trayIcon); // force an exit since they are several threads lurking around that could keep the process running System.exit(0); } public static void main(String[] args) throws Exception { new Client(); } } / * To change this template, choose Tools \| Templates * and open the template in the editor. / package client; import constants.Constants; 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.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.Socket; import java.util.Timer; import java.util.logging.Level; import java.util.logging.Logger; /* * * @author geoma48p */ public class Client { private String ip; private PopupMenu popup = new PopupMenu(); private Image image = Toolkit.getDefaultToolkit().getImage("icon.png"); private final TrayIcon trayIcon = new TrayIcon(image, "Request Help", popup); private String machine; public Client() { try { createTrayMenu(); addShutdownHook(); // String compName = System.getenv("COMPUTERNAME"); String compName = "SB306-13"; String[] nameBits = compName.split("-"); final String lab = nameBits[0]; machine = nameBits[1]; if (compName == null \|\| nameBits.length < 2) { trayIcon.displayMessage("Whoops", "COMPUTERNAME environment variable is not set or not in the correct format.", TrayIcon.MessageType.ERROR); } // create a timer to cause a timeout if server IP not found within 5 seconds Timer timer = new Timer(); timer.schedule(new TimeoutTask(trayIcon), 5000); ip = findServerIP(lab); // we received a response so cancel timer timer.cancel(); } catch (Exception ex) { Logger.getLogger(Client.class.getName()).log(Level.SEVERE, null, ex); } } private void createTrayMenu() { try { trayIcon.setImageAutoSize(true); MenuItem request = new MenuItem("Request Help"); request.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { makeRequest(); } }); final MenuItem cancel = new MenuItem("Cancel Request"); cancel.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { cancelRequest(); } }); MenuItem exit = new MenuItem("Exit"); exit.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { exit(); } }); popup.add(request); popup.add(cancel); popup.addSeparator(); popup.add(exit); SystemTray.getSystemTray().add(trayIcon); } catch (Exception ex) { Logger.getLogger(Client.class.getName()).log(Level.SEVERE, null, ex); } } private void sendRequest(String request) throws Exception { Socket socket = new Socket(ip, Constants.PORT); PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); writer.println(request); writer.flush(); writer.close(); } private String findServerIP(String lab) throws Exception { DatagramSocket socket = new DatagramSocket(); InetAddress address = InetAddress.getByName(Constants.BROADCAST_ADDRESS); byte[] data = lab.getBytes(); int port = Constants.PORT; socket.send(new DatagramPacket(data, data.length, address, port)); byte[] response = new byte[256]; DatagramPacket packet = new DatagramPacket(response, response.length); socket.receive(packet); String serverIp = new String(packet.getData()).trim(); socket.close(); return serverIp; } private void addShutdownHook() { Runtime.getRuntime().addShutdownHook(new Thread() { @Override public void run() { exit(); } }); } private void makeRequest() { try { sendRequest("request " + machine); trayIcon.displayMessage("Success", "Request sent", TrayIcon.MessageType.INFO); } catch (Exception ex) { trayIcon.displayMessage("Whoops", "Failed to make request", TrayIcon.MessageType.ERROR); Logger.getLogger(Client.class.getName()).log(Level.SEVERE, "Error making request", ex); } } private void cancelRequest() { try { sendRequest("cancel " + machine); trayIcon.displayMessage("Success", "Request cancelled", TrayIcon.MessageType.INFO); } catch (Exception ex) { trayIcon.displayMessage("Whoops", "Failed to cancel request", TrayIcon.MessageType.ERROR); Logger.getLogger(Client.class.getName()).log(Level.SEVERE, "Error cancelling request", ex); } } private void exit() { cancelRequest(); SystemTray.getSystemTray().remove(trayIcon); System.exit(0); } public static void main(String[] args) throws Exception { new Client(); } }

Ignore Space Show notes View

src/client/Client.java

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package client;

import constants.Constants;
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.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Timer;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author geoma48p
 */
public class Client {

private String ip;
   private PopupMenu popup = new PopupMenu();
   private Image image = Toolkit.getDefaultToolkit().getImage("icon.png");
   private final TrayIcon trayIcon = new TrayIcon(image, "Request Help", popup);
   private String machine;
   private Thread shutDownHook = new Thread() {

@Override
      public void run() {
         exit();
      }
   };

public Client() {
      try {
         createTrayMenu();

shutDownHook.setDaemon(true);
         Runtime.getRuntime().addShutdownHook(shutDownHook);

//         String compName = System.getenv("COMPUTERNAME");
         String compName = "SB303-13";

String[] nameBits = compName.split("-");
         final String lab = nameBits[0];
         machine = nameBits[1];

if (compName == null || nameBits.length < 2) {
            trayIcon.displayMessage("Whoops", "COMPUTERNAME environment variable is not set or not in the correct format.", TrayIcon.MessageType.ERROR);
         }

// create a timer to cause a timeout if server IP not found within 5 seconds
         Timer timer = new Timer();
         timer.schedule(new TimeoutTask(trayIcon), 5000);
         ip = findServerIP(lab);

// we received a response so cancel timer
         timer.cancel();

} catch (Exception ex) {
         Logger.getLogger(Client.class.getName()).log(Level.SEVERE, null, ex);
      }

}

private void createTrayMenu() {
      try {
         trayIcon.setImageAutoSize(true);
         MenuItem request = new MenuItem("Request Help");
         request.addActionListener(new ActionListener() {

public void actionPerformed(ActionEvent e) {
               makeRequest();
            }
         });
         final MenuItem cancel = new MenuItem("Cancel Request");
         cancel.addActionListener(new ActionListener() {

public void actionPerformed(ActionEvent e) {
               cancelRequest();
            }
         });
         MenuItem exit = new MenuItem("Exit");
         exit.addActionListener(new ActionListener() {

public void actionPerformed(ActionEvent e) {
               exit();
            }
         });
         popup.add(request);
         popup.add(cancel);
         popup.addSeparator();
         popup.add(exit);
         SystemTray.getSystemTray().add(trayIcon);
      } catch (Exception ex) {
         Logger.getLogger(Client.class.getName()).log(Level.SEVERE, null, ex);
      }
   }

private void sendRequest(String request) throws Exception {
      Socket socket = new Socket(ip, Constants.PORT);
      PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
      writer.println(request);
      writer.flush();
      writer.close();
      socket.close();
   }

private String findServerIP(String lab) throws Exception {
      DatagramSocket socket = new DatagramSocket();
      InetAddress address = InetAddress.getByName(Constants.BROADCAST_ADDRESS);
      byte[] data = lab.getBytes();
      int port = Constants.PORT;
      socket.send(new DatagramPacket(data, data.length, address, port));

byte[] response = new byte[256];
      DatagramPacket packet = new DatagramPacket(response, response.length);

socket.receive(packet);
      String serverIp = new String(packet.getData()).trim();
      socket.close();

return serverIp;
   }

private void makeRequest() {
      try {
         sendRequest("request " + machine);
         trayIcon.displayMessage("Help is on the way", "Your request is now in the queue.", TrayIcon.MessageType.INFO);
      } catch (Exception ex) {
         trayIcon.displayMessage("Whoops", "Failed to make request", TrayIcon.MessageType.ERROR);
         Logger.getLogger(Client.class.getName()).log(Level.SEVERE, "Error making request", ex);
      }
   }

private void cancelRequest() {
      try {
         sendRequest("cancel " + machine);
         trayIcon.displayMessage("Request removed", "Your request has been removed from the queue.", TrayIcon.MessageType.INFO);
      } catch (Exception ex) {
         trayIcon.displayMessage("Whoops", "Failed to cancel request", TrayIcon.MessageType.ERROR);
         Logger.getLogger(Client.class.getName()).log(Level.SEVERE, "Error cancelling request", ex);
      }
   }

private void exit() {
      // cancel any requests the student has made
      cancelRequest();

// remove any shutdown hooks so we don't cause a deadlock when we call System.exit below
      Runtime.getRuntime().removeShutdownHook(shutDownHook);

// remove the tray icon from the system tray
      SystemTray.getSystemTray().remove(trayIcon);

// force an exit since they are several threads lurking around that could keep the process running
      System.exit(0);
   }

public static void main(String[] args) throws Exception {
      new Client();
   }
}

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package client;

/**
 *
 * @author geoma48p
 */
public class Client {

public Client() {
      try {
         createTrayMenu();
         addShutdownHook();

//      String compName = System.getenv("COMPUTERNAME");
         String compName = "SB306-13";

String[] nameBits = compName.split("-");
         final String lab = nameBits[0];
         machine = nameBits[1];

// we received a response so cancel timer
         timer.cancel();

} catch (Exception ex) {
         Logger.getLogger(Client.class.getName()).log(Level.SEVERE, null, ex);
      }

}

byte[] response = new byte[256];
      DatagramPacket packet = new DatagramPacket(response, response.length);

socket.receive(packet);
      String serverIp = new String(packet.getData()).trim();
      socket.close();

return serverIp;
   }

private void addShutdownHook() {
      Runtime.getRuntime().addShutdownHook(new Thread() {

@Override
         public void run() {
            exit();
         }
      });
   }

private void makeRequest() {
      try {
         sendRequest("request " + machine);
         trayIcon.displayMessage("Success", "Request sent", TrayIcon.MessageType.INFO);
      } catch (Exception ex) {
         trayIcon.displayMessage("Whoops", "Failed to make request", TrayIcon.MessageType.ERROR);
         Logger.getLogger(Client.class.getName()).log(Level.SEVERE, "Error making request", ex);
      }
   }

private void cancelRequest() {
      try {
         sendRequest("cancel " + machine);
         trayIcon.displayMessage("Success", "Request cancelled", TrayIcon.MessageType.INFO);
      } catch (Exception ex) {
         trayIcon.displayMessage("Whoops", "Failed to cancel request", TrayIcon.MessageType.ERROR);
         Logger.getLogger(Client.class.getName()).log(Level.SEVERE, "Error cancelling request", ex);
      }
   }

private void exit() {
      cancelRequest();
      SystemTray.getSystemTray().remove(trayIcon);
      System.exit(0);
   }

public static void main(String[] args) throws Exception {
      new Client();
   }
}

Ignore Space Show notes View src/server/ApplicationHandler.java
package server; import gui.IMapPanel; import java.net.ServerSocket; import java.net.Socket; import java.util.logging.Level; import java.util.logging.Logger; import javax.swing.JPanel; /** * * @author mark / public class ApplicationHandler extends Thread { private final IMapPanel panel; public ApplicationHandler(JPanel panel) { this.setDaemon(true); this.panel = (IMapPanel) panel; } @Override public void run() { try { ServerSocket ss = new ServerSocket(7321); while (true) { Socket socket = ss.accept(); new RequestThread(panel, socket).start(); } } catch (Exception ex) { Logger.getLogger(ApplicationHandler.class.getName()).log(Level.SEVERE, null, ex); } } } package server; import gui.IMapPanel; import java.net.ServerSocket; import java.net.Socket; import java.util.logging.Level; import java.util.logging.Logger; import javax.swing.JPanel; /* * * @author mark */ public class ApplicationHandler extends Thread { private final IMapPanel panel; public ApplicationHandler(JPanel panel) { this.panel = (IMapPanel) panel; setDaemon(true); } @Override public void run() { try { ServerSocket ss = new ServerSocket(7321); while (true) { Socket socket = ss.accept(); Thread thread = new Thread(new RequestThread(panel, socket)); thread.setDaemon(true); thread.start(); } } catch (Exception ex) { Logger.getLogger(ApplicationHandler.class.getName()).log(Level.SEVERE, null, ex); } } }

Ignore Space Show notes View

src/server/ApplicationHandler.java

Ignore Space Show notes View src/server/BroadcastResponder.java
package server; import constants.Constants; import java.net.DatagramPacket; import java.net.Inet4Address; import java.net.InetAddress; import java.net.MulticastSocket; import java.net.NetworkInterface; import java.util.Enumeration; import java.util.logging.Level; import java.util.logging.Logger; /** * * @author mark / public class BroadcastResponder extends Thread { private String lab; public BroadcastResponder(String lab) { this.setDaemon(true); this.lab = lab; } @Override public void run() { try { MulticastSocket socket = new MulticastSocket(Constants.PORT); socket.joinGroup(InetAddress.getByName(Constants.BROADCAST_ADDRESS)); while (true) { byte[] buffer = new byte[255]; DatagramPacket packet = new DatagramPacket(buffer, buffer.length); socket.receive(packet); String requestedLab = new String(packet.getData()).trim(); if (requestedLab.equalsIgnoreCase(lab)) { String serverIp = this.getServerIp(); buffer = serverIp.getBytes(); socket.send(new DatagramPacket(buffer, buffer.length, packet.getAddress(), packet.getPort())); } } } catch (Exception ex) { Logger.getLogger(BroadcastResponder.class.getName()).log(Level.SEVERE, null, ex); } } /* * This code comes from Christopher Frantz and seems less likely to pick the loopback IP address than other ways. / private String getServerIp() { try { for (Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements();) { NetworkInterface intf = en.nextElement(); for (Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements();) { InetAddress inetAddress = enumIpAddr.nextElement(); try { // quick hack to ensure we are only getting IPv4 addresses Inet4Address testIfIpv4 = (Inet4Address) inetAddress; if (!inetAddress.isLoopbackAddress()) { return inetAddress.getHostAddress().toString(); } } catch (ClassCastException ignored) { } } } } catch (Exception ex) { } return null; } } package server; import constants.Constants; import java.net.DatagramPacket; import java.net.Inet4Address; import java.net.InetAddress; import java.net.MulticastSocket; import java.net.NetworkInterface; import java.util.Enumeration; import java.util.logging.Level; import java.util.logging.Logger; /* * * @author mark / public class BroadcastResponder extends Thread { private String lab; public BroadcastResponder(String lab) { this.lab = lab; this.setDaemon(true); } @Override public void run() { try { MulticastSocket socket = new MulticastSocket(Constants.PORT); socket.joinGroup(InetAddress.getByName(Constants.BROADCAST_ADDRESS)); while (true) { byte[] buffer = new byte[255]; DatagramPacket packet = new DatagramPacket(buffer, buffer.length); socket.receive(packet); String requestedLab = new String(packet.getData()).trim(); if (requestedLab.equalsIgnoreCase(lab)) { String serverIp = this.getServerIp(); buffer = serverIp.getBytes(); socket.send(new DatagramPacket(buffer, buffer.length, packet.getAddress(), packet.getPort())); } } } catch (Exception ex) { Logger.getLogger(BroadcastResponder.class.getName()).log(Level.SEVERE, null, ex); } } /* * This code comes from Christopher Frantz and seems less likely to pick the loopback IP address than other ways. */ private String getServerIp() { try { for (Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements();) { NetworkInterface intf = en.nextElement(); for (Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements();) { InetAddress inetAddress = enumIpAddr.nextElement(); try { // quick hack to ensure we are only getting IPv4 addresses Inet4Address testIfIpv4 = (Inet4Address) inetAddress; if (!inetAddress.isLoopbackAddress()) { return inetAddress.getHostAddress().toString(); } } catch (ClassCastException ignored) { } } } } catch (Exception ex) { } return null; } }

Ignore Space Show notes View

src/server/BroadcastResponder.java

package server;

import constants.Constants;
import java.net.DatagramPacket;
import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.net.NetworkInterface;
import java.util.Enumeration;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author mark
 */
public class BroadcastResponder extends Thread {

private String lab;

public BroadcastResponder(String lab) {
      this.setDaemon(true);
      this.lab = lab;
   }

@Override
   public void run() {
      try {
         MulticastSocket socket = new MulticastSocket(Constants.PORT);
         socket.joinGroup(InetAddress.getByName(Constants.BROADCAST_ADDRESS));

while (true) {
            byte[] buffer = new byte[255];
            DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
            socket.receive(packet);
            String requestedLab = new String(packet.getData()).trim();
            if (requestedLab.equalsIgnoreCase(lab)) {
               String serverIp = this.getServerIp();
               buffer = serverIp.getBytes();
               socket.send(new DatagramPacket(buffer, buffer.length, packet.getAddress(), packet.getPort()));
            }
         }
         
      } catch (Exception ex) {
         Logger.getLogger(BroadcastResponder.class.getName()).log(Level.SEVERE, null, ex);
      }

}

/**
    *  This code comes from Christopher Frantz and seems less likely to pick the loopback IP address than other ways.
    */
   private String getServerIp() {
      try {

for (Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements();) {
            NetworkInterface intf = en.nextElement();
            for (Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements();) {
               InetAddress inetAddress = enumIpAddr.nextElement();
               try {
                  // quick hack to ensure we are only getting IPv4 addresses
                  Inet4Address testIfIpv4 = (Inet4Address) inetAddress;
                  if (!inetAddress.isLoopbackAddress()) {
                     return inetAddress.getHostAddress().toString();
                  }
               } catch (ClassCastException ignored) {
               }
            }
         }
      } catch (Exception ex) {
      }
      return null;
   }
}

package server;

/**
 *
 * @author mark
 */
public class BroadcastResponder extends Thread {

private String lab;

public BroadcastResponder(String lab) {
      this.lab = lab;
      this.setDaemon(true);
   }

@Override
   public void run() {
      try {
         MulticastSocket socket = new MulticastSocket(Constants.PORT);
         socket.joinGroup(InetAddress.getByName(Constants.BROADCAST_ADDRESS));

}

/**
    *  This code comes from Christopher Frantz and seems less likely to pick the loopback IP address than other ways.
    */
   private String getServerIp() {
      try {

Ignore Space Show notes View src/server/RequestThread.java
/* * To change this template, choose Tools \| Templates * and open the template in the editor. / package server; import gui.IMapPanel; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.Socket; import java.util.logging.Level; import java.util.logging.Logger; /* * * @author geoma48p / public class RequestThread extends Thread { private final IMapPanel panel; private final Socket socket; public RequestThread(IMapPanel panel, Socket socket) { this.setDaemon(true); this.panel = panel; this.socket = socket; } public void run() { try { BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); String message = reader.readLine(); processMessage(message); } catch (IOException ex) { Logger.getLogger(RequestThread.class.getName()).log(Level.SEVERE, null, ex); } } public void processMessage(String message) { String[] messageBits = message.split(" "); String performative = messageBits[0]; int machineId = Integer.parseInt(messageBits[1]); if (performative.equals("request")) { panel.getProcessor().request(machineId); } else { panel.getProcessor().cancel(machineId); } } } / * To change this template, choose Tools \| Templates * and open the template in the editor. / package server; import gui.IMapPanel; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.Socket; import java.util.logging.Level; import java.util.logging.Logger; /* * * @author geoma48p */ public class RequestThread implements Runnable { private final IMapPanel panel; private final Socket socket; public RequestThread(IMapPanel panel, Socket socket) { this.panel = panel; this.socket = socket; } public void run() { try { BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); String message = reader.readLine(); processMessage(message); } catch (IOException ex) { Logger.getLogger(RequestThread.class.getName()).log(Level.SEVERE, null, ex); } } public void processMessage(String message) { String[] messageBits = message.split(" "); String performative = messageBits[0]; int machineId = Integer.parseInt(messageBits[1]); if (performative.equals("request")) { panel.getProcessor().request(machineId); } else { panel.getProcessor().cancel(machineId); } } }

Ignore Space Show notes View

src/server/RequestThread.java

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package server;

import gui.IMapPanel;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author geoma48p
 */
public class RequestThread extends Thread {

private final IMapPanel panel;
   private final Socket socket;

public RequestThread(IMapPanel panel, Socket socket) {
      this.setDaemon(true);
      this.panel = panel;
      this.socket = socket;
   }

public void run() {
      try {
         BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
         String message = reader.readLine();
         processMessage(message);
      } catch (IOException ex) {
         Logger.getLogger(RequestThread.class.getName()).log(Level.SEVERE, null, ex);
      }
   }

public void processMessage(String message) {
      String[] messageBits = message.split(" ");

String performative = messageBits[0];
      int machineId = Integer.parseInt(messageBits[1]);

if (performative.equals("request")) {
         panel.getProcessor().request(machineId);
      } else {
         panel.getProcessor().cancel(machineId);
      }

}
}

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package server;

/**
 *
 * @author geoma48p
 */
public class RequestThread implements Runnable {

private final IMapPanel panel;
    private final Socket socket;

public RequestThread(IMapPanel panel, Socket socket) {
        this.panel = panel;
        this.socket = socket;
    }

public void run() {
        try {
            BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String message = reader.readLine();
            processMessage(message);
        } catch (IOException ex) {
            Logger.getLogger(RequestThread.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

public void processMessage(String message) {
        String[] messageBits = message.split(" ");

String performative = messageBits[0];
        int machineId = Integer.parseInt(messageBits[1]);

if (performative.equals("request")) {
            panel.getProcessor().request(machineId);
        } else {
            panel.getProcessor().cancel(machineId);
        }

}
}

Show line notes below