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/TCPReaderInit.java

Comparing projects/cms/source/server/uk/org/iscream/cms/server/filter/TCPReaderInit.java (file contents):
Revision 1.1 by tdb, Mon Nov 27 00:43:26 2000 UTC vs.
Revision 1.2 by tdb, Mon Nov 27 10:23:32 2000 UTC

#	Line 46 | Line 46 | class TCPReaderInit extends Thread {
46		//NEED TO MAJORILY CHANGE THIS BIT !
47		public void run() {
48		try {
49	<	String inBound = _socketIn.readLine();
50	<	if (!inBound.equals("STARTCONFIG")) {
51	<	_socketOut.println("ERROR");
52	<	_socketOut.flush();
53	<	throw new IOException("protocol error - expected:STARTCONFIG got:" + inBound);
54	<	}
55	<
56	<	Configuration myConfig = _configManager.getConfiguration(_socket.getInetAddress().getHostName().toLowerCase());
57	<	if (myConfig == null) {
58	<	_socketOut.println("ERROR");
59	<	throw new IOException("error in host configuration");
60	<	} else {
61	<	_socketOut.println("OK");
62	<	_socketOut.flush();
63	<
64	<	// get lastmodified
65	<	inBound = _socketIn.readLine();
66	<	if(!inBound.equals("LASTMODIFIED")) {
67	<	// protocol error
68	<	_socketOut.println("ERROR");
69	<	_socketOut.flush();
70	<	throw new IOException("protocol error - expected:LASTMODIFIED got:" + inBound);
71	<	}
72	<	else {
73	<	// send info
74	<	_socketOut.println(myConfig.getLastModified());
75	<	_socketOut.flush();
76	<	}
77	<
78	<	// get config fileList
79	<	inBound = _socketIn.readLine();
80	<	if(!inBound.equals("FILELIST")) {
81	<	// protocol error
82	<	_socketOut.println("ERROR");
83	<	_socketOut.flush();
84	<	throw new IOException("protocol error - expected:FILELIST got:" + inBound);
85	<	}
86	<	else {
87	<	// send info
88	<	_socketOut.println(myConfig.getFileList());
89	<	_socketOut.flush();
90	<	}
91	<
92	<	// get properties
93	<	inBound = _socketIn.readLine();
94	<	while(!inBound.equals("ENDCONFIG")) {
95	<
96	<	// get the property
97	<	try {
98	<	String returnedProperty = myConfig.getProperty(inBound);
99	<
100	<	_socketOut.println(returnedProperty);
101	<	_socketOut.flush();
102	<
103	<	} catch (org.omg.CORBA.MARSHAL e) {
104	<	_socketOut.println("ERROR");
105	<	_socketOut.flush();
106	<	}
107	<	inBound = _socketIn.readLine();
108	<	}
109	<	_logRef.write(toString(), Logger.SYSMSG, "configured host");
110	<	_socketOut.println("OK");
111	<	_socketOut.flush();
112	<
113	<	// get filter reference
114	<	inBound = _socketIn.readLine();
115	<	if(!inBound.equals("FILTER")) {
116	<	// protocol error
117	<	_socketOut.println("ERROR");
118	<	_socketOut.flush();
119	<	throw new IOException("protocol error - expected:FILTER got:" + inBound);
120	<	}
121	<	else {
122	<	// send info
123	<	String parentFilter =  myConfig.getProperty("Host.filter");
124	<	_logRef.write(toString(), Logger.DEBUG, " looking for parent - " + parentFilter);
125	<	org.omg.CORBA.Object objRef = _ncRef.resolve(_ncRef.to_name("iscream.Filter." + parentFilter));
126	<	Filter filter = FilterHelper.narrow(objRef);
127	<	_socketOut.println(filter.getHostName() + ";"
128	<	+ filter.getUDPPort() + ";"
129	<	+ filter.getTCPPort());
130	<	_socketOut.flush();
131	<	}
132	<
133	<	// confirm that all is ok
134	<	inBound = _socketIn.readLine();
135	<	if(!inBound.equals("END")) {
136	<	// protocol error
137	<	_socketOut.println("ERROR");
138	<	_socketOut.flush();
139	<	throw new IOException("protocol error - expected:END got:" + inBound);
140	<	}
141	<	else {
142	<	// send ok
143	<	_socketOut.println("OK");
144	<	_socketOut.flush();
145	<	}
146	<
147	<	}
49	>
50
51		} catch (Exception e) {
52		_logRef.write(toString(), Logger.ERROR, "ERROR: " + e.getMessage());

Diff Legend

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