Added a stress test for the BroadcastResponder.

mark.george / democall3

Browse code Added a stress test for the BroadcastResponder. master
1 parent 3bbf48b commit 33d393290815e3d663093a8aa8655973b1ff6cd4 Mark authored on 22 Sep 2012

Patch

Showing 10 changed files

Show notes View src/discovery/BroadcastResponder.java 100644 → 0
package discovery; 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 String lab; public BroadcastResponder(String lab) { this.setDaemon(true); this.lab = lab; } @Override public void run() { try { MulticastSocket socket = new MulticastSocket(Constants.PORT); socket.joinGroup(InetAddress.getByName(Constants.BROADCAST_ADDRESS)); while (true) { byte[] buffer = new byte[255]; DatagramPacket packet = new DatagramPacket(buffer, buffer.length); socket.receive(packet); String requestedLab = new String(packet.getData()).trim(); if (requestedLab.equalsIgnoreCase(lab)) { String serverIp = this.getServerIp(); buffer = serverIp.getBytes(); socket.send(new DatagramPacket(buffer, buffer.length, packet.getAddress(), packet.getPort())); } } } catch (Exception ex) { 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 (Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements();) { NetworkInterface intf = en.nextElement(); for (Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements();) { InetAddress inetAddress = enumIpAddr.nextElement(); try { // FIXME: quick hack to ensure we are only getting IPv4 addresses - need to test what happens with IPv6 addresses in the labs Inet4Address testIfIpv4 = (Inet4Address) inetAddress; if (!inetAddress.isLoopbackAddress()) { return inetAddress.getHostAddress().toString(); } } catch (ClassCastException ignored) { // ignored } } } } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } return null; } }

Show notes View

src/discovery/BroadcastResponder.java 100644 → 0

package discovery;

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 String lab;

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

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

while (true) {
            byte[] buffer = new byte[255];
            DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
            socket.receive(packet);
            String requestedLab = new String(packet.getData()).trim();
            if (requestedLab.equalsIgnoreCase(lab)) {
               String serverIp = this.getServerIp();
               buffer = serverIp.getBytes();
               socket.send(new DatagramPacket(buffer, buffer.length, packet.getAddress(), packet.getPort()));
            }
         }

} catch (Exception ex) {
         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 (Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements();) {
            NetworkInterface intf = en.nextElement();
            for (Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements();) {
               InetAddress inetAddress = enumIpAddr.nextElement();
               try {
                  // FIXME: quick hack to ensure we are only getting IPv4 addresses - need to test what happens with IPv6 addresses in the labs
                  Inet4Address testIfIpv4 = (Inet4Address) inetAddress;
                  if (!inetAddress.isLoopbackAddress()) {
                     return inetAddress.getHostAddress().toString();
                  }
               } catch (ClassCastException ignored) {
                  // ignored
               }
            }
         }
      } catch (Exception ex) {
         LOG.log(Level.SEVERE, null, ex);
      }
      return null;
   }
}

Show notes View src/discovery/ComputerNameResolver.java 100644 → 0
package discovery; /** * * @author Mark */ public class ComputerNameResolver { private ComputerNameResolver() { } public static String getName() { // return System.getenv("COMPUTERNAME"); // return "SBEASTCAL1-01"; return "SBEASTCAL1-30"; } }

Show notes View src/discovery/ServiceLocator.java 100644 → 0
package discovery; 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(String lab) { try { DatagramSocket socket = new DatagramSocket(); InetAddress address = InetAddress.getByName(Constants.BROADCAST_ADDRESS); byte[] data = lab.getBytes(); int port = Constants.PORT; socket.send(new DatagramPacket(data, data.length, address, port)); byte[] response = new byte[256]; DatagramPacket packet = new DatagramPacket(response, response.length); socket.receive(packet); String receivedIp = new String(packet.getData()).trim(); socket.close(); return receivedIp; } catch (Exception ex) { Logger.getLogger(ServiceLocator.class.getName()).log(Level.SEVERE, null, ex); } return null; } }

Show notes View

src/discovery/ServiceLocator.java 100644 → 0

package discovery;

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(String lab) {
      try {
         DatagramSocket socket = new DatagramSocket();
         InetAddress address = InetAddress.getByName(Constants.BROADCAST_ADDRESS);
         byte[] data = lab.getBytes();
         int port = Constants.PORT;
         socket.send(new DatagramPacket(data, data.length, address, port));
         byte[] response = new byte[256];
         DatagramPacket packet = new DatagramPacket(response, response.length);
         socket.receive(packet);
         String receivedIp = new String(packet.getData()).trim();
         socket.close();
         return receivedIp;
      } catch (Exception ex) {
         Logger.getLogger(ServiceLocator.class.getName()).log(Level.SEVERE, null, ex);
      }
      return null;
   }

}

Ignore Space Show notes View src/discovery/computername/ComputerNameResolver.java 0 → 100644
package discovery; /** * * @author Mark */ public class ComputerNameResolver { private ComputerNameResolver() { } public static String getName() { // return System.getenv("COMPUTERNAME"); // return "SBEASTCAL1-01"; return "SBEASTCAL1-30"; } }

Ignore Space Show notes View src/discovery/computername/OtagoComputerNameResolver.java 0 → 100644
package discovery; /** * * @author Mark */ public class ComputerNameResolver { private ComputerNameResolver() { } public static String getName() { // return System.getenv("COMPUTERNAME"); // return "SBEASTCAL1-01"; return "SBEASTCAL1-30"; } }

Ignore Space Show notes View src/discovery/server/BroadcastResponder.java 0 → 100644
package discovery; 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 String lab; public BroadcastResponder(String lab) { this.setDaemon(true); this.lab = lab; } @Override public void run() { try { MulticastSocket socket = new MulticastSocket(Constants.PORT); socket.joinGroup(InetAddress.getByName(Constants.BROADCAST_ADDRESS)); while (true) { byte[] buffer = new byte[255]; DatagramPacket packet = new DatagramPacket(buffer, buffer.length); socket.receive(packet); String requestedLab = new String(packet.getData()).trim(); if (requestedLab.equalsIgnoreCase(lab)) { String serverIp = this.getServerIp(); buffer = serverIp.getBytes(); socket.send(new DatagramPacket(buffer, buffer.length, packet.getAddress(), packet.getPort())); } } } catch (Exception ex) { 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 (Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements();) { NetworkInterface intf = en.nextElement(); for (Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements();) { InetAddress inetAddress = enumIpAddr.nextElement(); try { // FIXME: quick hack to ensure we are only getting IPv4 addresses - need to test what happens with IPv6 addresses in the labs Inet4Address testIfIpv4 = (Inet4Address) inetAddress; if (!inetAddress.isLoopbackAddress()) { return inetAddress.getHostAddress().toString(); } } catch (ClassCastException ignored) { // ignored } } } } catch (Exception ex) { LOG.log(Level.SEVERE, null, ex); } return null; } }

Ignore Space Show notes View

src/discovery/server/BroadcastResponder.java 0 → 100644

package discovery;

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 String lab;

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

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

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

Ignore Space Show notes View src/discovery/server/ServiceLocator.java 0 → 100644
package discovery; 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(String lab) { try { DatagramSocket socket = new DatagramSocket(); InetAddress address = InetAddress.getByName(Constants.BROADCAST_ADDRESS); byte[] data = lab.getBytes(); int port = Constants.PORT; socket.send(new DatagramPacket(data, data.length, address, port)); byte[] response = new byte[256]; DatagramPacket packet = new DatagramPacket(response, response.length); socket.receive(packet); String receivedIp = new String(packet.getData()).trim(); socket.close(); return receivedIp; } catch (Exception ex) { Logger.getLogger(ServiceLocator.class.getName()).log(Level.SEVERE, null, ex); } return null; } }

Ignore Space Show notes View

src/discovery/server/ServiceLocator.java 0 → 100644

package discovery;

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 {

}

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

Ignore Space Show notes View

src/gui/processors/AbstractLabelProcessor.java 0 → 100644

package gui.processors;

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

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

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

public abstract MouseAdapter getMouseAdapter();

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

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

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

label.addMouseListener(this.getMouseAdapter());

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

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

final String queueStr = queue.toString();

final JLabel label = labels.get(id);

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

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

String queueStr = queue.toString();

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

final JLabel label = labels.get(id);

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

public Collection<Integer> getQueue() {
      synchronized (queue) {
         // Creating a copy of queue to prevent ConcurrentModification errors.
         // This only works because queue is locked by the sync block
         return new ArrayList<Integer>(queue);
      }
   }
}

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

Show notes View

src/gui/processors/LabelProcessor.java 100644 → 0

package gui.processors;

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

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

public abstract MouseAdapter getMouseAdapter();

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

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

label.addMouseListener(this.getMouseAdapter());

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

final String queueStr = queue.toString();

final JLabel label = labels.get(id);

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

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

String queueStr = queue.toString();

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

final JLabel label = labels.get(id);

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

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

Ignore Space Show notes View

tests/BroadcasterTest.java 0 → 100644

Show line notes below