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
(Generate patch)

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.18 by tdb, Wed Feb 28 10:27:54 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 java.net.Socket;
7 < import java.io.InputStream;
8 < import java.io.OutputStream;
9 < import java.io.IOException;
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  
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");
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");
57 <                _socketOut.flush();
48 <                throw new IOException("Protocol Error");
57 >                throw new IOException("protocol error - expected:STARTCONFIG got:" + inBound);
58              }
59  
60 <            Configuration myConfig = _configurator.getConfiguration(_socket.getInetAddress().getHostName().toLowerCase());
60 >            Configuration myConfig = _configManager.getConfiguration("Host." + _socket.getInetAddress().getHostName().toLowerCase());
61              if (myConfig == null) {
62                  _socketOut.println("ERROR");
63 <                throw new IOException("No Configuration File For Host");
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 <                while(!inBound.equals("LASTMODIFIED")) {
69 >                if(!inBound.equals("LASTMODIFIED")) {
70 >                        // protocol error
71                      _socketOut.println("ERROR");
72 <                    _socketOut.flush();
64 <                    inBound = _socketIn.readLine();
72 >                    throw new IOException("protocol error - expected:LASTMODIFIED got:" + inBound);
73                  }
74 <                _socketOut.println(myConfig.getLastModified());
75 <                _socketOut.flush();
74 >                else {
75 >                        // send info
76 >                        _socketOut.println(myConfig.getLastModified());
77 >                }
78                  
79 +                // get config fileList
80 +                inBound = _socketIn.readLine();
81 +                if(!inBound.equals("FILELIST")) {
82 +                        // protocol error
83 +                    _socketOut.println("ERROR");
84 +                    throw new IOException("protocol error - expected:FILELIST got:" + inBound);
85 +                }
86 +                else {
87 +                        // send info
88 +                        _socketOut.println(myConfig.getFileList());
89 +                }
90 +                
91 +                // send the FQDN to the host
92 +                inBound = _socketIn.readLine();
93 +                if(!inBound.equals("FQDN")) {
94 +                        // protocol error
95 +                    _socketOut.println("ERROR");
96 +                    throw new IOException("protocol error - expected:FQDN got:" + inBound);
97 +                }
98 +                else {
99 +                    try {
100 +                        // try to send the fqdn to the host
101 +                            _socketOut.println(InetAddress.getLocalHost().getHostName());
102 +                        }
103 +                        catch(UnknownHostException e) {
104 +                            // we failed for some reason
105 +                            _socketOut.println("ERROR");
106 +                        }
107 +                }
108 +                
109                  // get properties
110                  inBound = _socketIn.readLine();
111                  while(!inBound.equals("ENDCONFIG")) {
112                            
113                      // get the property
114                      try {
115 <                        String returnedProperty = myConfig.getProperty(inBound);    
115 >                        String returnedProperty = myConfig.getProperty("Host."+inBound);    
116                          
117                          _socketOut.println(returnedProperty);
78 –                        _socketOut.flush();
118      
119                      } catch (org.omg.CORBA.MARSHAL e) {
120                          _socketOut.println("ERROR");
82 –                        _socketOut.flush();
121                      }
122                      inBound = _socketIn.readLine();
123                  }
124 <                _logger.write(toString(), "configured host");
124 >                _logger.write(toString(), Logger.SYSMSG, "configured host");
125                  _socketOut.println("OK");
126 <                _socketOut.flush();
126 >                
127 >                // get filter reference
128 >                inBound = _socketIn.readLine();
129 >                if(!inBound.equals("FILTER")) {
130 >                        // protocol error
131 >                    _socketOut.println("ERROR");
132 >                    throw new IOException("protocol error - expected:FILTER got:" + inBound);
133 >                }
134 >                else {
135 >                        // send info
136 >                        String parentFilter =  myConfig.getProperty("Host.filter");
137 >                        _logger.write(toString(), Logger.DEBUG, " looking for parent - " + parentFilter);
138 >                    Filter filter = FilterHelper.narrow(ReferenceManager.getInstance().getCORBARef("iscream.Filter." + parentFilter));
139 >                        _socketOut.println(filter.getHostName() + ";"
140 >                                         + filter.getUDPPort() + ";"
141 >                                         + filter.getTCPPort());
142 >                }
143 >                
144 >                // confirm that all is ok
145 >                inBound = _socketIn.readLine();
146 >                if(!inBound.equals("END")) {
147 >                        // protocol error
148 >                    _socketOut.println("ERROR");
149 >                    throw new IOException("protocol error - expected:END got:" + inBound);
150 >                }
151 >                else {
152 >                        // send ok
153 >                        _socketOut.println("OK");
154 >                }
155 >
156              }
157              
158          } catch (Exception e) {
159 <            _logger.write(toString(), e.toString());
159 >            _logger.write(toString(), Logger.ERROR, "ERROR - " + e);
160          }
161          
162          _socketOut.flush();
# Line 99 | Line 166 | class HostInit extends Thread {
166              _socketOut.close();
167              _socket.close();
168          } catch (IOException e) {
169 <            _logger.write(toString(), "exception on socket close");
169 >            _logger.write(toString(), Logger.ERROR, "exception on socket close");
170          }
171 <        _logger.write(toString(), "finished");
171 >        _logger.write(toString(), Logger.SYSMSG, "finished");
172      }
173      
174      /**
175       * Overrides the {@link java.lang.Object#toString() Object.toString()}
176       * method to provide clean logging (every class should have this).
177       *
178 +     * This uses the uk.ac.ukc.iscream.util.NameFormat class
179 +     * to format the toString()
180 +     *
181       * @return the name of this class and its CVS revision
182       */
183      public String toString() {
184 <        return this.getClass().getName() + "{" + _socket.getInetAddress().getHostName()
185 <         + "}(" + REVISION.substring(11, REVISION.length() - 2) + ")";
186 <        
184 >        return FormatName.getName(
185 >            _name,
186 >            getClass().getName(),
187 >            REVISION);
188      }
189  
190   //---PRIVATE METHODS---
# Line 122 | Line 193 | class HostInit extends Thread {
193  
194   //---ATTRIBUTES---
195  
196 <    Configurator _configurator;
197 <    Logger _logger;
198 <    Socket _socket;
199 <    BufferedReader _socketIn;
200 <    PrintWriter _socketOut;
196 >    /**
197 >     * This holds a reference to the
198 >     * system logger that is being used.
199 >     */
200 >    private Logger _logger = ReferenceManager.getInstance().getLogger();
201 >    
202 >    /**
203 >     * A reference to the Configuration Manager the system is using
204 >     */
205 >    private ConfigurationManager _configManager = ReferenceManager.getInstance().getCM();
206 >    
207 >    /**
208 >     * This is the friendly identifier of the
209 >     * component this class is running in.
210 >     * eg, a Filter may be called "filter1",
211 >     * If this class does not have an owning
212 >     * component,  a name from the configuration
213 >     * can be placed here.  This name could also
214 >     * be changed to null for utility classes.
215 >     */
216 >    private String _name = FilterManager.NAME;
217 >    
218 >    /**
219 >     * The socket this class uses
220 >     */
221 >    private Socket _socket;
222 >
223 >    /**
224 >     * Used for the input stream of this socket
225 >     */
226 >    private BufferedReader _socketIn;
227 >    
228 >    /**
229 >     * Used for the output stream of this socket
230 >     */
231 >    private PrintWriter _socketOut;
232  
233   //---STATIC ATTRIBUTES---
234  

Diff Legend

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