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.29 by tdb, Fri Mar 22 10:43:06 2002 UTC vs.
Revision 1.31 by tdb, Mon May 20 11:38:14 2002 UTC

# Line 1 | Line 1
1 + /*
2 + * i-scream central monitoring system
3 + * Copyright (C) 2000-2002 i-scream
4 + *
5 + * This program is free software; you can redistribute it and/or
6 + * modify it under the terms of the GNU General Public License
7 + * as published by the Free Software Foundation; either version 2
8 + * of the License, or (at your option) any later version.
9 + *
10 + * This program is distributed in the hope that it will be useful,
11 + * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13 + * GNU General Public License for more details.
14 + *
15 + * You should have received a copy of the GNU General Public License
16 + * along with this program; if not, write to the Free Software
17 + * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
18 + */
19 +
20   //---PACKAGE DECLARATION---
21   package uk.org.iscream.cms.server.filtermanager;
22  
# Line 108 | Line 127 | class HostInit extends Thread {
127                  }
128              }
129                  
130 <                // hopefully we found a filter
130 >            // hopefully we found a filter
131              if(filterInfoRef != null) {
132                  _logger.write(toString(), Logger.DEBUG, " found filter- " + filter);
133 <                // tell the host about it...
134 <                    _socketOut.println(filterInfoRef.getHostName() + ";"
135 <                                     + filterInfoRef.getUDPPort() + ";"
136 <                                     + filterInfoRef.getTCPPort());
133 >                try {
134 >                    // tell the host about it...
135 >                        _socketOut.println(filterInfoRef.getHostName() + ";"
136 >                                         + filterInfoRef.getUDPPort() + ";"
137 >                                         + filterInfoRef.getTCPPort());
138 >                    }
139 >                    catch(org.omg.CORBA.COMM_FAILURE e) {
140 >                        // failed to talk to filter, lets signal an error
141 >                        _socketOut.println("ERROR");
142 >                        throw new IOException("error communicating with filter - " + e);
143 >                    }
144                  }
145                  else {
146                      // ...or throw a wobbly (and tell the host!)

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines