37 |
|
* @param socket The socket to which the host is connected |
38 |
|
*/ |
39 |
|
public HostInit(Socket socket) throws IOException { |
40 |
+ |
// set the Thread name |
41 |
+ |
setName("filtermanager.HostInit"); |
42 |
+ |
|
43 |
|
_socket = socket; |
44 |
|
// setup reader & writer |
45 |
|
_socketIn = new BufferedReader(new InputStreamReader(_socket.getInputStream())); |
140 |
|
_logger.write(toString(), Logger.DEBUG, " looking for filter- " + filter); |
141 |
|
try { |
142 |
|
filterRef = FilterHelper.narrow(ReferenceManager.getInstance().getCORBARef("iscream.Filter." + filter)); |
143 |
< |
} catch (Exception e) { // THIS SHOULD BE A MORE SPECIFIC EXCEPTION |
143 |
> |
} catch (ComponentCORBAException e) { |
144 |
|
_logger.write(toString(), Logger.DEBUG, " unable to find filter- " + filter); |
145 |
|
} |
146 |
|
} |
154 |
|
+ filterRef.getTCPPort()); |
155 |
|
} |
156 |
|
else { |
157 |
< |
// ...or throw a wobbly |
157 |
> |
// ...or throw a wobbly (and tell the host!) |
158 |
> |
_socketOut.println("ERROR"); |
159 |
|
throw new IOException("unable to find filter for host"); |
160 |
|
} |
161 |
|
} |