Browse code Moved some packages prior to switch to JMS. master
1 parent f9ee697 commit df4a127a7f4806561505443216274be3b763c791 geoma48p authored on 20 Jul 2015

Showing 19 changed files

• nbproject/project.properties
• src/clients/StudentClient.java
• src/clients/TutorClient.java
• src/discovery/server/BroadcastResponder.java
• src/discovery/server/KnownClients.java
• src/discovery/server/ServiceLocator.java
• src/discovery/server/ServiceNotFoundException.java
• src/discovery/server/multicast/BroadcastResponder.java
• src/discovery/server/multicast/KnownClients.java
• src/discovery/server/multicast/ServiceLocator.java
• src/discovery/server/multicast/ServiceNotFoundException.java
• src/gui/processors/RequestProcessor.java
• src/server/ApplicationHandler.java
• src/server/RequestThread.java
• src/server/Server.java
• src/server/sockets/ApplicationHandler.java
• src/server/sockets/RequestThread.java
• src/server/sockets/Server.java
• tests/BroadcasterTest.java

Ignore Space Show notes View nbproject/project.properties

annotation.processing.enabled=true annotation.processing.enabled.in.editor=false annotation.processing.processors.list= annotation.processing.run.all.processors=true application.title=democall3 application.vendor=geoma48p build.classes.dir=${build.dir}/classes build.classes.excludes=**/*.java,**/*.form # This directory is removed when the project is cleaned: build.dir=build build.generated.dir=${build.dir}/generated build.generated.sources.dir=${build.dir}/generated-sources # Only compile against the classpath explicitly listed here: build.sysclasspath=ignore build.test.classes.dir=${build.dir}/test/classes build.test.results.dir=${build.dir}/test/results # Uncomment to specify the preferred debugger connection transport: #debug.transport=dt_socket debug.classpath=\ ${run.classpath} debug.test.classpath=\ ${run.test.classpath} # This directory is removed when the project is cleaned: dist.dir=dist dist.jar=${dist.dir}/democall3.jar dist.javadoc.dir=${dist.dir}/javadoc endorsed.classpath= excludes= includes=** jar.compress=false javac.classpath= # Space-separated list of extra javac options javac.compilerargs= javac.deprecation=false javac.processorpath=\ ${javac.classpath} javac.source=1.6 javac.target=1.6 javac.test.classpath=\ ${javac.classpath}:\ ${build.classes.dir} javadoc.additionalparam= javadoc.author=false javadoc.encoding=${source.encoding} javadoc.noindex=false javadoc.nonavbar=false javadoc.notree=false javadoc.private=false javadoc.splitindex=true javadoc.use=true javadoc.version=false javadoc.windowtitle= main.class=server.sockets.Server manifest.file=manifest.mf meta.inf.dir=${src.dir}/META-INF mkdist.disabled=false platform.active=default_platform run.classpath=\ ${javac.classpath}:\ ${build.classes.dir} run.test.classpath=\ ${javac.test.classpath}:\ ${build.test.classes.dir} source.encoding=UTF-8 src.dir=src test.tests.dir=tests annotation.processing.enabled=true annotation.processing.enabled.in.editor=false annotation.processing.processors.list= annotation.processing.run.all.processors=true application.title=democall3 application.vendor=geoma48p build.classes.dir=${build.dir}/classes build.classes.excludes=**/*.java,**/*.form # This directory is removed when the project is cleaned: build.dir=build build.generated.dir=${build.dir}/generated build.generated.sources.dir=${build.dir}/generated-sources # Only compile against the classpath explicitly listed here: build.sysclasspath=ignore build.test.classes.dir=${build.dir}/test/classes build.test.results.dir=${build.dir}/test/results # Uncomment to specify the preferred debugger connection transport: #debug.transport=dt_socket debug.classpath=\ ${run.classpath} debug.test.classpath=\ ${run.test.classpath} # This directory is removed when the project is cleaned: dist.dir=dist dist.jar=${dist.dir}/democall3.jar dist.javadoc.dir=${dist.dir}/javadoc endorsed.classpath= excludes= includes=** jar.compress=false javac.classpath= # Space-separated list of extra javac options javac.compilerargs= javac.deprecation=false javac.processorpath=\ ${javac.classpath} javac.source=1.6 javac.target=1.6 javac.test.classpath=\ ${javac.classpath}:\ ${build.classes.dir} javadoc.additionalparam= javadoc.author=false javadoc.encoding=${source.encoding} javadoc.noindex=false javadoc.nonavbar=false javadoc.notree=false javadoc.private=false javadoc.splitindex=true javadoc.use=true javadoc.version=false javadoc.windowtitle= main.class=server.Server manifest.file=manifest.mf meta.inf.dir=${src.dir}/META-INF mkdist.disabled=false platform.active=default_platform run.classpath=\ ${javac.classpath}:\ ${build.classes.dir} run.test.classpath=\ ${javac.test.classpath}:\ ${build.test.classes.dir} source.encoding=UTF-8 src.dir=src test.tests.dir=tests

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.multicast.ServiceLocator; import discovery.server.multicast.ServiceNotFoundException; import java.awt.*; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; 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.systemTrayIcon.displayMessage("Yay", "Server found: " +serverIp, TrayIcon.MessageType.INFO); 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 requestHelp = new MenuItem("Request Help"); requestHelp.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { helpRequest(); } }); final MenuItem requestMarking = new MenuItem("Request Marking"); requestMarking.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { markingRequest(); } }); final MenuItem cancelHelp = new MenuItem("Cancel Help"); cancelHelp.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { cancelHelp(); } }); final MenuItem cancelMarking = new MenuItem("Cancel Marking"); cancelMarking.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { cancelMarking(); } }); final MenuItem cancelAll = new MenuItem("Cancel All Requests"); cancelAll.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { cancelAll(); } }); final MenuItem exit = new MenuItem("Exit"); exit.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { exit(); } }); this.trayPopopMenu.add(requestHelp); this.trayPopopMenu.add(cancelHelp); this.trayPopopMenu.addSeparator(); this.trayPopopMenu.add(requestMarking); this.trayPopopMenu.add(cancelMarking); this.trayPopopMenu.addSeparator(); this.trayPopopMenu.add(cancelAll); this.trayPopopMenu.addSeparator(); this.trayPopopMenu.add(exit); SystemTray.getSystemTray().add(this.systemTrayIcon); } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } } private void helpRequest() { 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 markingRequest() { try { requestSender.sendRequest(generator.requestMarking(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 cancelHelp() { try { requestSender.sendRequest(generator.cancelHelp(machineId)); systemTrayIcon.displayMessage("Request removed", "Your request has been removed from 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 cancelMarking() { try { requestSender.sendRequest(generator.cancelMarking(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 cancelAll() { try { requestSender.sendRequest(generator.cancelHelp(machineId)); requestSender.sendRequest(generator.cancelMarking(machineId)); systemTrayIcon.displayMessage("All requests removeds", "All of your request have been removed from the queues.", 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) { cancelAll(); } // remove the tray icon from the system tray SystemTray.getSystemTray().remove(systemTrayIcon); } @SuppressWarnings("ResultOfObjectAllocationIgnored") public static void main(final String[] args) { // System.out.println("Student Client"); // final String name = "SB318-15"; // final String name = "SB317-10"; // final String name = "SBEASTCAL1-30"; // final String name = "SB316-15"; final String name = args.length > 0 ? args[0] : null; final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "CLIENTNAME"); 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 discovery.server.ServiceNotFoundException; import java.awt.*; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; 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.systemTrayIcon.displayMessage("Yay", "Server found: " +serverIp, TrayIcon.MessageType.INFO); 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 requestHelp = new MenuItem("Request Help"); requestHelp.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { helpRequest(); } }); final MenuItem requestMarking = new MenuItem("Request Marking"); requestMarking.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { markingRequest(); } }); final MenuItem cancelHelp = new MenuItem("Cancel Help"); cancelHelp.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { cancelHelp(); } }); final MenuItem cancelMarking = new MenuItem("Cancel Marking"); cancelMarking.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { cancelMarking(); } }); final MenuItem cancelAll = new MenuItem("Cancel All Requests"); cancelAll.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { cancelAll(); } }); final MenuItem exit = new MenuItem("Exit"); exit.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { exit(); } }); this.trayPopopMenu.add(requestHelp); this.trayPopopMenu.add(cancelHelp); this.trayPopopMenu.addSeparator(); this.trayPopopMenu.add(requestMarking); this.trayPopopMenu.add(cancelMarking); this.trayPopopMenu.addSeparator(); this.trayPopopMenu.add(cancelAll); this.trayPopopMenu.addSeparator(); this.trayPopopMenu.add(exit); SystemTray.getSystemTray().add(this.systemTrayIcon); } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } } private void helpRequest() { 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 markingRequest() { try { requestSender.sendRequest(generator.requestMarking(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 cancelHelp() { try { requestSender.sendRequest(generator.cancelHelp(machineId)); systemTrayIcon.displayMessage("Request removed", "Your request has been removed from 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 cancelMarking() { try { requestSender.sendRequest(generator.cancelMarking(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 cancelAll() { try { requestSender.sendRequest(generator.cancelHelp(machineId)); requestSender.sendRequest(generator.cancelMarking(machineId)); systemTrayIcon.displayMessage("All requests removeds", "All of your request have been removed from the queues.", 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) { cancelAll(); } // remove the tray icon from the system tray SystemTray.getSystemTray().remove(systemTrayIcon); } @SuppressWarnings("ResultOfObjectAllocationIgnored") public static void main(final String[] args) { // System.out.println("Student Client"); // final String name = "SB318-15"; // final String name = "SB317-10"; // final String name = "SBEASTCAL1-30"; // final String name = "SB316-15"; final String name = args.length > 0 ? args[0] : null; final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "CLIENTNAME"); new StudentClient(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.multicast.ServiceLocator; import discovery.server.multicast.ServiceNotFoundException; import gui.Lab; import gui.LabRegistry; import gui.QueuePanel; import gui.processors.TutorLabelProcessor; import java.awt.event.ComponentAdapter; import java.awt.event.ComponentEvent; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.Socket; import java.util.LinkedHashSet; import java.util.logging.Level; import java.util.logging.Logger; import javax.sound.sampled.AudioInputStream; import javax.sound.sampled.AudioSystem; import javax.sound.sampled.Clip; import javax.swing.GroupLayout; import javax.swing.JFrame; import javax.swing.JOptionPane; import javax.swing.JPanel; import javax.swing.LayoutStyle; import network.RequestSender; /** * * @author Mark */ public class TutorClient { private static final Logger LOG = Logger.getLogger(TutorClient.class.getName()); private TutorLabelProcessor processor; private String serverIp; private Clip beep; @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(); QueuePanel helpPanel = new QueuePanel(new LinkedHashSet()); QueuePanel markingPanel = new QueuePanel(new LinkedHashSet()); processor = new TutorLabelProcessor(helpPanel, markingPanel, serverIp); processor.processLabels(mapPanel); frame.setTitle(String.format("Democall %1s - Tutor Client (%1s)", Constants.VERSION, lab.getLabDescription())); javax.swing.GroupLayout layout = new javax.swing.GroupLayout(frame.getContentPane()); frame.getContentPane().setLayout(layout); layout.setHorizontalGroup( layout.createParallelGroup(GroupLayout.Alignment.LEADING) .addComponent(helpPanel, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE) .addComponent(markingPanel, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE) .addComponent(mapPanel, GroupLayout.Alignment.CENTER, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE)); layout.setVerticalGroup( layout.createParallelGroup(GroupLayout.Alignment.LEADING) .addGroup(layout.createSequentialGroup() .addComponent(helpPanel, Constants.QUEUE_MIN_HEIGHT, GroupLayout.DEFAULT_SIZE, Constants.QUEUE_MAX_HEIGHT) .addComponent(markingPanel, Constants.QUEUE_MIN_HEIGHT, GroupLayout.DEFAULT_SIZE, Constants.QUEUE_MAX_HEIGHT) .addPreferredGap(LayoutStyle.ComponentPlacement.RELATED) .addComponent(mapPanel, 100, GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE) .addPreferredGap(LayoutStyle.ComponentPlacement.RELATED))); frame.pack(); frame.setVisible(true); final Socket socket = new RequestSender(serverIp).registerTutorClient(); new Thread(new Runnable() { @Override public void run() { try { BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); while (true) { final String message = reader.readLine(); if (message != null) { // readLine returns null if buffer is empty processMessage(message); } } } catch (IOException ex) { Logger.getLogger(TutorClient.class.getName()).log(Level.SEVERE, null, ex); } } } ).start(); // dynamic font resize based on window size final int defaultSize = Constants.DEFAULT_MAP_FONT_SIZE; final int defaultWidth = mapPanel.getWidth(); frame.addComponentListener( new ComponentAdapter() { @Override public void componentResized(ComponentEvent e) { int newWidth = mapPanel.getWidth(); float scaleFactor = (float) newWidth / (float) defaultWidth; int newFontSize = Math.round(defaultSize * scaleFactor); processor.resizeFonts(newFontSize); } } ); // load the beep audio clip into the audio system sample bank AudioInputStream is = AudioSystem.getAudioInputStream(getClass().getResourceAsStream("/blip.wav")); beep = AudioSystem.getClip(); beep.open(is); } 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); } } public void processMessage(final String message) { // System.out.println("processMessage: " + message); final String[] messageBits = message.split(" "); final String performative = messageBits[0]; final int machineId = Integer.parseInt(messageBits[1]); if ("help".equals(performative)) { processor.requestHelp(machineId); beep(); } else if ("marking".equals(performative)) { processor.requestMarking(machineId); beep(); } else if ("cancelhelp".equals(performative)) { processor.cancelHelp(machineId); } else if ("cancelmarking".equals(performative)) { processor.cancelMarking(machineId); } } private void beep() { try { if(beep !=null && beep.isRunning()) beep.stop(); beep.setFramePosition(0); // rewind clip beep.start(); } catch (Exception ex) { Logger.getLogger(TutorClient.class.getName()).log(Level.SEVERE, null, ex); } } @SuppressWarnings("ResultOfObjectAllocationIgnored") public static void main(final String[] args) { // System.out.println("Tutor Client"); // final String name = "SBEASTCAL1-31"; // final String name = "SB318-10"; // final String name = "SB316-10"; final String name = args.length > 0 ? args[0] : null; final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "CLIENTNNAME"); 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 discovery.server.ServiceNotFoundException; import gui.Lab; import gui.LabRegistry; import gui.QueuePanel; import gui.processors.TutorLabelProcessor; import java.awt.event.ComponentAdapter; import java.awt.event.ComponentEvent; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.Socket; import java.util.LinkedHashSet; import java.util.logging.Level; import java.util.logging.Logger; import javax.sound.sampled.AudioInputStream; import javax.sound.sampled.AudioSystem; import javax.sound.sampled.Clip; import javax.swing.GroupLayout; import javax.swing.JFrame; import javax.swing.JOptionPane; import javax.swing.JPanel; import javax.swing.LayoutStyle; import network.RequestSender; /** * * @author Mark */ public class TutorClient { private static final Logger LOG = Logger.getLogger(TutorClient.class.getName()); private TutorLabelProcessor processor; private String serverIp; private Clip beep; @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(); QueuePanel helpPanel = new QueuePanel(new LinkedHashSet()); QueuePanel markingPanel = new QueuePanel(new LinkedHashSet()); processor = new TutorLabelProcessor(helpPanel, markingPanel, serverIp); processor.processLabels(mapPanel); frame.setTitle(String.format("Democall %1s - Tutor Client (%1s)", Constants.VERSION, lab.getLabDescription())); javax.swing.GroupLayout layout = new javax.swing.GroupLayout(frame.getContentPane()); frame.getContentPane().setLayout(layout); layout.setHorizontalGroup( layout.createParallelGroup(GroupLayout.Alignment.LEADING) .addComponent(helpPanel, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE) .addComponent(markingPanel, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE) .addComponent(mapPanel, GroupLayout.Alignment.CENTER, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE)); layout.setVerticalGroup( layout.createParallelGroup(GroupLayout.Alignment.LEADING) .addGroup(layout.createSequentialGroup() .addComponent(helpPanel, Constants.QUEUE_MIN_HEIGHT, GroupLayout.DEFAULT_SIZE, Constants.QUEUE_MAX_HEIGHT) .addComponent(markingPanel, Constants.QUEUE_MIN_HEIGHT, GroupLayout.DEFAULT_SIZE, Constants.QUEUE_MAX_HEIGHT) .addPreferredGap(LayoutStyle.ComponentPlacement.RELATED) .addComponent(mapPanel, 100, GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE) .addPreferredGap(LayoutStyle.ComponentPlacement.RELATED))); frame.pack(); frame.setVisible(true); final Socket socket = new RequestSender(serverIp).registerTutorClient(); new Thread(new Runnable() { @Override public void run() { try { BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); while (true) { final String message = reader.readLine(); if (message != null) { // readLine returns null if buffer is empty processMessage(message); } } } catch (IOException ex) { Logger.getLogger(TutorClient.class.getName()).log(Level.SEVERE, null, ex); } } } ).start(); // dynamic font resize based on window size final int defaultSize = Constants.DEFAULT_MAP_FONT_SIZE; final int defaultWidth = mapPanel.getWidth(); frame.addComponentListener( new ComponentAdapter() { @Override public void componentResized(ComponentEvent e) { int newWidth = mapPanel.getWidth(); float scaleFactor = (float) newWidth / (float) defaultWidth; int newFontSize = Math.round(defaultSize * scaleFactor); processor.resizeFonts(newFontSize); } } ); // load the beep audio clip into the audio system sample bank AudioInputStream is = AudioSystem.getAudioInputStream(getClass().getResourceAsStream("/blip.wav")); beep = AudioSystem.getClip(); beep.open(is); } 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); } } public void processMessage(final String message) { // System.out.println("processMessage: " + message); final String[] messageBits = message.split(" "); final String performative = messageBits[0]; final int machineId = Integer.parseInt(messageBits[1]); if ("help".equals(performative)) { processor.requestHelp(machineId); beep(); } else if ("marking".equals(performative)) { processor.requestMarking(machineId); beep(); } else if ("cancelhelp".equals(performative)) { processor.cancelHelp(machineId); } else if ("cancelmarking".equals(performative)) { processor.cancelMarking(machineId); } } private void beep() { try { if(beep !=null && beep.isRunning()) beep.stop(); beep.setFramePosition(0); // rewind clip beep.start(); } catch (Exception ex) { Logger.getLogger(TutorClient.class.getName()).log(Level.SEVERE, null, ex); } } @SuppressWarnings("ResultOfObjectAllocationIgnored") public static void main(final String[] args) { // System.out.println("Tutor Client"); // final String name = "SBEASTCAL1-31"; // final String name = "SB318-10"; // final String name = "SB316-10"; final String name = args.length > 0 ? args[0] : null; final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "CLIENTNNAME"); new TutorClient(nameResolver); } }

Show notes View src/discovery/server/BroadcastResponder.java 100644 → 0

package discovery.server; import constants.Constants; import java.net.*; import java.util.Enumeration; import java.util.logging.Level; import java.util.logging.Logger; /** * * @author Mark, and Christopher Frantz */ public class BroadcastResponder extends Thread { private static final Logger LOG = Logger.getLogger(BroadcastResponder.class.getName()); private final String lab; public BroadcastResponder(final String lab) { super(); super.setDaemon(true); this.lab = lab; } @Override public void run() { try { final MulticastSocket socket = new MulticastSocket(Constants.PORT); socket.joinGroup(InetAddress.getByName(Constants.BROADCAST_ADDRESS)); final int bufferSize = 255; while (true) { byte[] buffer = new byte[bufferSize]; // NOPMD: need to reset buffer each time final DatagramPacket packet = new DatagramPacket(buffer, buffer.length); // NOPMD: safer to create new packets than try to reuse socket.receive(packet); final String requestedLab = new String(packet.getData()).trim(); // NOPMD: String.valueOf does not handle byte[] properly... if (requestedLab.equalsIgnoreCase(lab)) { final String serverIp = this.getServerIp(); buffer = serverIp.getBytes(); packet.setData(buffer); socket.send(packet); } } } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } } /** * This code comes from Christopher Frantz and seems less likely to pick the * loopback IP address than other ways. */ private String getServerIp() { try { for (final Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements();) { final NetworkInterface intf = en.nextElement(); for (final Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements();) { final InetAddress inetAddress = enumIpAddr.nextElement(); try { // FIXME: Quick hack to ensure we are only getting IPv4 // addresses - need to test what happens with IPv6 // addresses. // // This variable is never used - the cast is to check // if IPv4 or 6. final Inet4Address testIfIpv4 = (Inet4Address) inetAddress; // NOPMD: see above comment if (!inetAddress.isLoopbackAddress()) { return inetAddress.getHostAddress().toString(); } } catch (ClassCastException ignored) { continue; } } } } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } return null; } }

Show notes View src/discovery/server/KnownClients.java 100644 → 0

package discovery.server; import java.io.PrintWriter; import java.util.HashSet; import java.util.Set; import network.MessageGenerator; /** * * @author mark */ public class KnownClients { private static final Set<PrintWriter> clients = new HashSet<PrintWriter>(); public static void addClient(PrintWriter client) { clients.add(client); } public static void requestHelp(Integer id) { for (PrintWriter client : clients) { client.println(new MessageGenerator().requestHelp(String.valueOf(id))); client.flush(); } } public static void requestMarking(Integer id) { for (PrintWriter client : clients) { client.println(new MessageGenerator().requestMarking(String.valueOf(id))); client.flush(); } } public static void cancelHelp(Integer id) { for (PrintWriter client : clients) { client.println(new MessageGenerator().cancelHelp(String.valueOf(id))); client.flush(); } } public static void cancelMarking(Integer id) { for (PrintWriter client : clients) { client.println(new MessageGenerator().cancelMarking(String.valueOf(id))); client.flush(); } } }

Show notes View src/discovery/server/ServiceLocator.java 100644 → 0

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; } }

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

Ignore Space Show notes View src/discovery/server/multicast/BroadcastResponder.java 0 → 100644

package discovery.server.multicast; import constants.Constants; import java.net.*; import java.util.Enumeration; import java.util.logging.Level; import java.util.logging.Logger; /** * * @author Mark, and Christopher Frantz */ public class BroadcastResponder extends Thread { private static final Logger LOG = Logger.getLogger(BroadcastResponder.class.getName()); private final String lab; public BroadcastResponder(final String lab) { super(); super.setDaemon(true); this.lab = lab; } @Override public void run() { try { final MulticastSocket socket = new MulticastSocket(Constants.PORT); socket.joinGroup(InetAddress.getByName(Constants.BROADCAST_ADDRESS)); final int bufferSize = 255; while (true) { byte[] buffer = new byte[bufferSize]; // NOPMD: need to reset buffer each time final DatagramPacket packet = new DatagramPacket(buffer, buffer.length); // NOPMD: safer to create new packets than try to reuse socket.receive(packet); final String requestedLab = new String(packet.getData()).trim(); // NOPMD: String.valueOf does not handle byte[] properly... if (requestedLab.equalsIgnoreCase(lab)) { final String serverIp = this.getServerIp(); buffer = serverIp.getBytes(); packet.setData(buffer); socket.send(packet); } } } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } } /** * This code comes from Christopher Frantz and seems less likely to pick the * loopback IP address than other ways. */ private String getServerIp() { try { for (final Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements();) { final NetworkInterface intf = en.nextElement(); for (final Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements();) { final InetAddress inetAddress = enumIpAddr.nextElement(); try { // FIXME: Quick hack to ensure we are only getting IPv4 // addresses - need to test what happens with IPv6 // addresses. // // This variable is never used - the cast is to check // if IPv4 or 6. final Inet4Address testIfIpv4 = (Inet4Address) inetAddress; // NOPMD: see above comment if (!inetAddress.isLoopbackAddress()) { return inetAddress.getHostAddress().toString(); } } catch (ClassCastException ignored) { continue; } } } } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } return null; } }

Ignore Space Show notes View src/discovery/server/multicast/KnownClients.java 0 → 100644

package discovery.server.multicast; import java.io.PrintWriter; import java.util.HashSet; import java.util.Set; import network.MessageGenerator; /** * * @author mark */ public class KnownClients { private static final Set<PrintWriter> clients = new HashSet<PrintWriter>(); public static void addClient(PrintWriter client) { clients.add(client); } public static void requestHelp(Integer id) { for (PrintWriter client : clients) { client.println(new MessageGenerator().requestHelp(String.valueOf(id))); client.flush(); } } public static void requestMarking(Integer id) { for (PrintWriter client : clients) { client.println(new MessageGenerator().requestMarking(String.valueOf(id))); client.flush(); } } public static void cancelHelp(Integer id) { for (PrintWriter client : clients) { client.println(new MessageGenerator().cancelHelp(String.valueOf(id))); client.flush(); } } public static void cancelMarking(Integer id) { for (PrintWriter client : clients) { client.println(new MessageGenerator().cancelMarking(String.valueOf(id))); client.flush(); } } }

Ignore Space Show notes View src/discovery/server/multicast/ServiceLocator.java 0 → 100644

package discovery.server.multicast; 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; } }

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

Ignore Space Show notes View src/gui/processors/RequestProcessor.java

package gui.processors; import discovery.server.multicast.KnownClients; import gui.QueuePanel; import java.awt.Color; import java.awt.Component; import java.awt.Font; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.MouseAdapter; import java.awt.event.MouseEvent; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import javax.swing.JLabel; import javax.swing.JMenuItem; import javax.swing.JPanel; import javax.swing.JPopupMenu; /** * * @author Mark */ public abstract class RequestProcessor { private final Color helpCol = Color.GREEN; private final Color markingCol = Color.YELLOW; private final Color regularCol = new JLabel().getBackground(); private final Map<Integer, Student> students = new ConcurrentHashMap<Integer, Student>(); private final Set<JLabel> labels = new HashSet<JLabel>(); protected final QueuePanel helpQueue; protected final QueuePanel markingQueue; public abstract MouseAdapter getMouseAdapter(); // { // return new MouseAdapter() { // // @Override // public void mousePressed(final MouseEvent e) { // super.mousePressed(e); // final JLabel label = (JLabel) e.getSource(); // final Integer machine = new Integer(label.getText()); // // Status status = getStatus(machine); // // if (status == Status.BOTH) { // // final JPopupMenu menu = new JPopupMenu(); // // final JMenuItem cancelHelp = new JMenuItem("Cancel Help"); // cancelHelp.addActionListener(new ActionListener() { // // @Override // public void actionPerformed(final ActionEvent e) { // cancelHelp(machine); // } // }); // // final JMenuItem cancelMarking = new JMenuItem("Cancel Marking"); // cancelMarking.addActionListener(new ActionListener() { // // @Override // public void actionPerformed(final ActionEvent e) { // cancelMarking(machine); // } // }); // // menu.add(cancelHelp); // menu.add(cancelMarking); // // menu.show((Component) e.getSource(), e.getX(), e.getY()); // // } else if (status == Status.HELP) { // cancelHelp(machine); // } else if (status == Status.MARKING) { // cancelMarking(machine); // } // // } // }; // } public RequestProcessor(QueuePanel helpPanel, QueuePanel markingPanel) { this.helpQueue = helpPanel; this.markingQueue = markingPanel; } public final void processLabels(final JPanel panel) { processPanel(panel); } private void processPanel(final JPanel panel) { for (Component component : panel.getComponents()) { if (component instanceof JLabel) { final JLabel label = (JLabel) component; try { // component must be opaque so the background color can be set label.setOpaque(true); final Integer id = Integer.valueOf(label.getText()); students.put(id, new Student(id, label)); labels.add(label); label.addMouseListener(this.getMouseAdapter()); } catch (NumberFormatException ignored) { continue; } } else if (component instanceof JPanel) { // found a panel that might contain labels so recurse processPanel((JPanel) component); } } } public void resizeFonts(float newFontSize) { // there should always labels in this map so hopefully this next line doesn't cause issues Font newFont = labels.iterator().next().getFont().deriveFont(newFontSize); for (JLabel label : labels) { label.setFont(newFont); } helpQueue.setQueueFont(newFont); markingQueue.setQueueFont(newFont); } public final void requestHelp(final int id) { synchronized (helpQueue) { helpQueue.addRequest(id); students.get(id).addStatus(Status.HELP); } KnownClients.requestHelp(id); } public final void requestMarking(final int id) { synchronized (markingQueue) { markingQueue.addRequest(id); students.get(id).addStatus(Status.MARKING); } KnownClients.requestMarking(id); } public synchronized void cancelHelp(final int id) { synchronized (helpQueue) { helpQueue.removeRequest(id); students.get(id).removeStatus(Status.HELP); } KnownClients.cancelHelp(id); } public synchronized void cancelMarking(final int id) { synchronized (helpQueue) { markingQueue.removeRequest(id); students.get(id).removeStatus(Status.MARKING); } KnownClients.cancelMarking(id); } public final Collection<Integer> getHelpQueue() { synchronized (helpQueue) { // Creating a copy of helpQueue to prevent ConcurrentModification errors. // This only works because helpQueue is locked by the sync block return new ArrayList<Integer>(helpQueue.getQueue()); } } public final Collection<Integer> getMarkingQueue() { synchronized (markingQueue) { // Creating a copy of helpQueue to prevent ConcurrentModification errors. // This only works because helpQueue is locked by the sync block return new ArrayList<Integer>(markingQueue.getQueue()); } } public Status getStatus(Integer id) { return students.get(id).getStatus(); } // private void updateTutorClients(Collection<Integer> queue1) { // Iterator<ObjectOutputStream> it = Constants.PERSISTENT_SOCKETS.iterator(); // while (it.hasNext()) { // try { // ObjectOutputStream oos = it.next(); // oos.reset(); // necessary since if you send the same object twice some "optimisations" happen causing the client to see cached versions of the object // oos.writeObject(helpQueue); // oos.flush(); // System.out.println(helpQueue); // } catch (IOException ex) { // it.remove(); // } // } // } } package gui.processors; import discovery.server.KnownClients; import gui.QueuePanel; import java.awt.Color; import java.awt.Component; import java.awt.Font; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.MouseAdapter; import java.awt.event.MouseEvent; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import javax.swing.JLabel; import javax.swing.JMenuItem; import javax.swing.JPanel; import javax.swing.JPopupMenu; /** * * @author Mark */ public abstract class RequestProcessor { private final Color helpCol = Color.GREEN; private final Color markingCol = Color.YELLOW; private final Color regularCol = new JLabel().getBackground(); private final Map<Integer, Student> students = new ConcurrentHashMap<Integer, Student>(); private final Set<JLabel> labels = new HashSet<JLabel>(); protected final QueuePanel helpQueue; protected final QueuePanel markingQueue; public abstract MouseAdapter getMouseAdapter(); // { // return new MouseAdapter() { // // @Override // public void mousePressed(final MouseEvent e) { // super.mousePressed(e); // final JLabel label = (JLabel) e.getSource(); // final Integer machine = new Integer(label.getText()); // // Status status = getStatus(machine); // // if (status == Status.BOTH) { // // final JPopupMenu menu = new JPopupMenu(); // // final JMenuItem cancelHelp = new JMenuItem("Cancel Help"); // cancelHelp.addActionListener(new ActionListener() { // // @Override // public void actionPerformed(final ActionEvent e) { // cancelHelp(machine); // } // }); // // final JMenuItem cancelMarking = new JMenuItem("Cancel Marking"); // cancelMarking.addActionListener(new ActionListener() { // // @Override // public void actionPerformed(final ActionEvent e) { // cancelMarking(machine); // } // }); // // menu.add(cancelHelp); // menu.add(cancelMarking); // // menu.show((Component) e.getSource(), e.getX(), e.getY()); // // } else if (status == Status.HELP) { // cancelHelp(machine); // } else if (status == Status.MARKING) { // cancelMarking(machine); // } // // } // }; // } public RequestProcessor(QueuePanel helpPanel, QueuePanel markingPanel) { this.helpQueue = helpPanel; this.markingQueue = markingPanel; } public final void processLabels(final JPanel panel) { processPanel(panel); } private void processPanel(final JPanel panel) { for (Component component : panel.getComponents()) { if (component instanceof JLabel) { final JLabel label = (JLabel) component; try { // component must be opaque so the background color can be set label.setOpaque(true); final Integer id = Integer.valueOf(label.getText()); students.put(id, new Student(id, label)); labels.add(label); label.addMouseListener(this.getMouseAdapter()); } catch (NumberFormatException ignored) { continue; } } else if (component instanceof JPanel) { // found a panel that might contain labels so recurse processPanel((JPanel) component); } } } public void resizeFonts(float newFontSize) { // there should always labels in this map so hopefully this next line doesn't cause issues Font newFont = labels.iterator().next().getFont().deriveFont(newFontSize); for (JLabel label : labels) { label.setFont(newFont); } helpQueue.setQueueFont(newFont); markingQueue.setQueueFont(newFont); } public final void requestHelp(final int id) { synchronized (helpQueue) { helpQueue.addRequest(id); students.get(id).addStatus(Status.HELP); } KnownClients.requestHelp(id); } public final void requestMarking(final int id) { synchronized (markingQueue) { markingQueue.addRequest(id); students.get(id).addStatus(Status.MARKING); } KnownClients.requestMarking(id); } public synchronized void cancelHelp(final int id) { synchronized (helpQueue) { helpQueue.removeRequest(id); students.get(id).removeStatus(Status.HELP); } KnownClients.cancelHelp(id); } public synchronized void cancelMarking(final int id) { synchronized (helpQueue) { markingQueue.removeRequest(id); students.get(id).removeStatus(Status.MARKING); } KnownClients.cancelMarking(id); } public final Collection<Integer> getHelpQueue() { synchronized (helpQueue) { // Creating a copy of helpQueue to prevent ConcurrentModification errors. // This only works because helpQueue is locked by the sync block return new ArrayList<Integer>(helpQueue.getQueue()); } } public final Collection<Integer> getMarkingQueue() { synchronized (markingQueue) { // Creating a copy of helpQueue to prevent ConcurrentModification errors. // This only works because helpQueue is locked by the sync block return new ArrayList<Integer>(markingQueue.getQueue()); } } public Status getStatus(Integer id) { return students.get(id).getStatus(); } // private void updateTutorClients(Collection<Integer> queue1) { // Iterator<ObjectOutputStream> it = Constants.PERSISTENT_SOCKETS.iterator(); // while (it.hasNext()) { // try { // ObjectOutputStream oos = it.next(); // oos.reset(); // necessary since if you send the same object twice some "optimisations" happen causing the client to see cached versions of the object // oos.writeObject(helpQueue); // oos.flush(); // System.out.println(helpQueue); // } catch (IOException ex) { // it.remove(); // } // } // } }

Show notes View src/server/ApplicationHandler.java 100644 → 0

package server; import constants.Constants; import gui.processors.RequestProcessor; 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 RequestProcessor processor; private static final Logger LOG = Logger.getLogger(ApplicationHandler.class.getName()); public ApplicationHandler(final RequestProcessor processor) { super(); super.setDaemon(true); this.processor = processor; } @Override public void run() { try { final ServerSocket ss = new ServerSocket(Constants.PORT); while (true) { final Socket socket = ss.accept(); new RequestThread(processor, socket).start(); } } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } } }

Show notes View src/server/RequestThread.java 100644 → 0

package server; import discovery.server.KnownClients; import gui.processors.RequestProcessor; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.Socket; import java.util.Collection; import java.util.HashSet; import java.util.Set; import java.util.logging.Level; import java.util.logging.Logger; import network.MessageGenerator; /** * * @author Mark */ public class RequestThread extends Thread { private static final Logger LOG = Logger.getLogger(RequestThread.class.getName()); private static final Set<PrintWriter> tutorClients = new HashSet<PrintWriter>(); private final RequestProcessor processor; private final Socket socket; private boolean dontClose = false; public RequestThread(final RequestProcessor processor, final Socket socket) { super(); super.setDaemon(true); this.processor = processor; this.socket = socket; } @Override public void run() { try { final BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); final String message = reader.readLine(); if (message != null) { // readLine returns null if buffer is empty processMessage(message); } if (!dontClose) { socket.close(); } } catch (IOException ex) { LOG.log(Level.SEVERE, null, ex); } } public void processMessage(final String message) { System.out.println(message); final String[] messageBits = message.split(" "); final String performative = messageBits[0]; final int machineId = Integer.parseInt(messageBits[1]); if ("help".equals(performative)) { processor.requestHelp(machineId); } else if ("marking".equals(performative)) { processor.requestMarking(machineId); } else if ("cancelhelp".equals(performative)) { processor.cancelHelp(machineId); } else if ("cancelmarking".equals(performative)) { processor.cancelMarking(machineId); // } else if ("queue".equals(performative)) { // try { // final ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream()); // oos.writeObject(processor.getQueue()); // oos.close(); // } catch (IOException ex) { // LOG.log(Level.SEVERE, null, ex); // } } else if ("register".equals(performative)) { try { // send the current state of the queues back to the connecting client final PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); Collection<Integer> helpQueue = processor.getHelpQueue(); for (Integer i : helpQueue) { writer.println(new MessageGenerator().requestHelp(String.valueOf(i))); } Collection<Integer> markingQueue = processor.getMarkingQueue(); for (Integer i : markingQueue) { writer.println(new MessageGenerator().requestMarking(String.valueOf(i))); } writer.flush(); KnownClients.addClient(writer); dontClose = true; } catch (IOException ex) { LOG.log(Level.SEVERE, null, ex); } } else { LOG.log(Level.SEVERE, "Unknown command: {0}", performative); } } }

Show notes View src/server/Server.java 100644 → 0

package server; import constants.Constants; import discovery.computername.ComputerNameResolver; import discovery.computername.InvalidComputerNameException; import discovery.computername.OtagoComputerNameResolver; import discovery.server.BroadcastResponder; import gui.Lab; import gui.LabRegistry; import gui.QueuePanel; import gui.processors.RequestProcessor; import gui.processors.ServerLabelProcessor; import java.awt.BorderLayout; import java.awt.event.*; import java.io.IOException; import java.util.Collection; import java.util.LinkedHashSet; import javax.swing.GroupLayout; import javax.swing.JFrame; import javax.swing.JOptionPane; import javax.swing.JPanel; import javax.swing.LayoutStyle; /** * * @author Mark */ public final class Server { private Server() { } public static void main(final String[] args) throws IOException { // System.out.println("Server"); // final String name = "SBEASTCAL1-01"; // final String name = "SB316-01"; // final String name = "SB317-1"; // final String name = "SB318-1"; final String name = args.length > 0 ? args[0] : null; ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "CLIENTNAME"); try { nameResolver.resolve(); } catch (InvalidComputerNameException ex) { JOptionPane.showMessageDialog(null, "There is no map for this lab yet.\nThe machine ID is : " + nameResolver.getComputerName(), "No map", JOptionPane.ERROR_MESSAGE); System.exit(Constants.EXIT_NO_MAP_FOUND); } final String labName = nameResolver.getLabName(); final JFrame frame = new JFrame(); frame.setLayout(new BorderLayout()); frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); final LabRegistry registry = new LabRegistry(); final Lab lab = registry.getLab(labName); final JPanel mapPanel = lab.getPanel(); final Collection<Integer> helpQueue = new LinkedHashSet<Integer>(); final Collection<Integer> markingQueue = new LinkedHashSet<Integer>(); QueuePanel helpPanel = new QueuePanel(helpQueue); QueuePanel markingPanel = new QueuePanel(markingQueue); final RequestProcessor processor = new ServerLabelProcessor(helpPanel, markingPanel); processor.processLabels(mapPanel); frame.setTitle(String.format("Democall %1s - Server (%1s)", Constants.VERSION, lab.getLabDescription())); javax.swing.GroupLayout layout = new javax.swing.GroupLayout(frame.getContentPane()); frame.getContentPane().setLayout(layout); layout.setHorizontalGroup( layout.createParallelGroup(GroupLayout.Alignment.LEADING) .addComponent(helpPanel, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE) .addComponent(markingPanel, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE) .addComponent(mapPanel, GroupLayout.Alignment.CENTER, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE)); layout.setVerticalGroup( layout.createParallelGroup(GroupLayout.Alignment.LEADING) .addGroup(layout.createSequentialGroup() .addComponent(helpPanel, Constants.QUEUE_MIN_HEIGHT, GroupLayout.DEFAULT_SIZE, Constants.QUEUE_MAX_HEIGHT) .addComponent(markingPanel, Constants.QUEUE_MIN_HEIGHT, GroupLayout.DEFAULT_SIZE, Constants.QUEUE_MAX_HEIGHT) .addPreferredGap(LayoutStyle.ComponentPlacement.RELATED) .addComponent(mapPanel, 100, GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE) .addPreferredGap(LayoutStyle.ComponentPlacement.RELATED))); frame.pack(); frame.setVisible(true); // dynamic font resize based on window size final int defaultFontSize = Constants.DEFAULT_MAP_FONT_SIZE; final int currentHeight = mapPanel.getHeight(); frame.addComponentListener(new ComponentAdapter() { @Override public void componentResized(ComponentEvent e) { int newHeight = mapPanel.getHeight(); float scaleFactor = (float) newHeight / (float) currentHeight * 0.8f; int newFontSize = Math.round(defaultFontSize * scaleFactor); processor.resizeFonts(newFontSize); } }); new ApplicationHandler(processor).start(); new BroadcastResponder(labName).start(); } }

Ignore Space Show notes View src/server/sockets/ApplicationHandler.java 0 → 100644

package server.sockets; import constants.Constants; import gui.processors.RequestProcessor; 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 RequestProcessor processor; private static final Logger LOG = Logger.getLogger(ApplicationHandler.class.getName()); public ApplicationHandler(final RequestProcessor processor) { super(); super.setDaemon(true); this.processor = processor; } @Override public void run() { try { final ServerSocket ss = new ServerSocket(Constants.PORT); while (true) { final Socket socket = ss.accept(); new RequestThread(processor, socket).start(); } } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } } }

Ignore Space Show notes View src/server/sockets/RequestThread.java 0 → 100644

package server.sockets; import discovery.server.multicast.KnownClients; import gui.processors.RequestProcessor; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.Socket; import java.util.Collection; import java.util.HashSet; import java.util.Set; import java.util.logging.Level; import java.util.logging.Logger; import network.MessageGenerator; /** * * @author Mark */ public class RequestThread extends Thread { private static final Logger LOG = Logger.getLogger(RequestThread.class.getName()); private static final Set<PrintWriter> tutorClients = new HashSet<PrintWriter>(); private final RequestProcessor processor; private final Socket socket; private boolean dontClose = false; public RequestThread(final RequestProcessor processor, final Socket socket) { super(); super.setDaemon(true); this.processor = processor; this.socket = socket; } @Override public void run() { try { final BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); final String message = reader.readLine(); if (message != null) { // readLine returns null if buffer is empty processMessage(message); } if (!dontClose) { socket.close(); } } catch (IOException ex) { LOG.log(Level.SEVERE, null, ex); } } public void processMessage(final String message) { System.out.println(message); final String[] messageBits = message.split(" "); final String performative = messageBits[0]; final int machineId = Integer.parseInt(messageBits[1]); if ("help".equals(performative)) { processor.requestHelp(machineId); } else if ("marking".equals(performative)) { processor.requestMarking(machineId); } else if ("cancelhelp".equals(performative)) { processor.cancelHelp(machineId); } else if ("cancelmarking".equals(performative)) { processor.cancelMarking(machineId); // } else if ("queue".equals(performative)) { // try { // final ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream()); // oos.writeObject(processor.getQueue()); // oos.close(); // } catch (IOException ex) { // LOG.log(Level.SEVERE, null, ex); // } } else if ("register".equals(performative)) { try { // send the current state of the queues back to the connecting client final PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); Collection<Integer> helpQueue = processor.getHelpQueue(); for (Integer i : helpQueue) { writer.println(new MessageGenerator().requestHelp(String.valueOf(i))); } Collection<Integer> markingQueue = processor.getMarkingQueue(); for (Integer i : markingQueue) { writer.println(new MessageGenerator().requestMarking(String.valueOf(i))); } writer.flush(); KnownClients.addClient(writer); dontClose = true; } catch (IOException ex) { LOG.log(Level.SEVERE, null, ex); } } else { LOG.log(Level.SEVERE, "Unknown command: {0}", performative); } } }

Ignore Space Show notes View src/server/sockets/Server.java 0 → 100644

package server.sockets; import constants.Constants; import discovery.computername.ComputerNameResolver; import discovery.computername.InvalidComputerNameException; import discovery.computername.OtagoComputerNameResolver; import discovery.server.multicast.BroadcastResponder; import gui.Lab; import gui.LabRegistry; import gui.QueuePanel; import gui.processors.RequestProcessor; import gui.processors.ServerLabelProcessor; import java.awt.BorderLayout; import java.awt.event.*; import java.io.IOException; import java.util.Collection; import java.util.LinkedHashSet; import javax.swing.GroupLayout; import javax.swing.JFrame; import javax.swing.JOptionPane; import javax.swing.JPanel; import javax.swing.LayoutStyle; /** * * @author Mark */ public final class Server { private Server() { } public static void main(final String[] args) throws IOException { // System.out.println("Server"); // final String name = "SBEASTCAL1-01"; // final String name = "SB316-01"; // final String name = "SB317-1"; // final String name = "SB318-1"; final String name = args.length > 0 ? args[0] : null; ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "CLIENTNAME"); try { nameResolver.resolve(); } catch (InvalidComputerNameException ex) { JOptionPane.showMessageDialog(null, "There is no map for this lab yet.\nThe machine ID is : " + nameResolver.getComputerName(), "No map", JOptionPane.ERROR_MESSAGE); System.exit(Constants.EXIT_NO_MAP_FOUND); } final String labName = nameResolver.getLabName(); final JFrame frame = new JFrame(); frame.setLayout(new BorderLayout()); frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); final LabRegistry registry = new LabRegistry(); final Lab lab = registry.getLab(labName); final JPanel mapPanel = lab.getPanel(); final Collection<Integer> helpQueue = new LinkedHashSet<Integer>(); final Collection<Integer> markingQueue = new LinkedHashSet<Integer>(); QueuePanel helpPanel = new QueuePanel(helpQueue); QueuePanel markingPanel = new QueuePanel(markingQueue); final RequestProcessor processor = new ServerLabelProcessor(helpPanel, markingPanel); processor.processLabels(mapPanel); frame.setTitle(String.format("Democall %1s - Server (%1s)", Constants.VERSION, lab.getLabDescription())); javax.swing.GroupLayout layout = new javax.swing.GroupLayout(frame.getContentPane()); frame.getContentPane().setLayout(layout); layout.setHorizontalGroup( layout.createParallelGroup(GroupLayout.Alignment.LEADING) .addComponent(helpPanel, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE) .addComponent(markingPanel, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE) .addComponent(mapPanel, GroupLayout.Alignment.CENTER, GroupLayout.DEFAULT_SIZE, GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE)); layout.setVerticalGroup( layout.createParallelGroup(GroupLayout.Alignment.LEADING) .addGroup(layout.createSequentialGroup() .addComponent(helpPanel, Constants.QUEUE_MIN_HEIGHT, GroupLayout.DEFAULT_SIZE, Constants.QUEUE_MAX_HEIGHT) .addComponent(markingPanel, Constants.QUEUE_MIN_HEIGHT, GroupLayout.DEFAULT_SIZE, Constants.QUEUE_MAX_HEIGHT) .addPreferredGap(LayoutStyle.ComponentPlacement.RELATED) .addComponent(mapPanel, 100, GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE) .addPreferredGap(LayoutStyle.ComponentPlacement.RELATED))); frame.pack(); frame.setVisible(true); // dynamic font resize based on window size final int defaultFontSize = Constants.DEFAULT_MAP_FONT_SIZE; final int currentHeight = mapPanel.getHeight(); frame.addComponentListener(new ComponentAdapter() { @Override public void componentResized(ComponentEvent e) { int newHeight = mapPanel.getHeight(); float scaleFactor = (float) newHeight / (float) currentHeight * 0.8f; int newFontSize = Math.round(defaultFontSize * scaleFactor); processor.resizeFonts(newFontSize); } }); new ApplicationHandler(processor).start(); new BroadcastResponder(labName).start(); } }

Ignore Space Show notes View tests/BroadcasterTest.java

import discovery.computername.ComputerNameResolver; import discovery.computername.OtagoComputerNameResolver; import discovery.server.multicast.ServiceLocator; /* * A stress test for the BroadcastResponder. * * @author mark */ public final class BroadcasterTest { private BroadcasterTest() { } public static void main(final String[] args) { final String name = "SBEASTCAL1-30"; final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "CLIENTNAME"); nameResolver.resolve(); final String lab = nameResolver.getLabName(); final ServiceLocator locator = new ServiceLocator(); for(int i=0; i<500; i++) { final String serverIp = locator.locateServer(lab); System.out.println(i + " " + serverIp); } } } import discovery.computername.ComputerNameResolver; import discovery.computername.OtagoComputerNameResolver; import discovery.server.ServiceLocator; /* * A stress test for the BroadcastResponder. * * @author mark */ public final class BroadcasterTest { private BroadcasterTest() { } public static void main(final String[] args) { final String name = "SBEASTCAL1-30"; final ComputerNameResolver nameResolver = new OtagoComputerNameResolver(name, "CLIENTNAME"); nameResolver.resolve(); final String lab = nameResolver.getLabName(); final ServiceLocator locator = new ServiceLocator(); for(int i=0; i<500; i++) { final String serverIp = locator.locateServer(lab); System.out.println(i + " " + serverIp); } } }

Show line notes below