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.6 by tdb, Mon Nov 20 18:55:24 2000 UTC vs.
Revision 1.11 by tdb, Thu Dec 7 00:02:17 2000 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 uk.ac.ukc.iscream.filter.*;
7 + import uk.ac.ukc.iscream.util.*;
8   import java.net.Socket;
6 import java.io.InputStream;
7 import java.io.OutputStream;
8 import java.io.IOException;
9   import java.io.*;
10  
11   /**
12 < * <ONE LINE DESCRIPTION>
13 < * <DETAILED DESCRIPTION>
12 > * Handles setting up a host.
13   *
14   * @author  $Author$
15   * @version $Id$
# Line 28 | Line 27 | class HostInit extends Thread {
27  
28   //---CONSTRUCTORS---
29  
30 <    public HostInit(Socket socket, ConfigurationManager configManager, Logger logger) throws IOException {
32 <        _configManager = configManager;
33 <        _logger = logger;
30 >    public HostInit(Socket socket) throws IOException {
31          _socket = socket;
32          _socketIn = new BufferedReader(new InputStreamReader(_socket.getInputStream()));
33          _socketOut = new PrintWriter(_socket.getOutputStream());
# Line 45 | Line 42 | class HostInit extends Thread {
42              if (!inBound.equals("STARTCONFIG")) {
43                  _socketOut.println("ERROR");
44                  _socketOut.flush();
45 <                throw new IOException("Protocol Error");
45 >                throw new IOException("protocol error - expected:STARTCONFIG got:" + inBound);
46              }
47  
48 <            Configuration myConfig = _configManager.getConfiguration(_socket.getInetAddress().getHostName().toLowerCase());
48 >            Configuration myConfig = _configManager.getConfiguration("Host." + _socket.getInetAddress().getHostName().toLowerCase());
49              if (myConfig == null) {
50                  _socketOut.println("ERROR");
51 <                throw new IOException("No Configuration File For Host");
51 >                throw new IOException("error in host configuration");
52              } else {
53                  _socketOut.println("OK");
54                  _socketOut.flush();
# Line 62 | Line 59 | class HostInit extends Thread {
59                          // protocol error
60                      _socketOut.println("ERROR");
61                      _socketOut.flush();
62 <                    throw new IOException("Protocol Error");
62 >                    throw new IOException("protocol error - expected:LASTMODIFIED got:" + inBound);
63                  }
64                  else {
65                          // send info
# Line 70 | Line 67 | class HostInit extends Thread {
67                          _socketOut.flush();
68                  }
69                  
70 +                // get config fileList
71 +                inBound = _socketIn.readLine();
72 +                if(!inBound.equals("FILELIST")) {
73 +                        // protocol error
74 +                    _socketOut.println("ERROR");
75 +                    _socketOut.flush();
76 +                    throw new IOException("protocol error - expected:FILELIST got:" + inBound);
77 +                }
78 +                else {
79 +                        // send info
80 +                        _socketOut.println(myConfig.getFileList());
81 +                        _socketOut.flush();
82 +                }
83 +
84                  // get properties
85                  inBound = _socketIn.readLine();
86                  while(!inBound.equals("ENDCONFIG")) {
87                            
88                      // get the property
89                      try {
90 <                        String returnedProperty = myConfig.getProperty(inBound);    
90 >                        String returnedProperty = myConfig.getProperty("Host."+inBound);    
91                          
92                          _socketOut.println(returnedProperty);
93                          _socketOut.flush();
# Line 90 | Line 101 | class HostInit extends Thread {
101                  _logger.write(toString(), Logger.SYSMSG, "configured host");
102                  _socketOut.println("OK");
103                  _socketOut.flush();
104 +                
105 +                // get filter reference
106 +                inBound = _socketIn.readLine();
107 +                if(!inBound.equals("FILTER")) {
108 +                        // protocol error
109 +                    _socketOut.println("ERROR");
110 +                    _socketOut.flush();
111 +                    throw new IOException("protocol error - expected:FILTER got:" + inBound);
112 +                }
113 +                else {
114 +                        // send info
115 +                        String parentFilter =  myConfig.getProperty("Host.filter");
116 +                        _logger.write(toString(), Logger.DEBUG, " looking for parent - " + parentFilter);
117 +                    Filter filter = FilterHelper.narrow(ReferenceManager.getInstance().getCORBARef("iscream.Filter." + parentFilter));
118 +                        _socketOut.println(filter.getHostName() + ";"
119 +                                         + filter.getUDPPort() + ";"
120 +                                         + filter.getTCPPort());
121 +                        _socketOut.flush();
122 +                }
123 +                
124 +                // confirm that all is ok
125 +                inBound = _socketIn.readLine();
126 +                if(!inBound.equals("END")) {
127 +                        // protocol error
128 +                    _socketOut.println("ERROR");
129 +                    _socketOut.flush();
130 +                    throw new IOException("protocol error - expected:END got:" + inBound);
131 +                }
132 +                else {
133 +                        // send ok
134 +                        _socketOut.println("OK");
135 +                        _socketOut.flush();
136 +                }
137 +
138              }
139              
140          } catch (Exception e) {
141 <            _logger.write(toString(), Logger.ERROR, e.toString());
141 >            _logger.write(toString(), Logger.ERROR, "ERROR: " + e.getMessage());
142          }
143          
144          _socketOut.flush();
# Line 126 | Line 171 | class HostInit extends Thread {
171  
172   //---ATTRIBUTES---
173  
174 <    ConfigurationManager _configManager;
175 <    Logger _logger;
174 >    /**
175 >     * A reference to the logger the system is using
176 >     */
177 >    Logger _logger = ReferenceManager.getInstance().getLogger();
178 >    
179 >    /**
180 >     * A reference to the Configuration Manager the system is using
181 >     */
182 >    ConfigurationManager _configManager = ReferenceManager.getInstance().getCM();
183 >    
184      Socket _socket;
185      BufferedReader _socketIn;
186      PrintWriter _socketOut;

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines