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.12 by tdb, Fri Jan 12 00:45:25 2001 UTC vs.
Revision 1.23 by tdb, Sat May 18 18:16:02 2002 UTC

#	Line 1 | Line 1
1	+	/*
2	+	* i-scream central monitoring system
3	+	* Copyright (C) 2000-2002 i-scream
4	+	*
5	+	* This program is free software; you can redistribute it and/or
6	+	* modify it under the terms of the GNU General Public License
7	+	* as published by the Free Software Foundation; either version 2
8	+	* of the License, or (at your option) any later version.
9	+	*
10	+	* This program is distributed in the hope that it will be useful,
11	+	* but WITHOUT ANY WARRANTY; without even the implied warranty of
12	+	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13	+	* GNU General Public License for more details.
14	+	*
15	+	* You should have received a copy of the GNU General Public License
16	+	* along with this program; if not, write to the Free Software
17	+	* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
18	+	*/
19	+
20		//---PACKAGE DECLARATION---
21	<	package uk.ac.ukc.iscream.filter;
21	>	package uk.org.iscream.cms.server.filter;
22
23		//---IMPORTS---
24		import java.io.*;
25		import java.net.*;
26		import java.util.*;
27	<	import uk.ac.ukc.iscream.core.*;
28	<	import uk.ac.ukc.iscream.filter.*;
29	<	import uk.ac.ukc.iscream.util.*;
27	>	import uk.org.iscream.cms.server.core.*;
28	>	import uk.org.iscream.cms.server.componentmanager.*;
29	>	import uk.org.iscream.cms.server.filter.*;
30	>	import uk.org.iscream.cms.server.util.*;
31
32		/**
33		* This class contains the main method to be run by
34	<	* the filter children.  It harvests UDP traffic.
34	>	* the filterd.  It harvests UDP traffic, and queues it.
35		*
36		* @author  $Author$
37		* @version $Id$
#	Line 24 | Line 44 | public class UDPReader extends Thread{
44		* The current CVS revision of this class
45		*/
46		public final String REVISION = "$Revision$";
47	<
47	>
48		/**
49		* The maximum size of a packet
50		*/
#	Line 35 | Line 55 | public class UDPReader extends Thread{
55		//---CONSTRUCTORS---
56
57		/**
58	<	* It is normal to use this constructor in preference
59	<	* to any other in this class.
58	>	* Constructs a new UDPReader.
59	>	*
60	>	* @param port The port on which we listen for UDP data
61	>	* @param queue The queue which we are using
62		*/
63		public UDPReader(int port, Queue queue){
64	+	// set the Thread name
65	+	setName("filter.UDPReader");
66	+
67		_port = port;
68		_queue = queue;
69	+	_logger.write(toString(), Logger.SYSINIT, "started");
70		}
71
72		//---PUBLIC METHODS---
73	<
73	>
74	>	/**
75	>	* The main method in the class. Reads and queues XML sent
76	>	* over UDP.
77	>	*/
78		public void run() {
79	<
79	>	// setup an empty ACL defaulting to ALLOW
80	>	ACL acl = new ACL(ACL.ALLOW);
81	>
82	>	// setup a Datagram socket
83		DatagramSocket socket = null;
84		try {
85	<	socket = new DatagramSocket(_port);
85	>	socket = new ACLDatagramSocket(acl, _port);
86		}
87		catch (BindException e){
88		_logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+_port+" as this port was already in use.");
#	Line 61 | Line 94 | public class UDPReader extends Thread{
94		}
95
96		_logger.write(this.toString(), Logger.SYSMSG, "UDPReader thread ready and listening for UDP packets on port "+_port);
97	<
97	>
98		byte[] buf;
99
100	+	ConfigurationProxy cp = ConfigurationProxy.getInstance();
101	+	String stringACL = "";
102	+	String newStringACL = "";
103	+
104	+	// read UDP packets and queue them
105		boolean running = true;
106		while (running){
107	+	// get hold of the ACL in the configuration
108		try {
109	<
110	<	// receive request and put it in the Queue
109	>	newStringACL = cp.getProperty("Filter." + FilterMain.NAME, "Filter.UDPACL");
110	>	}
111	>	catch(PropertyNotFoundException e) {
112	>	// if we can't find it, we'll just use a null ACL
113	>	newStringACL = "";
114	>	_logger.write(toString(), Logger.WARNING, "No ACL found for UDPReader, using empty ACL instead: " + e);
115	>	}
116	>	// check to see if the ACL has changed
117	>	if(!newStringACL.equals(stringACL)) {
118	>	_logger.write(toString(), Logger.SYSMSG, "Reloading Access Control List");
119	>	// clear the ACL
120	>	acl.clear();
121	>	// set the default to something sane
122	>	acl.setDefaultMode(ACL.ALLOW);
123	>	// add the new ACL (this may change the default)
124	>	acl.add(newStringACL);
125	>	stringACL = newStringACL;
126	>	}
127	>	try {
128	>
129	>	// receive request and put it in the Queue
130		buf = new byte[packetSizeLimit];
131		DatagramPacket packet = new DatagramPacket(buf, buf.length);
132		socket.receive(packet);
#	Line 77 | Line 135 | public class UDPReader extends Thread{
135		}
136		catch (IOException e) {
137		_logger.write(this.toString(), Logger.WARNING, "This UDPReader thread has been shut down as an exception occured: "+e);
138	<	return;
138	>	running = false;
139		}
140		}
141		socket.close();
142		}
143	<
143	>
144		/**
145		* Overrides the {@link java.lang.Object#toString() Object.toString()}
146		* method to provide clean logging (every class should have this).
147		*
148	<	* This uses the uk.ac.ukc.iscream.util.NameFormat class
148	>	* This uses the uk.org.iscream.cms.server.util.NameFormat class
149		* to format the toString()
150		*
151		* @return the name of this class and its CVS revision
#	Line 115 | Line 173 | public class UDPReader extends Thread{
173		* be changed to null for utility classes.
174		*/
175		private String _name = FilterMain.NAME;
176	<
176	>
177		/**
178		* This holds a reference to the
179		* system logger that is being used.
#	Line 130 | Line 188 | public class UDPReader extends Thread{
188		/**
189		* The Queue object
190		*/
191	<	Queue _queue;
191	>	Queue _queue;
192
193		//---STATIC ATTRIBUTES---
194

Diff Legend

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