server/filtermanager/HostInit.java

//---PACKAGE DECLARATION---
package uk.ac.ukc.iscream.filtermanager;

//---IMPORTS---
import uk.ac.ukc.iscream.core.*;
import uk.ac.ukc.iscream.filter.*;
import uk.ac.ukc.iscream.util.*;
import uk.ac.ukc.iscream.componentmanager.*;
import java.net.*;
import java.io.*;
import java.util.*;

/**
 * Handles setting up a host.
 * This class provides a host with appropriate configuration
 * and a reference to a Filter to which it should pass data.
 *
 * @author  $Author: tdb1 $
 * @version $Id: HostInit.java,v 1.21 2001/02/28 11:05:20 tdb1 Exp $
 */
class HostInit extends Thread {

//---FINAL ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public final String REVISION = "$Revision: 1.21 $";
    
//---STATIC METHODS---

//---CONSTRUCTORS---

    /**
     * Construct a new HostInit.
     *
     * @param socket The socket to which the host is connected
     */
    public HostInit(Socket socket) throws IOException {
        _socket = socket;
        // setup reader & writer
        _socketIn = new BufferedReader(new InputStreamReader(_socket.getInputStream()));
        _socketOut = new PrintWriter(_socket.getOutputStream(), true);
        _logger.write(toString(), Logger.SYSINIT, "created");
    }
    
//---PUBLIC METHODS---

    /**
     * Main method in this class, which handles communicating with
     * the host to determine it's setup.
     */
    public void run() {
        try {
            String inBound = _socketIn.readLine();
            if (!inBound.equals("STARTCONFIG")) {
                _socketOut.println("ERROR");
                throw new IOException("protocol error - expected:STARTCONFIG got:" + inBound);
            }

            Configuration myConfig = _configManager.getConfiguration("Host." + _socket.getInetAddress().getHostName().toLowerCase());
            if (myConfig == null) {
                _socketOut.println("ERROR");
                throw new IOException("error in host configuration");
            } else {
                _socketOut.println("OK");
                
                // get lastmodified
                inBound = _socketIn.readLine();
                if(!inBound.equals("LASTMODIFIED")) {
                        // protocol error
                    _socketOut.println("ERROR");
                    throw new IOException("protocol error - expected:LASTMODIFIED got:" + inBound);
                }
                else {
                        // send info
                        _socketOut.println(myConfig.getLastModified());
                }
                
                // get config fileList
                inBound = _socketIn.readLine();
                if(!inBound.equals("FILELIST")) {
                        // protocol error
                    _socketOut.println("ERROR");
                    throw new IOException("protocol error - expected:FILELIST got:" + inBound);
                }
                else {
                        // send info
                        _socketOut.println(myConfig.getFileList());
                }
                
                // send the FQDN to the host
                inBound = _socketIn.readLine();
                if(!inBound.equals("FQDN")) {
                        // protocol error
                    _socketOut.println("ERROR");
                    throw new IOException("protocol error - expected:FQDN got:" + inBound);
                }
                else {
                    // send the fqdn (of the host) to the host
                    _socketOut.println(_socket.getInetAddress().getHostName().toLowerCase());
                }
                
                // get properties
                inBound = _socketIn.readLine();
                while(!inBound.equals("ENDCONFIG")) {
                          
                    // get the property
                    try {
                        String returnedProperty = myConfig.getProperty("Host."+inBound);    
                        
                        _socketOut.println(returnedProperty);
    
                    } catch (org.omg.CORBA.MARSHAL e) {
                        _socketOut.println("ERROR");
                    }
                    inBound = _socketIn.readLine();
                }
                _logger.write(toString(), Logger.SYSMSG, "configured host");
                _socketOut.println("OK");
                
                // get filter reference
                inBound = _socketIn.readLine();
                if(!inBound.equals("FILTER")) {
                        // protocol error
                    _socketOut.println("ERROR");
                    throw new IOException("protocol error - expected:FILTER got:" + inBound);
                }
                else {
                        // send info
                        String filterList = myConfig.getProperty("Host.filter");
                        Filter filterRef = null;
                        String filter = null;
                        StringTokenizer st = new StringTokenizer(filterList, ";");
                    while (filterRef==null && st.hasMoreTokens()) {
                        filter = st.nextToken();
                        _logger.write(toString(), Logger.DEBUG, " looking for filter- " + filter);
                        try {
                            filterRef = FilterHelper.narrow(ReferenceManager.getInstance().getCORBARef("iscream.Filter." + filter));
                        } catch (Exception e) { // THIS SHOULD BE A MORE SPECIFIC EXCEPTION
                            _logger.write(toString(), Logger.DEBUG, " unable to find filter- " + filter);
                        }
                    }
                        
                        // hopefully we found a filter
                    if(filterRef != null) {
                        _logger.write(toString(), Logger.DEBUG, " found filter- " + filter);
                        // tell the host about it...
                            _socketOut.println(filterRef.getHostName() + ";"
                                             + filterRef.getUDPPort() + ";"
                                             + filterRef.getTCPPort());
                        }
                        else {
                            // ...or throw a wobbly
                            throw new IOException("unable to find filter for host");
                        }
                }
                
                // confirm that all is ok
                inBound = _socketIn.readLine();
                if(!inBound.equals("END")) {
                        // protocol error
                    _socketOut.println("ERROR");
                    throw new IOException("protocol error - expected:END got:" + inBound);
                }
                else {
                        // send ok
                        _socketOut.println("OK");
                }

            }
            
        } catch (Exception e) {
            _logger.write(toString(), Logger.ERROR, "ERROR - " + e);
        }
        
        _socketOut.flush();
        // Disconnect streams & socket
        try {
            _socketIn.close();
            _socketOut.close();
            _socket.close();
        } catch (IOException e) {
            _logger.write(toString(), Logger.ERROR, "exception on socket close");
        }
        _logger.write(toString(), Logger.SYSMSG, "finished");
    }
    
    /**
     * Overrides the {@link java.lang.Object#toString() Object.toString()}
     * method to provide clean logging (every class should have this).
     *
     * This uses the uk.ac.ukc.iscream.util.NameFormat class
     * to format the toString()
     *
     * @return the name of this class and its CVS revision
     */
    public String toString() {
        return FormatName.getName(
            _name,
            getClass().getName(),
            REVISION);
    }

//---PRIVATE METHODS---

//---ACCESSOR/MUTATOR METHODS---

//---ATTRIBUTES---

    /**
     * This holds a reference to the
     * system logger that is being used.
     */
    private Logger _logger = ReferenceManager.getInstance().getLogger();
    
    /**
     * A reference to the Configuration Manager the system is using
     */
    private ConfigurationManager _configManager = ReferenceManager.getInstance().getCM();
    
    /**
     * This is the friendly identifier of the
     * component this class is running in.
     * eg, a Filter may be called "filter1",
     * If this class does not have an owning
     * component,  a name from the configuration
     * can be placed here.  This name could also
     * be changed to null for utility classes.
     */
    private String _name = FilterManager.NAME;
    
    /** 
     * The socket this class uses
     */
    private Socket _socket;

    /**
     * Used for the input stream of this socket
     */
    private BufferedReader _socketIn;
    
    /**
     * Used for the output stream of this socket
     */
    private PrintWriter _socketOut;

//---STATIC ATTRIBUTES---

}
Revision:	1.22
Committed:	Mon Mar 5 02:26:01 2001 UTC (23 years, 2 months ago) by tdb
Branch:	MAIN
Changes since 1.21:	+29 -8 lines
Log Message:	One can now specify a list of Filter's for a host. This allows a priority list to be given to a host, and is helpful if a filter isn't active. NOTE: the exception caught when looking for a Filter could be better. PROBLEM?: what if the host gets the secondary filter, but the primary comes back online at a later date ? it won't get it unless told to reconfigure...
#	Content
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.*;
10	import java.io.*;
11	import java.util.*;
12
13	/**
14	* Handles setting up a host.
15	* This class provides a host with appropriate configuration
16	* and a reference to a Filter to which it should pass data.
17	*
18	* @author $Author: tdb1 $
19	* @version $Id: HostInit.java,v 1.21 2001/02/28 11:05:20 tdb1 Exp $
20	*/
21	class HostInit extends Thread {
22
23	//---FINAL ATTRIBUTES---
24
25	/**
26	* The current CVS revision of this class
27	*/
28	public final String REVISION = "$Revision: 1.21 $";
29
30	//---STATIC METHODS---
31
32	//---CONSTRUCTORS---
33
34	/**
35	* Construct a new HostInit.
36	*
37	* @param socket The socket to which the host is connected
38	*/
39	public HostInit(Socket socket) throws IOException {
40	_socket = socket;
41	// setup reader & writer
42	_socketIn = new BufferedReader(new InputStreamReader(_socket.getInputStream()));
43	_socketOut = new PrintWriter(_socket.getOutputStream(), true);
44	_logger.write(toString(), Logger.SYSINIT, "created");
45	}
46
47	//---PUBLIC METHODS---
48
49	/**
50	* Main method in this class, which handles communicating with
51	* the host to determine it's setup.
52	*/
53	public void run() {
54	try {
55	String inBound = _socketIn.readLine();
56	if (!inBound.equals("STARTCONFIG")) {
57	_socketOut.println("ERROR");
58	throw new IOException("protocol error - expected:STARTCONFIG got:" + inBound);
59	}
60
61	Configuration myConfig = _configManager.getConfiguration("Host." + _socket.getInetAddress().getHostName().toLowerCase());
62	if (myConfig == null) {
63	_socketOut.println("ERROR");
64	throw new IOException("error in host configuration");
65	} else {
66	_socketOut.println("OK");
67
68	// get lastmodified
69	inBound = _socketIn.readLine();
70	if(!inBound.equals("LASTMODIFIED")) {
71	// protocol error
72	_socketOut.println("ERROR");
73	throw new IOException("protocol error - expected:LASTMODIFIED got:" + inBound);
74	}
75	else {
76	// send info
77	_socketOut.println(myConfig.getLastModified());
78	}
79
80	// get config fileList
81	inBound = _socketIn.readLine();
82	if(!inBound.equals("FILELIST")) {
83	// protocol error
84	_socketOut.println("ERROR");
85	throw new IOException("protocol error - expected:FILELIST got:" + inBound);
86	}
87	else {
88	// send info
89	_socketOut.println(myConfig.getFileList());
90	}
91
92	// send the FQDN to the host
93	inBound = _socketIn.readLine();
94	if(!inBound.equals("FQDN")) {
95	// protocol error
96	_socketOut.println("ERROR");
97	throw new IOException("protocol error - expected:FQDN got:" + inBound);
98	}
99	else {
100	// send the fqdn (of the host) to the host
101	_socketOut.println(_socket.getInetAddress().getHostName().toLowerCase());
102	}
103
104	// get properties
105	inBound = _socketIn.readLine();
106	while(!inBound.equals("ENDCONFIG")) {
107
108	// get the property
109	try {
110	String returnedProperty = myConfig.getProperty("Host."+inBound);
111
112	_socketOut.println(returnedProperty);
113
114	} catch (org.omg.CORBA.MARSHAL e) {
115	_socketOut.println("ERROR");
116	}
117	inBound = _socketIn.readLine();
118	}
119	_logger.write(toString(), Logger.SYSMSG, "configured host");
120	_socketOut.println("OK");
121
122	// get filter reference
123	inBound = _socketIn.readLine();
124	if(!inBound.equals("FILTER")) {
125	// protocol error
126	_socketOut.println("ERROR");
127	throw new IOException("protocol error - expected:FILTER got:" + inBound);
128	}
129	else {
130	// send info
131	String filterList = myConfig.getProperty("Host.filter");
132	Filter filterRef = null;
133	String filter = null;
134	StringTokenizer st = new StringTokenizer(filterList, ";");
135	while (filterRef==null && st.hasMoreTokens()) {
136	filter = st.nextToken();
137	_logger.write(toString(), Logger.DEBUG, " looking for filter- " + filter);
138	try {
139	filterRef = FilterHelper.narrow(ReferenceManager.getInstance().getCORBARef("iscream.Filter." + filter));
140	} catch (Exception e) { // THIS SHOULD BE A MORE SPECIFIC EXCEPTION
141	_logger.write(toString(), Logger.DEBUG, " unable to find filter- " + filter);
142	}
143	}
144
145	// hopefully we found a filter
146	if(filterRef != null) {
147	_logger.write(toString(), Logger.DEBUG, " found filter- " + filter);
148	// tell the host about it...
149	_socketOut.println(filterRef.getHostName() + ";"
150	+ filterRef.getUDPPort() + ";"
151	+ filterRef.getTCPPort());
152	}
153	else {
154	// ...or throw a wobbly
155	throw new IOException("unable to find filter for host");
156	}
157	}
158
159	// confirm that all is ok
160	inBound = _socketIn.readLine();
161	if(!inBound.equals("END")) {
162	// protocol error
163	_socketOut.println("ERROR");
164	throw new IOException("protocol error - expected:END got:" + inBound);
165	}
166	else {
167	// send ok
168	_socketOut.println("OK");
169	}
170
171	}
172
173	} catch (Exception e) {
174	_logger.write(toString(), Logger.ERROR, "ERROR - " + e);
175	}
176
177	_socketOut.flush();
178	// Disconnect streams & socket
179	try {
180	_socketIn.close();
181	_socketOut.close();
182	_socket.close();
183	} catch (IOException e) {
184	_logger.write(toString(), Logger.ERROR, "exception on socket close");
185	}
186	_logger.write(toString(), Logger.SYSMSG, "finished");
187	}
188
189	/**
190	* Overrides the {@link java.lang.Object#toString() Object.toString()}
191	* method to provide clean logging (every class should have this).
192	*
193	* This uses the uk.ac.ukc.iscream.util.NameFormat class
194	* to format the toString()
195	*
196	* @return the name of this class and its CVS revision
197	*/
198	public String toString() {
199	return FormatName.getName(
200	_name,
201	getClass().getName(),
202	REVISION);
203	}
204
205	//---PRIVATE METHODS---
206
207	//---ACCESSOR/MUTATOR METHODS---
208
209	//---ATTRIBUTES---
210
211	/**
212	* This holds a reference to the
213	* system logger that is being used.
214	*/
215	private Logger _logger = ReferenceManager.getInstance().getLogger();
216
217	/**
218	* A reference to the Configuration Manager the system is using
219	*/
220	private ConfigurationManager _configManager = ReferenceManager.getInstance().getCM();
221
222	/**
223	* This is the friendly identifier of the
224	* component this class is running in.
225	* eg, a Filter may be called "filter1",
226	* If this class does not have an owning
227	* component, a name from the configuration
228	* can be placed here. This name could also
229	* be changed to null for utility classes.
230	*/
231	private String _name = FilterManager.NAME;
232
233	/**
234	* The socket this class uses
235	*/
236	private Socket _socket;
237
238	/**
239	* Used for the input stream of this socket
240	*/
241	private BufferedReader _socketIn;
242
243	/**
244	* Used for the output stream of this socket
245	*/
246	private PrintWriter _socketOut;
247
248	//---STATIC ATTRIBUTES---
249
250	}