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.6 by tdb, Wed Nov 29 19:26:00 2000 UTC vs.
Revision 1.10 by ajm, Wed Dec 13 13:36:46 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.util.*;
11
12		/**
13		* This class contains the main method to be run by
#	Line 28 | Line 29 | public class UDPReader extends Thread{
29
30		//---CONSTRUCTORS---
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;
37	<	this.parent = parent;
32	>	/**
33	>	* It is normal to use this constructor in preference
34	>	* to any other in this class.
35	>	*/
36	>	public UDPReader(int port, Filter parent){
37	>	_port = port;
38	>	_parent = parent;
39		}
38	–
39	–	public UDPReader(Filter parent, Logger logger){
40	–	this(4589, parent, logger);
41	–	}
40
41		//---PUBLIC METHODS---
42
#	Line 46 | Line 44 | public class UDPReader extends Thread{
44
45		DatagramSocket socket = null;
46		try {
47	<	socket = new DatagramSocket(port);
47	>	socket = new DatagramSocket(_port);
48		}
49		catch (BindException e){
50	<	logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+port+" as this port was already in use.");
50	>	_logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+_port+" as this port was already in use.");
51		return;
52		}
53		catch (Exception e){
54	<	logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+port+".");
54	>	_logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+_port+".");
55		return;
56		}
57
58	<	logger.write(this.toString(), Logger.SYSMSG, "UDPReader thread ready and listening for UDP packets on port "+port);
58	>	_logger.write(this.toString(), Logger.SYSMSG, "UDPReader thread ready and listening for UDP packets on port "+_port);
59
60		byte[] buf;
61
#	Line 69 | Line 67 | public class UDPReader extends Thread{
67		buf = new byte[packetSizeLimit];
68		DatagramPacket packet = new DatagramPacket(buf, buf.length);
69		socket.receive(packet);
70	<	FilterThread t = new FilterThread(packet, parent, logger);
70	>	FilterThread t = new FilterThread(packet, _parent);
71		t.start();
72
73		}
74		catch (IOException e) {
75	<	logger.write(this.toString(), Logger.WARNING, "This UDPReader thread has been shut down as an exception occured: "+e);
75	>	_logger.write(this.toString(), Logger.WARNING, "This UDPReader thread has been shut down as an exception occured: "+e);
76		return;
77		}
78		}
#	Line 97 | Line 95 | public class UDPReader extends Thread{
95
96		//---ATTRIBUTES---
97
98	<	Logger logger;
99	<	int port;
100	<	Filter parent;
98	>	Logger _logger = ReferenceManager.getInstance().getLogger();
99	>	int _port;
100	>	Filter _parent;
101
102		final int packetSizeLimit = 8192;
103

Diff Legend

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