Cleanup, and further improvements to concurrency.

mark.george / democall3

Browse code Cleanup, and further improvements to concurrency. Should hopefully be bullet proof now. Seems to handle the stress test OK. The tutor client doesn't lose sync during stress test, so hopefully that problem is now fixed. master
1 parent fe6c4f7 commit c56368ec097333c323c2bedc0694e0b31de5be4e Mark authored on 8 Aug 2012

Patch

Showing 8 changed files

Ignore Space Show notes View src/clients/StudentClient.java
package clients; import constants.Constants; import discovery.ServiceLocator; import java.awt.; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.util.Timer; import java.util.logging.Level; import java.util.logging.Logger; import network.MessageGenerator; import network.RequestSender; /* * The student's client for requesting help. * * It adds a system tray icon that has a pop-up menu that the student can use to * request help or cancel their request. Requests are automatically canceled * when the student clicks the "exit" menu item, or the client is terminated by * the OS (via a shutdown hook) meaning there should never be requests in the * queue for students who have gone home. * * This aims to be both simple and robust, therefor the StudentClient stores no * state relating to requests, uses no persistent connections to the server, * and receives no information from the server. * * The client uses a multi-cast broadcast to discover the IP of the server, * which it then uses to send requests to the server. * * The wire protocol is very simple. A string in the form "request 23" is a * request for from the machine with ID 23, and "cancel 23" will cancel that * request. Sending multiple "request" commands or multiple "cancel" commands to * the server should cause no duplication or problems on the server and are * effectively ignored. * * @author Mark / public class StudentClient { private final PopupMenu trayPopopMenu = new PopupMenu(); private final Image trayIconImage = Toolkit.getDefaultToolkit().getImage(getClass().getResource("/icon.png")); private final TrayIcon systemTrayIcon = new TrayIcon(trayIconImage, "Demo Call " + Constants.VERSION, trayPopopMenu); private final MessageGenerator generator = new MessageGenerator(); private String serverIp; private String machineId; private RequestSender requestSender; private boolean foundServer = false; private final Thread shutDownHook = new Thread() { @Override public void run() { cleanUp(); } }; public StudentClient(String compName) { try { createTrayMenu(); // not sure this is necessary but Windows is currently not exiting when the shutdown hook kicks in... this.shutDownHook.setDaemon(true); Runtime.getRuntime().addShutdownHook(this.shutDownHook); if (compName == null) { this.systemTrayIcon.displayMessage("Whoops", "COMPUTERNAME environment variable is not set.", TrayIcon.MessageType.ERROR); // give user a chance to read message Thread.sleep(5000); // shutdown exit(); } // lab machines usually have a COMPUTERNAME in the form "labname-machineId", eg SB316-23 // process computer name to extract lab and machine ID String[] nameBits = compName.split("-"); if (nameBits.length < 2) { this.systemTrayIcon.displayMessage("Whoops", "COMPUTERNAME environment variable is not in the expected format.", TrayIcon.MessageType.ERROR); // give user a chance to read message Thread.sleep(5000); // shutdown exit(); } String lab = nameBits[0]; this.machineId = nameBits[1]; // create a timer to cause a timeout if server IP not found within 5 seconds Timer timer = new Timer(); timer.schedule(new TimeoutTask(this.systemTrayIcon), 5000); // find server IP (uses network multicast) this.serverIp = new ServiceLocator().locateServer(lab); // if we get to this point we got an IP so cancel timer timer.cancel(); this.foundServer = true; this.requestSender = new RequestSender(serverIp); } catch (Exception ex) { Logger.getLogger(StudentClient.class.getName()).log(Level.SEVERE, null, ex); } } private void createTrayMenu() { try { this.systemTrayIcon.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(); } }); this.trayPopopMenu.add(request); this.trayPopopMenu.add(cancel); this.trayPopopMenu.addSeparator(); this.trayPopopMenu.add(exit); SystemTray.getSystemTray().add(this.systemTrayIcon); } catch (Exception ex) { Logger.getLogger(StudentClient.class.getName()).log(Level.SEVERE, null, ex); } } private void makeRequest() { try { requestSender.sendRequest(generator.requestHelp(machineId)); systemTrayIcon.displayMessage("Help is on the way", "Your request is now in the queue.", TrayIcon.MessageType.INFO); } catch (Exception ex) { systemTrayIcon.displayMessage("Whoops", "Failed to make request", TrayIcon.MessageType.ERROR); Logger.getLogger(StudentClient.class.getName()).log(Level.SEVERE, "Error making request", ex); } } private void cancelRequest() { try { requestSender.sendRequest(generator.cancelRequest(machineId)); systemTrayIcon.displayMessage("Request removed", "Your request has been removed from the queue.", TrayIcon.MessageType.INFO); } catch (Exception ex) { systemTrayIcon.displayMessage("Whoops", "Failed to cancel request", TrayIcon.MessageType.ERROR); Logger.getLogger(StudentClient.class.getName()).log(Level.SEVERE, "Error cancelling request", ex); } } private void exit() { this.cleanUp(); // force an exit since they are several threads lurking around that could keep the process running System.exit(0); } private void cleanUp() { // cancel any requests the student has made if(this.foundServer) { cancelRequest(); } // remove the tray icon from the system tray SystemTray.getSystemTray().remove(systemTrayIcon); } @SuppressWarnings("ResultOfObjectAllocationIgnored") public static void main(String[] args) throws Exception { // String compName = System.getenv("COMPUTERNAME"); String compName = "SBEASTCAL1-30"; if(args.length > 0) { compName = args[0]; } new StudentClient(compName); } } package clients; import constants.Constants; import discovery.ServiceLocator; 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.util.Timer; import java.util.logging.Level; import java.util.logging.Logger; import network.MessageGenerator; import network.RequestSender; /* * The student's client for requesting help. It adds a system that icon that has a pop-up menu that the student can use to request help or cancel * their request. Requests are automatically canceled when the student clicks the "exit" menu item, or the client is terminated by the OS (via a * shutdown hook) meaning there should never be requests in the queue for students who have gone home. * * This aims to be both simple and robust, therefor the StudentClient stores no state relating to requests, and uses no persistent connections to the * server and receives no information from the server. * * The client uses a multi-cast broadcast to discover the IP of the server, which it then uses to sent requests to the server. * * The wire protocol is very simple. A string in the form "request 23" is a request for from the machine with ID 23, and "cancel 23" will cancel that * request. Sending multiple "request" commands or multiple "cancel" commands to the server should cause no duplication or problems on the server and * are effectively ignored. * * @author Mark */ public class StudentClient { private final PopupMenu trayPopopMenu = new PopupMenu(); private final Image trayIconImage = Toolkit.getDefaultToolkit().getImage(getClass().getResource("/icon.png")); private final TrayIcon systemTrayIcon = new TrayIcon(trayIconImage, "Demo Call " + Constants.VERSION, trayPopopMenu); private final MessageGenerator generator = new MessageGenerator(); private String serverIp; private String machineId; private RequestSender requestSender; private boolean foundServer = false; private final Thread shutDownHook = new Thread() { @Override public void run() { cleanUp(); } }; public StudentClient(String compName) { try { createTrayMenu(); // not sure this is necessary but Windows is currently not exiting when the shutdown hook kicks in... this.shutDownHook.setDaemon(true); Runtime.getRuntime().addShutdownHook(this.shutDownHook); if (compName == null) { this.systemTrayIcon.displayMessage("Whoops", "COMPUTERNAME environment variable is not set.", TrayIcon.MessageType.ERROR); // give user a chance to read message Thread.sleep(5000); // shutdown exit(); } // lab machines usually have a COMPUTERNAME in the form "labname-machineId", eg SB316-23 // process computer name to extract lab and machine ID String[] nameBits = compName.split("-"); if (nameBits.length < 2) { this.systemTrayIcon.displayMessage("Whoops", "COMPUTERNAME environment variable is not in the expected format.", TrayIcon.MessageType.ERROR); // give user a chance to read message Thread.sleep(5000); // shutdown exit(); } String lab = nameBits[0]; this.machineId = nameBits[1]; // create a timer to cause a timeout if server IP not found within 5 seconds Timer timer = new Timer(); timer.schedule(new TimeoutTask(this.systemTrayIcon), 5000); // find server IP (uses network multicast) this.serverIp = new ServiceLocator().locateServer(lab); // if we get to this point we got an IP so cancel timer timer.cancel(); this.foundServer = true; this.requestSender = new RequestSender(serverIp); } catch (Exception ex) { Logger.getLogger(StudentClient.class.getName()).log(Level.SEVERE, null, ex); } } private void createTrayMenu() { try { this.systemTrayIcon.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(); } }); this.trayPopopMenu.add(request); this.trayPopopMenu.add(cancel); this.trayPopopMenu.addSeparator(); this.trayPopopMenu.add(exit); SystemTray.getSystemTray().add(this.systemTrayIcon); } catch (Exception ex) { Logger.getLogger(StudentClient.class.getName()).log(Level.SEVERE, null, ex); } } private void makeRequest() { try { requestSender.sendRequest(generator.requestHelp(machineId)); systemTrayIcon.displayMessage("Help is on the way", "Your request is now in the queue.", TrayIcon.MessageType.INFO); } catch (Exception ex) { systemTrayIcon.displayMessage("Whoops", "Failed to make request", TrayIcon.MessageType.ERROR); Logger.getLogger(StudentClient.class.getName()).log(Level.SEVERE, "Error making request", ex); } } private void cancelRequest() { try { requestSender.sendRequest(generator.cancelRequest(machineId)); systemTrayIcon.displayMessage("Request removed", "Your request has been removed from the queue.", TrayIcon.MessageType.INFO); } catch (Exception ex) { systemTrayIcon.displayMessage("Whoops", "Failed to cancel request", TrayIcon.MessageType.ERROR); Logger.getLogger(StudentClient.class.getName()).log(Level.SEVERE, "Error cancelling request", ex); } } private void exit() { this.cleanUp(); // force an exit since they are several threads lurking around that could keep the process running System.exit(0); } private void cleanUp() { // cancel any requests the student has made if(this.foundServer) { cancelRequest(); } // remove the tray icon from the system tray SystemTray.getSystemTray().remove(systemTrayIcon); } @SuppressWarnings("ResultOfObjectAllocationIgnored") public static void main(String[] args) throws Exception { // String compName = System.getenv("COMPUTERNAME"); String compName = "SBEASTCAL1-30"; if(args.length > 0) { compName = args[0]; } new StudentClient(compName); } }

Ignore Space Show notes View

src/clients/StudentClient.java

package clients;

import constants.Constants;
import discovery.ServiceLocator;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.util.Timer;
import java.util.logging.Level;
import java.util.logging.Logger;
import network.MessageGenerator;
import network.RequestSender;

/**
 * The student's client for requesting help.
 * 
 * It adds a system tray icon that has a pop-up menu that the student can use to
 * request help or cancel their request. Requests are automatically canceled
 * when the student clicks the "exit" menu item, or the client is terminated by
 * the OS (via a shutdown hook) meaning there should never be requests in the
 * queue for students who have gone home.
 *
 * This aims to be both simple and robust, therefor the StudentClient stores no
 * state relating to requests, uses no persistent connections to the server,
 * and receives no information from the server.
 *
 * The client uses a multi-cast broadcast to discover the IP of the server,
 * which it then uses to send requests to the server.
 *
 * The wire protocol is very simple. A string in the form "request 23" is a
 * request for from the machine with ID 23, and "cancel 23" will cancel that
 * request. Sending multiple "request" commands or multiple "cancel" commands to
 * the server should cause no duplication or problems on the server and are
 * effectively ignored.
 *
 * @author Mark
 */
public class StudentClient {

private final PopupMenu trayPopopMenu = new PopupMenu();
   private final Image trayIconImage = Toolkit.getDefaultToolkit().getImage(getClass().getResource("/icon.png"));
   private final TrayIcon systemTrayIcon = new TrayIcon(trayIconImage, "Demo Call " + Constants.VERSION, trayPopopMenu);
   private final MessageGenerator generator = new MessageGenerator();

private String serverIp;
   private String machineId;
   private  RequestSender requestSender;

private boolean foundServer = false;

private final Thread shutDownHook = new Thread() {

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

};

public StudentClient(String compName) {
      try {
         createTrayMenu();

// not sure this is necessary but Windows is currently not exiting when the shutdown hook kicks in...
         this.shutDownHook.setDaemon(true);

Runtime.getRuntime().addShutdownHook(this.shutDownHook);

if (compName == null) {
            this.systemTrayIcon.displayMessage("Whoops", "COMPUTERNAME environment variable is not set.", TrayIcon.MessageType.ERROR);

// give user a chance to read message
            Thread.sleep(5000);

// shutdown
            exit();
         }

// lab machines usually have a COMPUTERNAME in the form "labname-machineId", eg SB316-23

// process computer name to extract lab and machine ID
         String[] nameBits = compName.split("-");

if (nameBits.length < 2) {
            this.systemTrayIcon.displayMessage("Whoops", "COMPUTERNAME environment variable is not in the expected format.", TrayIcon.MessageType.ERROR);

// give user a chance to read message
            Thread.sleep(5000);

// shutdown
            exit();
         }

String lab = nameBits[0];
         this.machineId = nameBits[1];

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

// find server IP (uses network multicast)
         this.serverIp =  new ServiceLocator().locateServer(lab);

// if we get to this point we got an IP so cancel timer
         timer.cancel();

this.foundServer = true;

this.requestSender = new RequestSender(serverIp);

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

}

private void createTrayMenu() {
      try {

this.systemTrayIcon.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();
            }

});

this.trayPopopMenu.add(request);
         this.trayPopopMenu.add(cancel);
         this.trayPopopMenu.addSeparator();
         this.trayPopopMenu.add(exit);

SystemTray.getSystemTray().add(this.systemTrayIcon);

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

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

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

private void exit() {
      this.cleanUp();

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

private void cleanUp() {
      // cancel any requests the student has made
      if(this.foundServer) {
         cancelRequest();
      }

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

@SuppressWarnings("ResultOfObjectAllocationIgnored")
   public static void main(String[] args) throws Exception {

//      String compName = System.getenv("COMPUTERNAME");
      String compName = "SBEASTCAL1-30";

if(args.length > 0) {
         compName = args[0];
      }

new StudentClient(compName);
   }
}

package clients;

import constants.Constants;
import discovery.ServiceLocator;
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.util.Timer;
import java.util.logging.Level;
import java.util.logging.Logger;
import network.MessageGenerator;
import network.RequestSender;

/**
 * The student's client for requesting help.  It adds a system that icon that has a pop-up menu that the student can use to request help or cancel
 * their request.  Requests are automatically canceled when the student clicks the "exit" menu item, or the client is terminated by the OS (via a
 * shutdown hook) meaning there should never be requests in the queue for students who have gone home.
 *
 * This aims to be both simple and robust, therefor the StudentClient stores no state relating to requests, and uses no persistent connections to the
 * server and receives no information from the server.
 *
 * The client uses a multi-cast broadcast to discover the IP of the server, which it then uses to sent requests to the server.
 *
 * The wire protocol is very simple.  A string in the form "request 23" is a request for from the machine with ID 23, and "cancel 23" will cancel that
 * request.  Sending multiple "request" commands or multiple "cancel" commands to the server should cause no duplication or problems on the server and
 * are effectively ignored.
 *
 * @author Mark
 */
public class StudentClient {

private String serverIp;
   private String machineId;
   private  RequestSender requestSender;

private boolean foundServer = false;

private final Thread shutDownHook = new Thread() {

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

};

public StudentClient(String compName) {
      try {
         createTrayMenu();

// not sure this is necessary but Windows is currently not exiting when the shutdown hook kicks in...
         this.shutDownHook.setDaemon(true);

Runtime.getRuntime().addShutdownHook(this.shutDownHook);

if (compName == null) {
            this.systemTrayIcon.displayMessage("Whoops", "COMPUTERNAME environment variable is not set.", TrayIcon.MessageType.ERROR);

// give user a chance to read message
            Thread.sleep(5000);

// shutdown
            exit();
         }

// lab machines usually have a COMPUTERNAME in the form "labname-machineId", eg SB316-23

// process computer name to extract lab and machine ID
         String[] nameBits = compName.split("-");

if (nameBits.length < 2) {
            this.systemTrayIcon.displayMessage("Whoops", "COMPUTERNAME environment variable is not in the expected format.", TrayIcon.MessageType.ERROR);

// give user a chance to read message
            Thread.sleep(5000);

// shutdown
            exit();
         }

String lab = nameBits[0];
         this.machineId = nameBits[1];

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

// find server IP (uses network multicast)
         this.serverIp =  new ServiceLocator().locateServer(lab);

// if we get to this point we got an IP so cancel timer
         timer.cancel();

this.foundServer = true;

this.requestSender = new RequestSender(serverIp);

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

}

private void createTrayMenu() {
      try {

this.systemTrayIcon.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();
            }

});

this.trayPopopMenu.add(request);
         this.trayPopopMenu.add(cancel);
         this.trayPopopMenu.addSeparator();
         this.trayPopopMenu.add(exit);

SystemTray.getSystemTray().add(this.systemTrayIcon);

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

private void exit() {
      this.cleanUp();

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

private void cleanUp() {
      // cancel any requests the student has made
      if(this.foundServer) {
         cancelRequest();
      }

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

@SuppressWarnings("ResultOfObjectAllocationIgnored")
   public static void main(String[] args) throws Exception {

//      String compName = System.getenv("COMPUTERNAME");
      String compName = "SBEASTCAL1-30";

if(args.length > 0) {
         compName = args[0];
      }

new StudentClient(compName);
   }
}

Ignore Space Show notes View src/constants/Constants.java
package constants; /** * * @author Mark / public class Constants { // version number for system public static final String VERSION = "3.2.0"; // randomly chosen multi-cast group public static final String BROADCAST_ADDRESS = "233.7.2.9"; // randomly chosen port public static final int PORT = 7321; // time between polls for tutor client (milliseconds) public static final int TUTOR_CLIENT_POLL = 5000; // exit code for clients if no server found public static final int EXIT_NO_SERVER_FOUND = 100; // exit code if no map found that matches current COMPUTERNAME env var public static final int EXIT_NO_MAP_FOUND = 200; } package constants; /* * * @author Mark */ public class Constants { // version number for system public static final String VERSION = "3.1.1"; // randomly chosen multi-cast group public static final String BROADCAST_ADDRESS = "233.7.2.9"; // randomly chosen port public static final int PORT = 7321; // time between polls for tutor client (milliseconds) public static final int TUTOR_CLIENT_POLL = 5000; // exit code for clients if no server found public static final int EXIT_NO_SERVER_FOUND = 100; // exit code if no map found that matches current COMPUTERNAME env var public static final int EXIT_NO_MAP_FOUND = 200; }

Ignore Space Show notes View

src/constants/Constants.java

Ignore Space Show notes View src/gui/processors/LabelProcessor.java
package gui.processors; import gui.QueuePanel; import java.awt.Color; import java.awt.Component; import java.awt.event.MouseAdapter; import java.util.; import javax.swing.JLabel; import javax.swing.JPanel; /* * * @author Mark / public abstract class LabelProcessor { private final Color requestCol = Color.GREEN; private final Color regularCol = new JLabel().getBackground(); private final Map<Integer, JLabel> labels = new HashMap<Integer, JLabel>(); // protected final Collection<Integer> queue = new ConcurrentLinkedQueue<Integer> (); protected final Collection<Integer> queue = new LinkedHashSet<Integer>(); public abstract MouseAdapter getMouseAdapter(); public void processLabels(JPanel panel) { processPanel(panel); } private void processPanel(JPanel panel) { for (Component component : panel.getComponents()) { if (component instanceof JLabel) { JLabel label = (JLabel) component; try { // component must be opaque so the background color can be set label.setOpaque(true); Integer id = new Integer(label.getText()); labels.put(id, label); label.addMouseListener(this.getMouseAdapter()); } catch (NumberFormatException ignored) { // ignored } } else if (component instanceof JPanel) { // found a panel that might contain buttons so recurse processPanel((JPanel) component); } } } public void request(final int id) { synchronized (queue) { queue.add(id); final String queueStr = queue.toString(); final JLabel label = labels.get(id); if (label != null) { label.setBackground(requestCol); } QueuePanel.getQueueLabel().setText(queueStr.substring(1, queueStr.length() - 1)); } } public synchronized void cancel(int id) { synchronized (queue) { queue.remove(id); String queueStr = queue.toString(); QueuePanel.getQueueLabel().setText(queueStr.substring(1, queueStr.length() - 1)); final JLabel label = labels.get(id); if (label != null) { label.setBackground(regularCol); } } } public Collection<Integer> getQueue() { synchronized (queue) { // creating a copy of queue to prevent ConcurrentModification errors return new ArrayList(queue); } } } package gui.processors; import gui.QueuePanel; import java.awt.Color; import java.awt.Component; import java.awt.EventQueue; import java.awt.event.MouseAdapter; import java.util.; import javax.swing.JLabel; import javax.swing.JPanel; /** * * @author Mark */ public abstract class LabelProcessor { private final Color requestCol = Color.GREEN; private final Color regularCol = new JLabel().getBackground(); private final Map<Integer, JLabel> labels = new HashMap<Integer, JLabel>(); protected final Set<Integer> queue = new LinkedHashSet<Integer>(); // protected final Collection<Integer> queue = new ConcurrentLinkedQueue(); public abstract MouseAdapter getMouseAdapter(); public void processLabels(JPanel panel) { processPanel(panel); } private void processPanel(JPanel panel) { for (Component component : panel.getComponents()) { if (component instanceof JLabel) { JLabel label = (JLabel) component; try { // component must be opaque so the background color can be set label.setOpaque(true); Integer id = new Integer(label.getText()); labels.put(id, label); label.addMouseListener(this.getMouseAdapter()); } catch (NumberFormatException ignored) { // ignored } } else if (component instanceof JPanel) { // found a panel that might contain buttons so recurse processPanel((JPanel) component); } } } public void request(final int id) { synchronized (queue) { queue.add(id); final String queueStr = queue.toString(); final JLabel label = labels.get(id); EventQueue.invokeLater(new Runnable() { public void run() { if (label != null) { label.setBackground(requestCol); } QueuePanel.getQueueLabel().setText(queueStr.substring(1, queueStr.length() - 1)); } }); } } public synchronized void cancel(int id) { synchronized (queue) { queue.remove(id); String queueStr = queue.toString(); QueuePanel.getQueueLabel().setText(queueStr.substring(1, queueStr.length() - 1)); final JLabel label = labels.get(id); EventQueue.invokeLater(new Runnable() { public void run() { if (label != null) { label.setBackground(regularCol); } } }); } } public Collection<Integer> getQueue() { synchronized (queue) { return queue; } } }

Ignore Space Show notes View

src/gui/processors/LabelProcessor.java

package gui.processors;

import gui.QueuePanel;
import java.awt.Color;
import java.awt.Component;
import java.awt.event.MouseAdapter;
import java.util.*;
import javax.swing.JLabel;
import javax.swing.JPanel;

/**
 *
 * @author Mark
 */
public abstract class LabelProcessor {

private final Color requestCol = Color.GREEN;
   private final Color regularCol = new JLabel().getBackground();
   private final Map<Integer, JLabel> labels = new HashMap<Integer, JLabel>();
//   protected final Collection<Integer> queue = new ConcurrentLinkedQueue<Integer> ();
   protected final Collection<Integer> queue = new LinkedHashSet<Integer>();

public abstract MouseAdapter getMouseAdapter();

public void processLabels(JPanel panel) {
      processPanel(panel);
   }

private void processPanel(JPanel panel) {
      for (Component component : panel.getComponents()) {

if (component instanceof JLabel) {
            JLabel label = (JLabel) component;
            try {
               // component must be opaque so the background color can be set
               label.setOpaque(true);
               Integer id = new Integer(label.getText());
               labels.put(id, label);

label.addMouseListener(this.getMouseAdapter());

} catch (NumberFormatException ignored) {
               // ignored
            }
         } else if (component instanceof JPanel) {
            // found a panel that might contain buttons so recurse
            processPanel((JPanel) component);
         }
      }
   }

public void request(final int id) {
      synchronized (queue) {
         queue.add(id);

final String queueStr = queue.toString();

final JLabel label = labels.get(id);

if (label != null) {
            label.setBackground(requestCol);
         }
         QueuePanel.getQueueLabel().setText(queueStr.substring(1, queueStr.length() - 1));
      }
   }

public synchronized void cancel(int id) {
      synchronized (queue) {
         queue.remove(id);

String queueStr = queue.toString();

QueuePanel.getQueueLabel().setText(queueStr.substring(1, queueStr.length() - 1));

final JLabel label = labels.get(id);

if (label != null) {
            label.setBackground(regularCol);
         }
      }
   }

public Collection<Integer> getQueue() {
      synchronized (queue) {
         // creating a copy of queue to prevent ConcurrentModification errors
         return new ArrayList(queue);
      }
   }
}

package gui.processors;

import gui.QueuePanel;
import java.awt.Color;
import java.awt.Component;
import java.awt.EventQueue;
import java.awt.event.MouseAdapter;
import java.util.*;
import javax.swing.JLabel;
import javax.swing.JPanel;

/**
 *
 * @author Mark
 */
public abstract class LabelProcessor {

private final Color requestCol = Color.GREEN;
   private final Color regularCol = new JLabel().getBackground();
   private final Map<Integer, JLabel> labels = new HashMap<Integer, JLabel>();
   protected final Set<Integer> queue = new LinkedHashSet<Integer>();
//   protected final Collection<Integer> queue = new ConcurrentLinkedQueue();

public abstract MouseAdapter getMouseAdapter();

public void processLabels(JPanel panel) {
      processPanel(panel);
   }

private void processPanel(JPanel panel) {
      for (Component component : panel.getComponents()) {

label.addMouseListener(this.getMouseAdapter());

public void request(final int id) {
      synchronized (queue) {
         queue.add(id);

final String queueStr = queue.toString();

final JLabel label = labels.get(id);

EventQueue.invokeLater(new Runnable() {

public void run() {
               if (label != null) {
                  label.setBackground(requestCol);
               }
               QueuePanel.getQueueLabel().setText(queueStr.substring(1, queueStr.length() - 1));
            }
         });
      }
   }

public synchronized void cancel(int id) {
      synchronized (queue) {
         queue.remove(id);

String queueStr = queue.toString();

QueuePanel.getQueueLabel().setText(queueStr.substring(1, queueStr.length() - 1));

final JLabel label = labels.get(id);

EventQueue.invokeLater(new Runnable() {

public void run() {
               if (label != null) {
                  label.setBackground(regularCol);
               }
            }
         });
      }
   }

public Collection<Integer> getQueue() {
      synchronized (queue) {
         return queue;
      }
   }
}

Ignore Space Show notes View src/gui/processors/TutorLabelProcessor.java
package gui.processors; import clients.StudentClient; import java.awt.event.MouseAdapter; import java.awt.event.MouseEvent; import java.util.ArrayList; import java.util.Collection; import java.util.logging.Level; import java.util.logging.Logger; import javax.swing.JLabel; import network.MessageGenerator; import network.RequestSender; /** * * @author Mark / public class TutorLabelProcessor extends LabelProcessor { private final String ip; public TutorLabelProcessor(String ip) { this.ip = ip; } @Override public MouseAdapter getMouseAdapter() { return new MouseAdapter() { @Override public void mousePressed(MouseEvent e) { super.mousePressed(e); JLabel label = (JLabel) e.getSource(); String machine = label.getText(); // send cancel request to server cancelRequest(machine); // cancel locally so change happens immediately cancel(new Integer(machine)); } }; } private void cancelRequest(String machine) { try { new RequestSender(ip).sendRequest(new MessageGenerator().cancelRequest(machine)); } catch (Exception ex) { Logger.getLogger(StudentClient.class.getName()).log(Level.SEVERE, "Error cancelling request", ex); } } public void update(Collection<Integer> queue) { clear(); for (Integer machine : new ArrayList<Integer>(queue)) { request(machine); } } private void clear() { for (Integer machine : new ArrayList<Integer>(queue)) { cancel(machine); } } } package gui.processors; import clients.StudentClient; import java.awt.event.MouseAdapter; import java.awt.event.MouseEvent; import java.util.LinkedHashSet; import java.util.Set; import java.util.logging.Level; import java.util.logging.Logger; import javax.swing.JLabel; import network.MessageGenerator; import network.RequestSender; /* * * @author Mark */ public class TutorLabelProcessor extends LabelProcessor { private final String ip; public TutorLabelProcessor(String ip) { this.ip = ip; } @Override public MouseAdapter getMouseAdapter() { return new MouseAdapter() { @Override public void mousePressed(MouseEvent e) { super.mousePressed(e); JLabel label = (JLabel) e.getSource(); String machine = label.getText(); // send cancel request to server cancelRequest(machine); // cancel locally so change happens immediately cancel(new Integer(machine)); } }; } private void cancelRequest(String machine) { try { new RequestSender(ip).sendRequest(new MessageGenerator().cancelRequest(machine)); } catch (Exception ex) { Logger.getLogger(StudentClient.class.getName()).log(Level.SEVERE, "Error cancelling request", ex); } } public void update(Set<Integer> queue) { clear(); // copy the queue so we don't get ConcurrentModificationExceptions in this iterator Set<Integer> copy = new LinkedHashSet<Integer>(queue); for (Integer machine : copy) { request(machine); } } private void clear() { // copy the queue so we don't get ConcurrentModificationExceptions in this iterator Set<Integer> copy = new LinkedHashSet<Integer>(queue); for (Integer machine : copy) { cancel(machine); } } }

Ignore Space Show notes View

src/gui/processors/TutorLabelProcessor.java

package gui.processors;

import clients.StudentClient;
import java.awt.event.MouseAdapter;
import java.awt.event.MouseEvent;
import java.util.ArrayList;
import java.util.Collection;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JLabel;
import network.MessageGenerator;
import network.RequestSender;

/**
 *
 * @author Mark
 */
public class TutorLabelProcessor extends LabelProcessor {

private final String ip;

public TutorLabelProcessor(String ip) {
      this.ip = ip;
   }

@Override
   public MouseAdapter getMouseAdapter() {
      return new MouseAdapter() {

@Override
         public void mousePressed(MouseEvent e) {
            super.mousePressed(e);
            JLabel label = (JLabel) e.getSource();
            String machine = label.getText();

// send cancel request to server
            cancelRequest(machine);

// cancel locally so change happens immediately
            cancel(new Integer(machine));
         }
      };
   }

private void cancelRequest(String machine) {
      try {
         new RequestSender(ip).sendRequest(new MessageGenerator().cancelRequest(machine));
      } catch (Exception ex) {
         Logger.getLogger(StudentClient.class.getName()).log(Level.SEVERE, "Error cancelling request", ex);
      }
   }

public void update(Collection<Integer> queue) {
      clear();

for (Integer machine : new ArrayList<Integer>(queue)) {
         request(machine);
      }
   }

private void clear() {
      for (Integer machine : new ArrayList<Integer>(queue)) {
         cancel(machine);
      }
   }   
   
 
   
}

package gui.processors;

import clients.StudentClient;
import java.awt.event.MouseAdapter;
import java.awt.event.MouseEvent;
import java.util.LinkedHashSet;
import java.util.Set;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JLabel;
import network.MessageGenerator;
import network.RequestSender;

/**
 *
 * @author Mark
 */
public class TutorLabelProcessor extends LabelProcessor {

private final String ip;

public TutorLabelProcessor(String ip) {
      this.ip = ip;
   }

@Override
   public MouseAdapter getMouseAdapter() {
      return new MouseAdapter() {

@Override
         public void mousePressed(MouseEvent e) {
            super.mousePressed(e);
            JLabel label = (JLabel) e.getSource();
            String machine = label.getText();

// send cancel request to server
            cancelRequest(machine);

// cancel locally so change happens immediately
            cancel(new Integer(machine));
         }
      };
   }

public void update(Set<Integer> queue) {
      clear();

// copy the queue so we don't get ConcurrentModificationExceptions in this iterator
      Set<Integer> copy = new LinkedHashSet<Integer>(queue);

for (Integer machine : copy) {
         request(machine);
      }
   }

private void clear() {
      // copy the queue so we don't get ConcurrentModificationExceptions in this iterator
      Set<Integer> copy = new LinkedHashSet<Integer>(queue);
      for (Integer machine : copy) {
         cancel(machine);
      }
   }   
   
}

Ignore Space Show notes View src/network/RequestSender.java
package network; import constants.Constants; import java.io.ObjectInputStream; import java.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.Socket; import java.util.Collection; import java.util.Collections; import java.util.logging.Level; import java.util.logging.Logger; /** * * @author Mark / public class RequestSender { private final String destinationIp; private final MessageGenerator messageGenerator = new MessageGenerator(); public RequestSender(String destinationIp) { this.destinationIp = destinationIp; } public void sendRequest(String request) { try { Socket socket = new Socket(destinationIp, Constants.PORT); PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); writer.println(request); writer.close(); socket.close(); } catch (Exception ex) { Logger.getLogger(RequestSender.class.getName()).log(Level.SEVERE, null, ex); } } @SuppressWarnings({"rawtypes", "unchecked"}) public Collection<Integer> requestQueue() { try { Socket socket = new Socket(destinationIp, Constants.PORT); PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); writer.println(messageGenerator.requestQueue()); writer.flush(); ObjectInputStream ois = new ObjectInputStream(socket.getInputStream()); Collection<Integer> response = (Collection<Integer>) ois.readObject(); writer.close(); ois.close(); socket.close(); return response; } catch (Exception ex) { Logger.getLogger(RequestSender.class.getName()).log(Level.SEVERE, null, ex); } return Collections.EMPTY_SET; } } package network; import constants.Constants; import java.io.ObjectInputStream; import java.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.Socket; import java.util.Collections; import java.util.Set; import java.util.logging.Level; import java.util.logging.Logger; /* * * @author Mark */ public class RequestSender { private final String destinationIp; public RequestSender(String destinationIp) { this.destinationIp = destinationIp; } public void sendRequest(String request) { try { Socket socket = new Socket(destinationIp, Constants.PORT); PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); writer.println(request); writer.flush(); writer.close(); socket.close(); } catch (Exception ex) { Logger.getLogger(RequestSender.class.getName()).log(Level.SEVERE, null, ex); } } @SuppressWarnings({"rawtypes", "unchecked"}) public Set<Integer> requestQueue() { try { Socket socket = new Socket(destinationIp, Constants.PORT); PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); writer.println(new MessageGenerator().requestQueue()); writer.flush(); ObjectInputStream ois = new ObjectInputStream(socket.getInputStream()); Set<Integer> response = (Set<Integer>) ois.readObject(); writer.close(); ois.close(); socket.close(); return response; } catch (Exception ex) { Logger.getLogger(RequestSender.class.getName()).log(Level.SEVERE, null, ex); } return Collections.EMPTY_SET; } }

Ignore Space Show notes View

src/network/RequestSender.java

package network;

import constants.Constants;
import java.io.ObjectInputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Collection;
import java.util.Collections;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author Mark
 */
public class RequestSender {

private final String destinationIp;
   private final MessageGenerator messageGenerator = new MessageGenerator();

public RequestSender(String destinationIp) {
      this.destinationIp = destinationIp;
   }

public void sendRequest(String request) {
      try {
         Socket socket = new Socket(destinationIp, Constants.PORT);
         PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
         writer.println(request);
         writer.close();
         socket.close();
      } catch (Exception ex) {
         Logger.getLogger(RequestSender.class.getName()).log(Level.SEVERE, null, ex);
      }
   }

@SuppressWarnings({"rawtypes", "unchecked"})
   public Collection<Integer> requestQueue() {
      try {
         Socket socket = new Socket(destinationIp, Constants.PORT);
         PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
         writer.println(messageGenerator.requestQueue());
         writer.flush();
         ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
         Collection<Integer> response = (Collection<Integer>) ois.readObject();
         writer.close();
         ois.close();
         socket.close();
         return response;
      } catch (Exception ex) {
         Logger.getLogger(RequestSender.class.getName()).log(Level.SEVERE, null, ex);
      }
      return Collections.EMPTY_SET;
   }

}

package network;

import constants.Constants;
import java.io.ObjectInputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Collections;
import java.util.Set;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author Mark
 */
public class RequestSender {

private final String destinationIp;

public RequestSender(String destinationIp) {
      this.destinationIp = destinationIp;
   }

public void sendRequest(String request) {
      try {
         Socket socket = new Socket(destinationIp, Constants.PORT);
         PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
         writer.println(request);
         writer.flush();
         writer.close();
         socket.close();
      } catch (Exception ex) {
         Logger.getLogger(RequestSender.class.getName()).log(Level.SEVERE, null, ex);
      }
   }

@SuppressWarnings({"rawtypes", "unchecked"})
   public Set<Integer> requestQueue() {
      try {
         Socket socket = new Socket(destinationIp, Constants.PORT);
         PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
         writer.println(new MessageGenerator().requestQueue());
         writer.flush();
         ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
         Set<Integer> response = (Set<Integer>) ois.readObject();
         writer.close();
         ois.close();
         socket.close();
         return response;
      } catch (Exception ex) {
         Logger.getLogger(RequestSender.class.getName()).log(Level.SEVERE, null, ex);
      }
      return Collections.EMPTY_SET;
   }

}

Ignore Space Show notes View src/server/ApplicationHandler.java
package server; import constants.Constants; import gui.processors.LabelProcessor; import java.net.ServerSocket; import java.net.Socket; import java.util.logging.Level; import java.util.logging.Logger; /** * * @author Mark / public class ApplicationHandler extends Thread { private final LabelProcessor processor; public ApplicationHandler(LabelProcessor processor) { this.setDaemon(true); this.processor = processor; } @Override public void run() { try { ServerSocket ss = new ServerSocket(Constants.PORT); while (true) { Socket socket = ss.accept(); new RequestThread(processor, socket).start(); } } catch (Exception ex) { Logger.getLogger(ApplicationHandler.class.getName()).log(Level.SEVERE, null, ex); } } } package server; import gui.processors.LabelProcessor; import java.net.ServerSocket; import java.net.Socket; import java.util.logging.Level; import java.util.logging.Logger; /* * * @author mark */ public class ApplicationHandler extends Thread { private final LabelProcessor processor; public ApplicationHandler(LabelProcessor processor) { this.setDaemon(true); this.processor = processor; } @Override public void run() { try { ServerSocket ss = new ServerSocket(7321); while (true) { Socket socket = ss.accept(); new RequestThread(processor, socket).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/RequestThread.java
package server; import gui.processors.LabelProcessor; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.ObjectOutputStream; import java.net.Socket; import java.util.logging.Level; import java.util.logging.Logger; /** * * @author geoma48p / public class RequestThread extends Thread { private final LabelProcessor processor; private final Socket socket; public RequestThread(LabelProcessor processor, Socket socket) { this.setDaemon(true); this.processor = processor; this.socket = socket; } @Override public void run() { try { BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); String message = reader.readLine(); if(message !=null) { // readLine returns null if buffer is empty processMessage(message); } socket.close(); } 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")) { processor.request(machineId); } else if (performative.equals("cancel")) { processor.cancel(machineId); } else if (performative.equals("queue")) { try { ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream()); oos.writeObject(processor.getQueue()); oos.close(); } catch (IOException ex) { Logger.getLogger(RequestThread.class.getName()).log(Level.SEVERE, null, ex); } } else { Logger.getLogger(RequestThread.class.getName()).log(Level.SEVERE, "Unknown command: {0}", performative); } } } package server; import gui.processors.LabelProcessor; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.ObjectOutputStream; import java.net.Socket; import java.util.logging.Level; import java.util.logging.Logger; /* * * @author geoma48p */ public class RequestThread extends Thread { private final LabelProcessor processor; private final Socket socket; public RequestThread(LabelProcessor processor, Socket socket) { this.setDaemon(true); this.processor = processor; this.socket = socket; } @Override public void run() { try { BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); String message = reader.readLine(); processMessage(message); socket.close(); } 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")) { processor.request(machineId); } else if (performative.equals("cancel")) { processor.cancel(machineId); } else if (performative.equals("queue")) { try { ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream()); oos.writeObject(processor.getQueue()); oos.close(); } catch (IOException ex) { Logger.getLogger(RequestThread.class.getName()).log(Level.SEVERE, null, ex); } } else { Logger.getLogger(RequestThread.class.getName()).log(Level.SEVERE, "Unknown performative: {0}", performative); } } }

Ignore Space Show notes View

src/server/RequestThread.java

package server;

import gui.processors.LabelProcessor;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;

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

private final LabelProcessor processor;
   private final Socket socket;

public RequestThread(LabelProcessor processor, Socket socket) {
      this.setDaemon(true);
      this.processor = processor;
      this.socket = socket;
   }

@Override
   public void run() {
      try {
         BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
         String message = reader.readLine();
         if(message !=null) {  // readLine returns null if buffer is empty
            processMessage(message);
         }
         socket.close();
      } 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")) {
         processor.request(machineId);
      } else if (performative.equals("cancel")) {
         processor.cancel(machineId);
      } else if (performative.equals("queue")) {
         try {
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject(processor.getQueue());
            oos.close();
         } catch (IOException ex) {
            Logger.getLogger(RequestThread.class.getName()).log(Level.SEVERE, null, ex);
         } 
      } else {
         Logger.getLogger(RequestThread.class.getName()).log(Level.SEVERE, "Unknown command: {0}", performative);
      }

}
}

package server;

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

private final LabelProcessor processor;
   private final Socket socket;

public RequestThread(LabelProcessor processor, Socket socket) {
      this.setDaemon(true);
      this.processor = processor;
      this.socket = socket;
   }

@Override
   public void run() {
      try {
         BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
         String message = reader.readLine();
         processMessage(message);
         socket.close();
      } 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]);

}
}

Ignore Space Show notes View src/server/Server.java
package server; import constants.Constants; import discovery.BroadcastResponder; import gui.Lab; import gui.LabRegistry; import gui.QueuePanel; import gui.processors.LabelProcessor; import gui.processors.ServerLabelProcessor; import java.awt.BorderLayout; import java.io.IOException; import javax.swing.JFrame; import javax.swing.JOptionPane; import javax.swing.JPanel; /** * * @author Mark / public class Server { public static void main(String[] args) throws IOException { // String compName = System.getenv("COMPUTERNAME"); String compName = "SBEASTCAL1-01"; if(args.length > 0) { compName = args[0]; } String[] nameBits = compName.split("-"); final String labName = nameBits[0]; JFrame frame = new JFrame(); frame.setLayout(new BorderLayout()); frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); LabRegistry registry = new LabRegistry(); Lab lab = registry.getLab(labName); if(lab == null) { JOptionPane.showMessageDialog(frame, "There is no map for this lab yet.", "No map", JOptionPane.ERROR_MESSAGE); System.exit(Constants.EXIT_NO_MAP_FOUND); } JPanel mapPanel = lab.getPanel(); LabelProcessor processor = new ServerLabelProcessor(); processor.processLabels(mapPanel); frame.setTitle(String.format("Democall %1s - Server (%1s)",Constants.VERSION, lab.getLabDescription())); frame.add(BorderLayout.NORTH, new QueuePanel()); frame.add(BorderLayout.CENTER, mapPanel); frame.pack(); frame.setVisible(true); new ApplicationHandler(processor).start(); new BroadcastResponder(labName).start(); } } / * To change this template, choose Tools \| Templates * and open the template in the editor. / package server; import constants.Constants; import discovery.BroadcastResponder; import gui.Lab; import gui.LabRegistry; import gui.QueuePanel; import gui.processors.LabelProcessor; import gui.processors.ServerLabelProcessor; import java.awt.BorderLayout; import java.io.IOException; import javax.swing.JFrame; import javax.swing.JOptionPane; import javax.swing.JPanel; /* * * @author geoma48p */ public class Server { public static void main(String[] args) throws IOException { // String compName = System.getenv("COMPUTERNAME"); String compName = "SBEASTCAL1-01"; if(args.length > 0) { compName = args[0]; } String[] nameBits = compName.split("-"); final String labName = nameBits[0]; JFrame frame = new JFrame(); frame.setLayout(new BorderLayout()); frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); LabRegistry registry = new LabRegistry(); Lab lab = registry.getLab(labName); if(lab == null) { JOptionPane.showMessageDialog(frame, "There is no map for this lab yet.", "No map", JOptionPane.ERROR_MESSAGE); System.exit(Constants.EXIT_NO_MAP_FOUND); } JPanel mapPanel = lab.getPanel(); LabelProcessor processor = new ServerLabelProcessor(); processor.processLabels(mapPanel); frame.setTitle(String.format("Democall %1s - Server (%1s)",Constants.VERSION, lab.getLabDescription())); frame.add(BorderLayout.NORTH, new QueuePanel()); frame.add(BorderLayout.CENTER, mapPanel); frame.pack(); frame.setVisible(true); new ApplicationHandler(processor).start(); new BroadcastResponder(labName).start(); } }

Ignore Space Show notes View

src/server/Server.java

package server;

import constants.Constants;
import discovery.BroadcastResponder;
import gui.Lab;
import gui.LabRegistry;
import gui.QueuePanel;
import gui.processors.LabelProcessor;
import gui.processors.ServerLabelProcessor;
import java.awt.BorderLayout;
import java.io.IOException;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JPanel;

/**
 *
 * @author Mark
 */
public class Server {

public static void main(String[] args) throws IOException {

//      String compName = System.getenv("COMPUTERNAME");
      String compName = "SBEASTCAL1-01";

if(args.length > 0) {
         compName = args[0];
      }

String[] nameBits = compName.split("-");
      final String labName = nameBits[0];

JFrame frame = new JFrame();
      frame.setLayout(new BorderLayout());
      frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

LabRegistry registry = new LabRegistry();
      Lab lab = registry.getLab(labName);

if(lab == null) {
          JOptionPane.showMessageDialog(frame, "There is no map for this lab yet.", "No map", JOptionPane.ERROR_MESSAGE);
          System.exit(Constants.EXIT_NO_MAP_FOUND);
      }

JPanel mapPanel = lab.getPanel();

LabelProcessor processor = new ServerLabelProcessor();
      processor.processLabels(mapPanel);

frame.setTitle(String.format("Democall %1s - Server (%1s)",Constants.VERSION, lab.getLabDescription()));
      frame.add(BorderLayout.NORTH, new QueuePanel());
      frame.add(BorderLayout.CENTER, mapPanel);
      frame.pack();
      frame.setVisible(true);

new ApplicationHandler(processor).start();
      new BroadcastResponder(labName).start();
   }
}

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

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

public static void main(String[] args) throws IOException {

//      String compName = System.getenv("COMPUTERNAME");
      String compName = "SBEASTCAL1-01";

if(args.length > 0) {
         compName = args[0];
      }

String[] nameBits = compName.split("-");
      final String labName = nameBits[0];

JFrame frame = new JFrame();
      frame.setLayout(new BorderLayout());
      frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

LabRegistry registry = new LabRegistry();
      Lab lab = registry.getLab(labName);

if(lab == null) {
          JOptionPane.showMessageDialog(frame, "There is no map for this lab yet.", "No map", JOptionPane.ERROR_MESSAGE);
          System.exit(Constants.EXIT_NO_MAP_FOUND);
      }

JPanel mapPanel = lab.getPanel();

LabelProcessor processor = new ServerLabelProcessor();
      processor.processLabels(mapPanel);

new ApplicationHandler(processor).start();
      new BroadcastResponder(labName).start();
   }
}

Show line notes below