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.14 by tdb, Thu Jan 18 23:15:09 2001 UTC vs.
Revision 1.17 by tdb, Sun Feb 25 23:19:20 2001 UTC

#	Line 30 | Line 30 | class HostInit extends Thread {
30
31		//---CONSTRUCTORS---
32
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());
42	>	_socketOut = new PrintWriter(_socket.getOutputStream(), true);
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");
47	–	_socketOut.flush();
57		throw new IOException("protocol error - expected:STARTCONFIG got:" + inBound);
58		}
59
#	Line 54 | Line 63 | class HostInit extends Thread {
63		throw new IOException("error in host configuration");
64		} else {
65		_socketOut.println("OK");
57	–	_socketOut.flush();
66
67		// get lastmodified
68		inBound = _socketIn.readLine();
69		if(!inBound.equals("LASTMODIFIED")) {
70		// protocol error
71		_socketOut.println("ERROR");
64	–	_socketOut.flush();
72		throw new IOException("protocol error - expected:LASTMODIFIED got:" + inBound);
73		}
74		else {
75		// send info
76		_socketOut.println(myConfig.getLastModified());
70	–	_socketOut.flush();
77		}
78
79		// get config fileList
#	Line 75 | Line 81 | class HostInit extends Thread {
81		if(!inBound.equals("FILELIST")) {
82		// protocol error
83		_socketOut.println("ERROR");
78	–	_socketOut.flush();
84		throw new IOException("protocol error - expected:FILELIST got:" + inBound);
85		}
86		else {
87		// send info
88		_socketOut.println(myConfig.getFileList());
84	–	_socketOut.flush();
89		}
90
91		// get properties
#	Line 93 | Line 97 | class HostInit extends Thread {
97		String returnedProperty = myConfig.getProperty("Host."+inBound);
98
99		_socketOut.println(returnedProperty);
96	–	_socketOut.flush();
100
101		} catch (org.omg.CORBA.MARSHAL e) {
102		_socketOut.println("ERROR");
100	–	_socketOut.flush();
103		}
104		inBound = _socketIn.readLine();
105		}
106		_logger.write(toString(), Logger.SYSMSG, "configured host");
107		_socketOut.println("OK");
106	–	_socketOut.flush();
108
109		// get filter reference
110		inBound = _socketIn.readLine();
111		if(!inBound.equals("FILTER")) {
112		// protocol error
113		_socketOut.println("ERROR");
113	–	_socketOut.flush();
114		throw new IOException("protocol error - expected:FILTER got:" + inBound);
115		}
116		else {
#	Line 121 | Line 121 | class HostInit extends Thread {
121		_socketOut.println(filter.getHostName() + ";"
122		+ filter.getUDPPort() + ";"
123		+ filter.getTCPPort());
124	–	_socketOut.flush();
124		}
125
126		// confirm that all is ok
#	Line 129 | Line 128 | class HostInit extends Thread {
128		if(!inBound.equals("END")) {
129		// protocol error
130		_socketOut.println("ERROR");
132	–	_socketOut.flush();
131		throw new IOException("protocol error - expected:END got:" + inBound);
132		}
133		else {
134		// send ok
135		_socketOut.println("OK");
138	–	_socketOut.flush();
136		}
137
138		}
139
140		} catch (Exception e) {
141	<	_logger.write(toString(), Logger.ERROR, "ERROR - " + e.getMessage());
141	>	_logger.write(toString(), Logger.ERROR, "ERROR - " + e);
142		}
143
144		_socketOut.flush();

Diff Legend

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