ViewVC Help

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

root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/filtermanager/HostInit.java

Comparing projects/cms/source/server/uk/org/iscream/cms/server/filtermanager/HostInit.java (file contents):
Revision 1.3 by tdb, Wed Nov 15 00:39:07 2000 UTC vs.
Revision 1.15 by tdb, Sun Jan 28 05:38:13 2001 UTC

#	Line 1 | Line 1
1		//---PACKAGE DECLARATION---
2	+	package uk.ac.ukc.iscream.filtermanager;
3
4		//---IMPORTS---
5		import uk.ac.ukc.iscream.core.*;
6	+	import uk.ac.ukc.iscream.filter.*;
7	+	import uk.ac.ukc.iscream.util.*;
8	+	import uk.ac.ukc.iscream.componentmanager.*;
9		import java.net.Socket;
6	–	import java.io.InputStream;
7	–	import java.io.OutputStream;
8	–	import java.io.IOException;
10		import java.io.*;
11
12		/**
13	<	* <ONE LINE DESCRIPTION>
14	<	* <DETAILED DESCRIPTION>
13	>	* Handles setting up a host.
14	>	* This class provides a host with appropriate configuration
15	>	* and a reference to a Filter to which it should pass data.
16		*
17		* @author  $Author$
18		* @version $Id$
#	Line 28 | Line 30 | class HostInit extends Thread {
30
31		//---CONSTRUCTORS---
32
33	<	public HostInit(Socket socket, Configurator configurator, Logger logger) throws IOException {
34	<	_configurator = configurator;
35	<	_logger = logger;
33	>	/**
34	>	* Construct a new HostInit.
35	>	*
36	>	* @param socket The socket to which the host is connected
37	>	*/
38	>	public HostInit(Socket socket) throws IOException {
39		_socket = socket;
40	+	// setup reader & writer
41		_socketIn = new BufferedReader(new InputStreamReader(_socket.getInputStream()));
42		_socketOut = new PrintWriter(_socket.getOutputStream());
43	<	_logger.write(toString(), "created");
43	>	_logger.write(toString(), Logger.SYSINIT, "created");
44		}
45
46		//---PUBLIC METHODS---
47
48	+	/**
49	+	* Main method in this class, which handles communicating with
50	+	* the host to determine it's setup.
51	+	*/
52		public void run() {
53		try {
54		String inBound = _socketIn.readLine();
55		if (!inBound.equals("STARTCONFIG")) {
56		_socketOut.println("ERROR");
57		_socketOut.flush();
58	<	throw new IOException("Protocol Error");
58	>	throw new IOException("protocol error - expected:STARTCONFIG got:" + inBound);
59		}
60
61	<	Configuration myConfig = _configurator.getConfiguration(_socket.getInetAddress().getHostName().toLowerCase());
61	>	Configuration myConfig = _configManager.getConfiguration("Host." + _socket.getInetAddress().getHostName().toLowerCase());
62		if (myConfig == null) {
63		_socketOut.println("ERROR");
64	<	throw new IOException("No Configuration File For Host");
64	>	throw new IOException("error in host configuration");
65		} else {
66		_socketOut.println("OK");
67		_socketOut.flush();
68
69		// get lastmodified
70		inBound = _socketIn.readLine();
71	<	while(!inBound.equals("LASTMODIFIED")) {
71	>	if(!inBound.equals("LASTMODIFIED")) {
72	>	// protocol error
73		_socketOut.println("ERROR");
74		_socketOut.flush();
75	<	inBound = _socketIn.readLine();
75	>	throw new IOException("protocol error - expected:LASTMODIFIED got:" + inBound);
76		}
77	<	_socketOut.println(myConfig.getLastModified());
78	<	_socketOut.flush();
77	>	else {
78	>	// send info
79	>	_socketOut.println(myConfig.getLastModified());
80	>	_socketOut.flush();
81	>	}
82
83	+	// get config fileList
84	+	inBound = _socketIn.readLine();
85	+	if(!inBound.equals("FILELIST")) {
86	+	// protocol error
87	+	_socketOut.println("ERROR");
88	+	_socketOut.flush();
89	+	throw new IOException("protocol error - expected:FILELIST got:" + inBound);
90	+	}
91	+	else {
92	+	// send info
93	+	_socketOut.println(myConfig.getFileList());
94	+	_socketOut.flush();
95	+	}
96	+
97		// get properties
98		inBound = _socketIn.readLine();
99		while(!inBound.equals("ENDCONFIG")) {
100
101		// get the property
102		try {
103	<	String returnedProperty = myConfig.getProperty(inBound);
103	>	String returnedProperty = myConfig.getProperty("Host."+inBound);
104
105		_socketOut.println(returnedProperty);
106		_socketOut.flush();
#	Line 83 | Line 111 | class HostInit extends Thread {
111		}
112		inBound = _socketIn.readLine();
113		}
114	<	_logger.write(toString(), "configured host");
114	>	_logger.write(toString(), Logger.SYSMSG, "configured host");
115		_socketOut.println("OK");
116		_socketOut.flush();
117	+
118	+	// get filter reference
119	+	inBound = _socketIn.readLine();
120	+	if(!inBound.equals("FILTER")) {
121	+	// protocol error
122	+	_socketOut.println("ERROR");
123	+	_socketOut.flush();
124	+	throw new IOException("protocol error - expected:FILTER got:" + inBound);
125	+	}
126	+	else {
127	+	// send info
128	+	String parentFilter =  myConfig.getProperty("Host.filter");
129	+	_logger.write(toString(), Logger.DEBUG, " looking for parent - " + parentFilter);
130	+	Filter filter = FilterHelper.narrow(ReferenceManager.getInstance().getCORBARef("iscream.Filter." + parentFilter));
131	+	_socketOut.println(filter.getHostName() + ";"
132	+	+ filter.getUDPPort() + ";"
133	+	+ filter.getTCPPort());
134	+	_socketOut.flush();
135	+	}
136	+
137	+	// confirm that all is ok
138	+	inBound = _socketIn.readLine();
139	+	if(!inBound.equals("END")) {
140	+	// protocol error
141	+	_socketOut.println("ERROR");
142	+	_socketOut.flush();
143	+	throw new IOException("protocol error - expected:END got:" + inBound);
144	+	}
145	+	else {
146	+	// send ok
147	+	_socketOut.println("OK");
148	+	_socketOut.flush();
149	+	}
150	+
151		}
152
153		} catch (Exception e) {
154	<	_logger.write(toString(), e.toString());
154	>	_logger.write(toString(), Logger.ERROR, "ERROR - " + e.getMessage());
155		}
156
157		_socketOut.flush();
#	Line 99 | Line 161 | class HostInit extends Thread {
161		_socketOut.close();
162		_socket.close();
163		} catch (IOException e) {
164	<	_logger.write(toString(), "exception on socket close");
164	>	_logger.write(toString(), Logger.ERROR, "exception on socket close");
165		}
166	<	_logger.write(toString(), "finished");
166	>	_logger.write(toString(), Logger.SYSMSG, "finished");
167		}
168
169		/**
170		* Overrides the {@link java.lang.Object#toString() Object.toString()}
171		* method to provide clean logging (every class should have this).
172		*
173	+	* This uses the uk.ac.ukc.iscream.util.NameFormat class
174	+	* to format the toString()
175	+	*
176		* @return the name of this class and its CVS revision
177		*/
178		public String toString() {
179	<	return this.getClass().getName() + "{" + _socket.getInetAddress().getHostName()
180	<	+ "}(" + REVISION.substring(11, REVISION.length() - 2) + ")";
181	<
179	>	return FormatName.getName(
180	>	_name,
181	>	getClass().getName(),
182	>	REVISION);
183		}
184
185		//---PRIVATE METHODS---
#	Line 122 | Line 188 | class HostInit extends Thread {
188
189		//---ATTRIBUTES---
190
191	<	Configurator _configurator;
192	<	Logger _logger;
193	<	Socket _socket;
194	<	BufferedReader _socketIn;
195	<	PrintWriter _socketOut;
191	>	/**
192	>	* This holds a reference to the
193	>	* system logger that is being used.
194	>	*/
195	>	private Logger _logger = ReferenceManager.getInstance().getLogger();
196	>
197	>	/**
198	>	* A reference to the Configuration Manager the system is using
199	>	*/
200	>	private ConfigurationManager _configManager = ReferenceManager.getInstance().getCM();
201	>
202	>	/**
203	>	* This is the friendly identifier of the
204	>	* component this class is running in.
205	>	* eg, a Filter may be called "filter1",
206	>	* If this class does not have an owning
207	>	* component,  a name from the configuration
208	>	* can be placed here.  This name could also
209	>	* be changed to null for utility classes.
210	>	*/
211	>	private String _name = FilterManager.NAME;
212	>
213	>	/**
214	>	* The socket this class uses
215	>	*/
216	>	private Socket _socket;
217	>
218	>	/**
219	>	* Used for the input stream of this socket
220	>	*/
221	>	private BufferedReader _socketIn;
222	>
223	>	/**
224	>	* Used for the output stream of this socket
225	>	*/
226	>	private PrintWriter _socketOut;
227
228		//---STATIC ATTRIBUTES---
229

Diff Legend

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