--- projects/cms/source/server/uk/org/iscream/cms/server/filter/UDPReader.java 2000/11/22 09:32:00 1.2 +++ projects/cms/source/server/uk/org/iscream/cms/server/filter/UDPReader.java 2000/11/23 09:08:07 1.3 @@ -7,7 +7,6 @@ import uk.ac.ukc.iscream.filter.*; // This class contains the main method to be run by // the filter children. It harvests UDP traffic. // -// public class UDPReader extends Thread{ // It is normal to use this constructor in preference @@ -44,12 +43,14 @@ public class UDPReader extends Thread{ boolean running = true; while (running){ try { + + // receive request and pass on to the FilterThread. buf = new byte[packetSizeLimit]; - // receive request DatagramPacket packet = new DatagramPacket(buf, buf.length); socket.receive(packet); - FilterThread t = new FilterThread(parent); - t.run(packet); + FilterThread t = new FilterThread(parent, packet); + t.start(); + } catch (IOException e) { logger.write(this.toString(), Logger.SYSMSG, "The UDPReader thread has been shut down as an exception occured: "+e);