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.23 2001/03/05 09:50:58 tdb1 Exp $
 */
class HostInit extends Thread {

//---FINAL ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public final String REVISION = "$Revision: 1.23 $";
    
//---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 (ComponentCORBAException e) {
                            _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 (and tell the host!)
                            _socketOut.println("ERROR");
                            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.24
Committed:	Mon Mar 5 23:53:39 2001 UTC (23 years, 2 months ago) by tdb
Branch:	MAIN
Changes since 1.23:	+4 -3 lines
Log Message:	The filtermanager returns something more useful to the Host if it can't find a filter for it.
#	User	Rev	Content
1	tdb	1.1	//---PACKAGE DECLARATION---
2	tdb	1.9	package uk.ac.ukc.iscream.filtermanager;
3	tdb	1.1
4			//---IMPORTS---
5			import uk.ac.ukc.iscream.core.*;
6	tdb	1.7	import uk.ac.ukc.iscream.filter.*;
7	tdb	1.11	import uk.ac.ukc.iscream.util.*;
8	tdb	1.14	import uk.ac.ukc.iscream.componentmanager.*;
9	tdb	1.18	import java.net.*;
10	tdb	1.1	import java.io.*;
11	tdb	1.22	import java.util.*;
12	tdb	1.1
13			/**
14	tdb	1.11	* Handles setting up a host.
15	ajm	1.12	* This class provides a host with appropriate configuration
16			* and a reference to a Filter to which it should pass data.
17	tdb	1.1	*
18	tdb	1.15	* @author $Author: tdb1 $
19	tdb	1.24	* @version $Id: HostInit.java,v 1.23 2001/03/05 09:50:58 tdb1 Exp $
20	tdb	1.1	*/
21			class HostInit extends Thread {
22
23			//---FINAL ATTRIBUTES---
24
25			/**
26			* The current CVS revision of this class
27			*/
28	tdb	1.24	public final String REVISION = "$Revision: 1.23 $";
29	tdb	1.1
30			//---STATIC METHODS---
31
32			//---CONSTRUCTORS---
33
34	tdb	1.15	/**
35			* Construct a new HostInit.
36			*
37			* @param socket The socket to which the host is connected
38			*/
39	tdb	1.11	public HostInit(Socket socket) throws IOException {
40	tdb	1.1	_socket = socket;
41	tdb	1.15	// setup reader & writer
42	tdb	1.1	_socketIn = new BufferedReader(new InputStreamReader(_socket.getInputStream()));
43	tdb	1.16	_socketOut = new PrintWriter(_socket.getOutputStream(), true);
44	tdb	1.11	_logger.write(toString(), Logger.SYSINIT, "created");
45	tdb	1.1	}
46
47			//---PUBLIC METHODS---
48
49	tdb	1.15	/**
50			* Main method in this class, which handles communicating with
51			* the host to determine it's setup.
52			*/
53	tdb	1.1	public void run() {
54			try {
55			String inBound = _socketIn.readLine();
56			if (!inBound.equals("STARTCONFIG")) {
57			_socketOut.println("ERROR");
58	tdb	1.7	throw new IOException("protocol error - expected:STARTCONFIG got:" + inBound);
59	tdb	1.1	}
60
61	ajm	1.8	Configuration myConfig = _configManager.getConfiguration("Host." + _socket.getInetAddress().getHostName().toLowerCase());
62	tdb	1.1	if (myConfig == null) {
63			_socketOut.println("ERROR");
64	tdb	1.7	throw new IOException("error in host configuration");
65	tdb	1.1	} else {
66			_socketOut.println("OK");
67
68	tdb	1.2	// get lastmodified
69			inBound = _socketIn.readLine();
70	tdb	1.4	if(!inBound.equals("LASTMODIFIED")) {
71			// protocol error
72	tdb	1.2	_socketOut.println("ERROR");
73	tdb	1.7	throw new IOException("protocol error - expected:LASTMODIFIED got:" + inBound);
74	tdb	1.4	}
75			else {
76			// send info
77			_socketOut.println(myConfig.getLastModified());
78	tdb	1.2	}
79
80	tdb	1.7	// 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	tdb	1.18
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	tdb	1.20	// send the fqdn (of the host) to the host
101	tdb	1.21	_socketOut.println(_socket.getInetAddress().getHostName().toLowerCase());
102	tdb	1.18	}
103
104	tdb	1.2	// get properties
105	tdb	1.1	inBound = _socketIn.readLine();
106			while(!inBound.equals("ENDCONFIG")) {
107
108			// get the property
109			try {
110	tdb	1.10	String returnedProperty = myConfig.getProperty("Host."+inBound);
111	tdb	1.1
112			_socketOut.println(returnedProperty);
113
114			} catch (org.omg.CORBA.MARSHAL e) {
115			_socketOut.println("ERROR");
116			}
117			inBound = _socketIn.readLine();
118			}
119	tdb	1.11	_logger.write(toString(), Logger.SYSMSG, "configured host");
120	tdb	1.1	_socketOut.println("OK");
121	tdb	1.7
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	tdb	1.22	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	tdb	1.23	} catch (ComponentCORBAException e) {
141	tdb	1.22	_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	tdb	1.24	// ...or throw a wobbly (and tell the host!)
155			_socketOut.println("ERROR");
156	tdb	1.22	throw new IOException("unable to find filter for host");
157			}
158	tdb	1.7	}
159
160			// confirm that all is ok
161			inBound = _socketIn.readLine();
162			if(!inBound.equals("END")) {
163			// protocol error
164			_socketOut.println("ERROR");
165			throw new IOException("protocol error - expected:END got:" + inBound);
166			}
167			else {
168			// send ok
169			_socketOut.println("OK");
170			}
171
172	tdb	1.1	}
173
174			} catch (Exception e) {
175	tdb	1.17	_logger.write(toString(), Logger.ERROR, "ERROR - " + e);
176	tdb	1.1	}
177
178			_socketOut.flush();
179			// Disconnect streams & socket
180			try {
181			_socketIn.close();
182			_socketOut.close();
183			_socket.close();
184			} catch (IOException e) {
185	tdb	1.11	_logger.write(toString(), Logger.ERROR, "exception on socket close");
186	tdb	1.1	}
187	tdb	1.11	_logger.write(toString(), Logger.SYSMSG, "finished");
188	tdb	1.1	}
189
190			/**
191			* Overrides the {@link java.lang.Object#toString() Object.toString()}
192			* method to provide clean logging (every class should have this).
193			*
194	ajm	1.12	* This uses the uk.ac.ukc.iscream.util.NameFormat class
195			* to format the toString()
196			*
197	tdb	1.1	* @return the name of this class and its CVS revision
198			*/
199			public String toString() {
200	ajm	1.12	return FormatName.getName(
201			_name,
202	ajm	1.13	getClass().getName(),
203	ajm	1.12	REVISION);
204	tdb	1.1	}
205
206			//---PRIVATE METHODS---
207
208			//---ACCESSOR/MUTATOR METHODS---
209
210			//---ATTRIBUTES---
211
212	tdb	1.11	/**
213	ajm	1.12	* This holds a reference to the
214			* system logger that is being used.
215	tdb	1.11	*/
216	ajm	1.12	private Logger _logger = ReferenceManager.getInstance().getLogger();
217	tdb	1.11
218			/**
219			* A reference to the Configuration Manager the system is using
220			*/
221	ajm	1.12	private ConfigurationManager _configManager = ReferenceManager.getInstance().getCM();
222
223			/**
224			* This is the friendly identifier of the
225			* component this class is running in.
226			* eg, a Filter may be called "filter1",
227			* If this class does not have an owning
228			* component, a name from the configuration
229			* can be placed here. This name could also
230			* be changed to null for utility classes.
231			*/
232			private String _name = FilterManager.NAME;
233
234			/**
235			* The socket this class uses
236			*/
237			private Socket _socket;
238
239			/**
240			* Used for the input stream of this socket
241			*/
242			private BufferedReader _socketIn;
243	tdb	1.11
244	ajm	1.12	/**
245			* Used for the output stream of this socket
246			*/
247			private PrintWriter _socketOut;
248	tdb	1.11
249	tdb	1.1	//---STATIC ATTRIBUTES---
250
251			}