Simplified the timeout when trying to find server. Now applies to all clients

mark.george / democall3

Browse code Simplified the timeout when trying to find server. Now applies to all clients - not just the student client. master
1 parent fce1eae commit 7361b4dc663fdcc0c4c6a1b6c3fe277bd0f9caa0 Mark authored on 22 Sep 2012

Patch

Showing 6 changed files

Ignore Space Show notes View src/clients/StudentClient.java
package clients; import constants.Constants; import discovery.computername.ComputerNameResolver; import discovery.computername.InvalidComputerNameException; import discovery.computername.OtagoComputerNameResolver; import discovery.server.ServiceLocator; import discovery.server.ServiceNotFoundException; 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 static final Logger LOG = Logger.getLogger(StudentClient.class.getName()); 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 machineId; private RequestSender requestSender; private boolean foundServer = false; private final Thread shutDownHook = new Thread() { @Override public void run() { cleanUp(); } }; public StudentClient(final ComputerNameResolver nameResolver) { 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); try { nameResolver.resolve(); } catch (InvalidComputerNameException ex) { this.systemTrayIcon.displayMessage("Whoops", ex.getMessage(), TrayIcon.MessageType.ERROR); // give user a chance to read message Thread.sleep(5000); // shutdown exit(); } final String lab = nameResolver.getLabName(); this.machineId = nameResolver.getMachineId(); // find server IP (uses network multicast) final String serverIp = new ServiceLocator().locateServer(lab); this.foundServer = true; this.requestSender = new RequestSender(serverIp); } catch (ServiceNotFoundException ex) { this.systemTrayIcon.displayMessage("Whoops", "Could not connect to server. Please try again and let the supervisor know if it continues to happen.", TrayIcon.MessageType.ERROR); } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } } private void createTrayMenu() { try { this.systemTrayIcon.setImageAutoSize(true); final MenuItem request = new MenuItem("Request Help"); request.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { makeRequest(); } }); final MenuItem cancel = new MenuItem("Cancel Request"); cancel.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { cancelRequest(); } }); final MenuItem exit = new MenuItem("Exit"); exit.addActionListener(new ActionListener() { public void actionPerformed(final 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) { LOG.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); LOG.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); LOG.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(final String[] args) { final String name = "SBEASTCAL1-30"; // final String name = args.length > 0 ? args[0] : null; final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "COMPUTERNAME"); new StudentClient(nameResolver); } } package clients; import constants.Constants; import discovery.computername.ComputerNameResolver; import discovery.computername.InvalidComputerNameException; import discovery.computername.OtagoComputerNameResolver; import discovery.server.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 static final Logger LOG = Logger.getLogger(StudentClient.class.getName()); 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 machineId; private RequestSender requestSender; private boolean foundServer = false; private final Thread shutDownHook = new Thread() { @Override public void run() { cleanUp(); } }; public StudentClient(final ComputerNameResolver nameResolver) { 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); try { nameResolver.resolve(); } catch (InvalidComputerNameException ex) { this.systemTrayIcon.displayMessage("Whoops", ex.getMessage(), TrayIcon.MessageType.ERROR); // give user a chance to read message Thread.sleep(5000); // shutdown exit(); } final String lab = nameResolver.getLabName(); this.machineId = nameResolver.getMachineId(); // create a timer to cause a timeout if server IP not found within 5 seconds final Timer timer = new Timer(); timer.schedule(new TimeoutTask(this.systemTrayIcon), 5000); // find server IP (uses network multicast) final String 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) { LOG.log(Level.SEVERE, null, ex); } } private void createTrayMenu() { try { this.systemTrayIcon.setImageAutoSize(true); final MenuItem request = new MenuItem("Request Help"); request.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { makeRequest(); } }); final MenuItem cancel = new MenuItem("Cancel Request"); cancel.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { cancelRequest(); } }); final MenuItem exit = new MenuItem("Exit"); exit.addActionListener(new ActionListener() { public void actionPerformed(final 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) { LOG.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); LOG.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); LOG.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(final String[] args) { final String name = "SBEASTCAL1-30"; // final String name = args.length > 0 ? args[0] : null; final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "COMPUTERNAME"); new StudentClient(nameResolver); } }

Ignore Space Show notes View

src/clients/StudentClient.java

package clients;

import constants.Constants;
import discovery.computername.ComputerNameResolver;
import discovery.computername.InvalidComputerNameException;
import discovery.computername.OtagoComputerNameResolver;
import discovery.server.ServiceLocator;
import discovery.server.ServiceNotFoundException;
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 static final Logger LOG = Logger.getLogger(StudentClient.class.getName());
   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 machineId;
   private RequestSender requestSender;
   private boolean foundServer = false;
   private final Thread shutDownHook = new Thread() {

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

public StudentClient(final ComputerNameResolver nameResolver) {
      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);

try {
            nameResolver.resolve();
         } catch (InvalidComputerNameException ex) {
            this.systemTrayIcon.displayMessage("Whoops", ex.getMessage(), TrayIcon.MessageType.ERROR);

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

// shutdown
            exit();
         }

final String lab = nameResolver.getLabName();
         this.machineId = nameResolver.getMachineId();

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

this.foundServer = true;

this.requestSender = new RequestSender(serverIp);

} catch (ServiceNotFoundException ex) {
         this.systemTrayIcon.displayMessage("Whoops", "Could not connect to server.  Please try again and let the supervisor know if it continues to happen.", TrayIcon.MessageType.ERROR);
      } catch (Exception ex) {
         LOG.log(Level.SEVERE, null, ex);
      }

}

private void createTrayMenu() {
      try {

this.systemTrayIcon.setImageAutoSize(true);

final MenuItem request = new MenuItem("Request Help");
         request.addActionListener(new ActionListener() {

public void actionPerformed(final ActionEvent e) {
               makeRequest();
            }
         });

final MenuItem cancel = new MenuItem("Cancel Request");
         cancel.addActionListener(new ActionListener() {

public void actionPerformed(final ActionEvent e) {
               cancelRequest();
            }
         });

final MenuItem exit = new MenuItem("Exit");
         exit.addActionListener(new ActionListener() {

public void actionPerformed(final 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) {
         LOG.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);
         LOG.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);
         LOG.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(final String[] args) {

final String name = "SBEASTCAL1-30";

//      final String name = args.length > 0 ? args[0] : null;

final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "COMPUTERNAME");

new StudentClient(nameResolver);
   }
}

package clients;

import constants.Constants;
import discovery.computername.ComputerNameResolver;
import discovery.computername.InvalidComputerNameException;
import discovery.computername.OtagoComputerNameResolver;
import discovery.server.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 static final Logger LOG = Logger.getLogger(StudentClient.class.getName());

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 machineId;
   private  RequestSender requestSender;

private boolean foundServer = false;

private final Thread shutDownHook = new Thread() {

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

};
   
   public StudentClient(final ComputerNameResolver nameResolver) {
      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);

try {
            nameResolver.resolve();
         } catch (InvalidComputerNameException ex) {
            this.systemTrayIcon.displayMessage("Whoops", ex.getMessage(), TrayIcon.MessageType.ERROR);

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

// shutdown
            exit();
         }

final String lab = nameResolver.getLabName();
         this.machineId = nameResolver.getMachineId();

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

// find server IP (uses network multicast)
         final String 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) {
         LOG.log(Level.SEVERE, null, ex);
      }

}

private void createTrayMenu() {
      try {

this.systemTrayIcon.setImageAutoSize(true);

final MenuItem request = new MenuItem("Request Help");
         request.addActionListener(new ActionListener() {

public void actionPerformed(final ActionEvent e) {
               makeRequest();
            }

});

final MenuItem cancel = new MenuItem("Cancel Request");
         cancel.addActionListener(new ActionListener() {

public void actionPerformed(final ActionEvent e) {
               cancelRequest();
            }

});

final MenuItem exit = new MenuItem("Exit");
         exit.addActionListener(new ActionListener() {

public void actionPerformed(final 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) {
         LOG.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(final String[] args) {

final String name = "SBEASTCAL1-30";

//      final String name = args.length > 0 ? args[0] : null;
      
      
      final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "COMPUTERNAME");

new StudentClient(nameResolver);
   }
   
}

Show notes View src/clients/TimeoutTask.java 100644 → 0
package clients; import constants.Constants; import java.awt.SystemTray; import java.awt.TrayIcon; import java.util.TimerTask; /** * * @author Mark */ public class TimeoutTask extends TimerTask { private final TrayIcon systemTrayIcon; public TimeoutTask(final TrayIcon trayIcon) { super(); this.systemTrayIcon = trayIcon; } @Override public void run() { systemTrayIcon.displayMessage("Connection Error", "Could not connect to server. Please try again, and let supervisor know if it continues to happen.", TrayIcon.MessageType.ERROR); try { Thread.sleep(5000); } catch (InterruptedException ex) { //ignored } // remove the tray icon from the system tray SystemTray.getSystemTray().remove(systemTrayIcon); System.exit(Constants.EXIT_NO_SERVER_FOUND); } }

Show notes View

src/clients/TimeoutTask.java 100644 → 0

Ignore Space Show notes View src/clients/TutorClient.java
package clients; import constants.Constants; import discovery.computername.ComputerNameResolver; import discovery.computername.InvalidComputerNameException; import discovery.computername.OtagoComputerNameResolver; import discovery.server.ServiceLocator; import discovery.server.ServiceNotFoundException; import gui.Lab; import gui.LabRegistry; import gui.QueuePanel; import gui.processors.TutorLabelProcessor; import java.awt.BorderLayout; import java.util.Collection; import java.util.Timer; import java.util.TimerTask; import java.util.logging.Level; import java.util.logging.Logger; import javax.swing.JFrame; import javax.swing.JOptionPane; import javax.swing.JPanel; import network.RequestSender; /** * * @author Mark / public class TutorClient { private static final Logger LOG = Logger.getLogger(TutorClient.class.getName()); private String serverIp; @SuppressWarnings("rawtypes") public TutorClient(final ComputerNameResolver nameResolver) { JFrame frame = null; try { nameResolver.resolve(); String labName = nameResolver.getLabName(); final LabRegistry registry = new LabRegistry(); final Lab[] labs = registry.getLabs().toArray(new Lab[registry.getLabs().size()]); final Lab currentLab = registry.getLab(labName); final Lab lab = (Lab) JOptionPane.showInputDialog(null, "Which lab?", "Which lab?", JOptionPane.QUESTION_MESSAGE, null, labs, currentLab); if (lab == null) { System.exit(0); } else { labName = lab.getLabName(); } serverIp = new ServiceLocator().locateServer(labName); frame = new JFrame(); frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); frame.setAlwaysOnTop(true); final JPanel mapPanel = lab.getPanel(); final TutorLabelProcessor processor = new TutorLabelProcessor(serverIp); processor.processLabels(mapPanel); frame.setTitle(String.format("Democall %1s - Tutor Client (%1s)", Constants.VERSION, lab.getLabDescription())); frame.setLayout(new BorderLayout()); frame.add(BorderLayout.NORTH, new QueuePanel()); frame.add(BorderLayout.CENTER, mapPanel); frame.pack(); frame.setVisible(true); final Timer timer = new Timer(true); timer.scheduleAtFixedRate(new TimerTask() { @Override public void run() { final Collection<Integer> queue = new RequestSender(serverIp).requestQueue(); processor.update(queue); } }, 0, Constants.TUTOR_CLIENT_POLL); } catch (InvalidComputerNameException ex) { JOptionPane.showMessageDialog(frame, ex.getMessage(), "Error getting computer name.", JOptionPane.ERROR_MESSAGE); } catch (ServiceNotFoundException ex) { JOptionPane.showMessageDialog(frame, "Could not connect to server.", "Connection error", JOptionPane.ERROR_MESSAGE); } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } } @SuppressWarnings("ResultOfObjectAllocationIgnored") public static void main(final String[] args) { final String name = "SBEASTCAL1-31"; // final String name = args.length > 0 ? args[0] : null; final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "COMPUTERNAME"); new TutorClient(nameResolver); } } package clients; import constants.Constants; import discovery.computername.ComputerNameResolver; import discovery.computername.InvalidComputerNameException; import discovery.computername.OtagoComputerNameResolver; import discovery.server.ServiceLocator; import gui.Lab; import gui.LabRegistry; import gui.QueuePanel; import gui.processors.TutorLabelProcessor; import java.awt.BorderLayout; import java.util.Collection; import java.util.Timer; import java.util.TimerTask; import java.util.logging.Level; import java.util.logging.Logger; import javax.swing.JFrame; import javax.swing.JOptionPane; import javax.swing.JPanel; import network.RequestSender; /* * * @author Mark */ public class TutorClient { private static final Logger LOG = Logger.getLogger(TutorClient.class.getName()); private String serverIp; @SuppressWarnings("rawtypes") public TutorClient(final ComputerNameResolver nameResolver) { JFrame frame = null; try { nameResolver.resolve(); String labName = nameResolver.getLabName(); final LabRegistry registry = new LabRegistry(); final Lab[] labs = registry.getLabs().toArray(new Lab[registry.getLabs().size()]); final Lab currentLab = registry.getLab(labName); final Lab lab = (Lab) JOptionPane.showInputDialog(null, "Which lab?", "Which lab?", JOptionPane.QUESTION_MESSAGE, null, labs, currentLab); if (lab == null) { System.exit(0); } else { labName = lab.getLabName(); } serverIp = new ServiceLocator().locateServer(labName); frame = new JFrame(); frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); frame.setAlwaysOnTop(true); final JPanel mapPanel = lab.getPanel(); final TutorLabelProcessor processor = new TutorLabelProcessor(serverIp); processor.processLabels(mapPanel); frame.setTitle(String.format("Democall %1s - Tutor Client (%1s)", Constants.VERSION, lab.getLabDescription())); frame.setLayout(new BorderLayout()); frame.add(BorderLayout.NORTH, new QueuePanel()); frame.add(BorderLayout.CENTER, mapPanel); frame.pack(); frame.setVisible(true); final Timer timer = new Timer(true); timer.scheduleAtFixedRate(new TimerTask() { @Override public void run() { final Collection<Integer> queue = new RequestSender(serverIp).requestQueue(); processor.update(queue); } }, 0, Constants.TUTOR_CLIENT_POLL); } catch (InvalidComputerNameException ex) { JOptionPane.showMessageDialog(frame, ex.getMessage(), "Error getting computer name", JOptionPane.ERROR_MESSAGE); } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } } @SuppressWarnings("ResultOfObjectAllocationIgnored") public static void main(final String[] args) { final String name = "SBEASTCAL1-31"; // final String name = args.length > 0 ? args[0] : null; final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "COMPUTERNAME"); new TutorClient(nameResolver); } }

Ignore Space Show notes View

src/clients/TutorClient.java

package clients;

import constants.Constants;
import discovery.computername.ComputerNameResolver;
import discovery.computername.InvalidComputerNameException;
import discovery.computername.OtagoComputerNameResolver;
import discovery.server.ServiceLocator;
import discovery.server.ServiceNotFoundException;
import gui.Lab;
import gui.LabRegistry;
import gui.QueuePanel;
import gui.processors.TutorLabelProcessor;
import java.awt.BorderLayout;
import java.util.Collection;
import java.util.Timer;
import java.util.TimerTask;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import network.RequestSender;

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

private static final Logger LOG = Logger.getLogger(TutorClient.class.getName());
   
   private String serverIp;

@SuppressWarnings("rawtypes")
   public TutorClient(final ComputerNameResolver nameResolver) {

JFrame frame = null;
      
      try {
         nameResolver.resolve();
         
         String labName = nameResolver.getLabName();

final LabRegistry registry = new LabRegistry();
         final Lab[] labs = registry.getLabs().toArray(new Lab[registry.getLabs().size()]);
         final Lab currentLab = registry.getLab(labName);
         
         final Lab lab = (Lab) JOptionPane.showInputDialog(null, "Which lab?", "Which lab?",  JOptionPane.QUESTION_MESSAGE, null, labs, currentLab);
         
         if (lab == null) {
            System.exit(0);
         } else {
            labName = lab.getLabName();
         }

serverIp = new ServiceLocator().locateServer(labName);
         frame = new JFrame();
         frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
         frame.setAlwaysOnTop(true);
         final JPanel mapPanel = lab.getPanel();
         final TutorLabelProcessor processor = new TutorLabelProcessor(serverIp);
         processor.processLabels(mapPanel);
         frame.setTitle(String.format("Democall %1s - Tutor Client (%1s)", Constants.VERSION, lab.getLabDescription()));
         frame.setLayout(new BorderLayout());
         frame.add(BorderLayout.NORTH, new QueuePanel());
         frame.add(BorderLayout.CENTER, mapPanel);
         frame.pack();
         frame.setVisible(true);

final Timer timer = new Timer(true);
         timer.scheduleAtFixedRate(new TimerTask() {

@Override
            public void run() {
               final Collection<Integer> queue = new RequestSender(serverIp).requestQueue();
               processor.update(queue);
            }
         }, 0, Constants.TUTOR_CLIENT_POLL);

} catch (InvalidComputerNameException ex) {
         JOptionPane.showMessageDialog(frame, ex.getMessage(), "Error getting computer name.", JOptionPane.ERROR_MESSAGE);
      } catch (ServiceNotFoundException ex) {
         JOptionPane.showMessageDialog(frame, "Could not connect to server.", "Connection error", JOptionPane.ERROR_MESSAGE);
      } catch (Exception ex) {
         LOG.log(Level.SEVERE, null, ex);
      }
   }

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

final String name = "SBEASTCAL1-31";

//      final String name = args.length > 0 ? args[0] : null;
      
      
      final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "COMPUTERNAME");

new TutorClient(nameResolver);
   }

}

package clients;

import constants.Constants;
import discovery.computername.ComputerNameResolver;
import discovery.computername.InvalidComputerNameException;
import discovery.computername.OtagoComputerNameResolver;
import discovery.server.ServiceLocator;
import gui.Lab;
import gui.LabRegistry;
import gui.QueuePanel;
import gui.processors.TutorLabelProcessor;
import java.awt.BorderLayout;
import java.util.Collection;
import java.util.Timer;
import java.util.TimerTask;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import network.RequestSender;

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

private static final Logger LOG = Logger.getLogger(TutorClient.class.getName());
   
   private String serverIp;

@SuppressWarnings("rawtypes")
   public TutorClient(final ComputerNameResolver nameResolver) {

JFrame frame = null;
      
      try {
         nameResolver.resolve();
         
         String labName = nameResolver.getLabName();

final Timer timer = new Timer(true);
         timer.scheduleAtFixedRate(new TimerTask() {

} catch (InvalidComputerNameException ex) {
         JOptionPane.showMessageDialog(frame, ex.getMessage(), "Error getting computer name", JOptionPane.ERROR_MESSAGE);
      } catch (Exception ex) {
         LOG.log(Level.SEVERE, null, ex);
      }
   }

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

final String name = "SBEASTCAL1-31";

//      final String name = args.length > 0 ? args[0] : null;
      
      
      final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "COMPUTERNAME");

new TutorClient(nameResolver);
   }

}

Ignore Space Show notes View src/constants/Constants.java
package constants; /** * * @author Mark / public final class Constants { private 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; // amount of time the service locator waits for a response from server public static final int SERVICE_LOCATOR_TIMEOUT = 5000; // milliseconds } package constants; /* * * @author Mark */ public final class Constants { private 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; }

Ignore Space Show notes View

src/constants/Constants.java

Ignore Space Show notes View src/discovery/server/ServiceLocator.java
package discovery.server; import constants.Constants; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketTimeoutException; import java.util.logging.Level; import java.util.logging.Logger; /** * * @author Mark / public class ServiceLocator { private static final Logger LOG = Logger.getLogger(ServiceLocator.class.getName()); /* * Send a multi-cast request for any democall servers. Server should respond * with its IP address. * * @param lab The lab in which to search for a server. * @return IP address of server * @throws Exception / public String locateServer(final String lab) { try { final DatagramSocket socket = new DatagramSocket(); socket.setSoTimeout(Constants.SERVICE_LOCATOR_TIMEOUT); final InetAddress address = InetAddress.getByName(Constants.BROADCAST_ADDRESS); final byte[] data = lab.getBytes(); final int port = Constants.PORT; socket.send(new DatagramPacket(data, data.length, address, port)); final byte[] response = new byte[256]; final DatagramPacket packet = new DatagramPacket(response, response.length); socket.receive(packet); final String receivedIp = new String(packet.getData()).trim(); socket.close(); return receivedIp; } catch(SocketTimeoutException ex) { throw new ServiceNotFoundException(); } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } return null; } } package discovery.server; import constants.Constants; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.util.logging.Level; import java.util.logging.Logger; /* * * @author Mark / public class ServiceLocator { private static final Logger LOG = Logger.getLogger(ServiceLocator.class.getName()); /* * Send a multi-cast request for any democall servers. Server should respond * with its IP address. * * @param lab The lab in which to search for a server. * @return IP address of server * @throws Exception */ public String locateServer(final String lab) { try { final DatagramSocket socket = new DatagramSocket(); final InetAddress address = InetAddress.getByName(Constants.BROADCAST_ADDRESS); final byte[] data = lab.getBytes(); final int port = Constants.PORT; socket.send(new DatagramPacket(data, data.length, address, port)); final byte[] response = new byte[256]; final DatagramPacket packet = new DatagramPacket(response, response.length); socket.receive(packet); final String receivedIp = new String(packet.getData()).trim(); socket.close(); return receivedIp; } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } return null; } }

Ignore Space Show notes View

src/discovery/server/ServiceLocator.java

package discovery.server;

import constants.Constants;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketTimeoutException;
import java.util.logging.Level;
import java.util.logging.Logger;

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

private static final Logger LOG = Logger.getLogger(ServiceLocator.class.getName());   
   
   /**
    * Send a multi-cast request for any democall servers.  Server should respond
    * with its IP address.
    *
    * @param lab The lab in which to search for a server.
    * @return IP address of server
    * @throws Exception
    */
   public String locateServer(final String lab) {
      try {
         final DatagramSocket socket = new DatagramSocket();
         
         socket.setSoTimeout(Constants.SERVICE_LOCATOR_TIMEOUT);
         
         final InetAddress address = InetAddress.getByName(Constants.BROADCAST_ADDRESS);
         final byte[] data = lab.getBytes();
         final int port = Constants.PORT;
         
         socket.send(new DatagramPacket(data, data.length, address, port));
         final byte[] response = new byte[256];
         final DatagramPacket packet = new DatagramPacket(response, response.length);

socket.receive(packet);
         final String receivedIp = new String(packet.getData()).trim();
         socket.close();
         return receivedIp;
      } catch(SocketTimeoutException ex) {
         throw new ServiceNotFoundException();
      } catch (Exception ex) {
         LOG.log(Level.SEVERE, null, ex);
      }
      return null;
   }

}

package discovery.server;

import constants.Constants;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.logging.Level;
import java.util.logging.Logger;

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

private static final Logger LOG = Logger.getLogger(ServiceLocator.class.getName());   
   
   /**
    * Send a multi-cast request for any democall servers.  Server should respond
    * with its IP address.
    *
    * @param lab The lab in which to search for a server.
    * @return IP address of server
    * @throws Exception
    */
   public String locateServer(final String lab) {
      try {
         final DatagramSocket socket = new DatagramSocket();
         final InetAddress address = InetAddress.getByName(Constants.BROADCAST_ADDRESS);
         final byte[] data = lab.getBytes();
         final int port = Constants.PORT;
         socket.send(new DatagramPacket(data, data.length, address, port));
         final byte[] response = new byte[256];
         final DatagramPacket packet = new DatagramPacket(response, response.length);
         socket.receive(packet);
         final String receivedIp = new String(packet.getData()).trim();
         socket.close();
         return receivedIp;
      } catch (Exception ex) {
         LOG.log(Level.SEVERE, null, ex);
      }
      return null;
   }

}

Ignore Space Show notes View src/discovery/server/ServiceNotFoundException.java 0 → 100644
package discovery.server; /** * @author Mark */ public class ServiceNotFoundException extends RuntimeException { }

Show line notes below