ViewVC Help

View File | Revision Log | Show Annotations | Revision Graph | Root Listing

root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/filter/UDPReader.java

Comparing projects/cms/source/server/uk/org/iscream/cms/server/filter/UDPReader.java (file contents):
Revision 1.7 by ajm, Wed Nov 29 21:27:39 2000 UTC vs.
Revision 1.8 by tdb, Thu Nov 30 02:00:55 2000 UTC

#	Line 7 | Line 7 | import java.net.*;
7		import java.util.*;
8		import uk.ac.ukc.iscream.core.*;
9		import uk.ac.ukc.iscream.filter.*;
10	+	import uk.ac.ukc.iscream.refman.*;
11
12		/**
13		* This class contains the main method to be run by
#	Line 30 | Line 31 | public class UDPReader extends Thread{
31
32		// It is normal to use this constructor in preference
33		// to any other in this class.
34	<	public UDPReader(int port, Filter parent, Logger logger){
35	<	this.logger = logger;
36	<	this.port = port;
36	<	this.parent = parent;
34	>	public UDPReader(int port, Filter parent){
35	>	_port = port;
36	>	_parent = parent;
37		}
38	–
39	–	public UDPReader(Filter parent, Logger logger){
40	–	this(4589, parent, logger);
41	–	}
38
39		//---PUBLIC METHODS---
40
#	Line 46 | Line 42 | public class UDPReader extends Thread{
42
43		DatagramSocket socket = null;
44		try {
45	<	socket = new DatagramSocket(port);
45	>	socket = new DatagramSocket(_port);
46		}
47		catch (BindException e){
48	<	logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+port+" as this port was already in use.");
48	>	_logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+_port+" as this port was already in use.");
49		return;
50		}
51		catch (Exception e){
52	<	logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+port+".");
52	>	_logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+_port+".");
53		return;
54		}
55
56	<	logger.write(this.toString(), Logger.SYSMSG, "UDPReader thread ready and listening for UDP packets on port "+port);
56	>	_logger.write(this.toString(), Logger.SYSMSG, "UDPReader thread ready and listening for UDP packets on port "+_port);
57
58		byte[] buf;
59
#	Line 69 | Line 65 | public class UDPReader extends Thread{
65		buf = new byte[packetSizeLimit];
66		DatagramPacket packet = new DatagramPacket(buf, buf.length);
67		socket.receive(packet);
68	<	FilterThread t = new FilterThread(packet, null,parent, logger);
68	>	FilterThread t = new FilterThread(packet, _parent);
69		t.start();
70
71		}
72		catch (IOException e) {
73	<	logger.write(this.toString(), Logger.WARNING, "This UDPReader thread has been shut down as an exception occured: "+e);
73	>	_logger.write(this.toString(), Logger.WARNING, "This UDPReader thread has been shut down as an exception occured: "+e);
74		return;
75		}
76		}
#	Line 97 | Line 93 | public class UDPReader extends Thread{
93
94		//---ATTRIBUTES---
95
96	<	Logger logger;
97	<	int port;
98	<	Filter parent;
96	>	Logger _logger = ReferenceManager.getInstance().getLogger();
97	>	int _port;
98	>	Filter _parent;
99
100		final int packetSizeLimit = 8192;
101

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines