ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/host/c++/Config.cpp
(Generate patch)

Comparing projects/cms/source/host/c++/Config.cpp (file contents):
Revision 1.5 by ab11, Mon Mar 5 12:41:06 2001 UTC vs.
Revision 1.7 by tdb, Sat May 18 18:15:56 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   #include "Config.h"
21  
22   Config::Config( string serverName, int serverPort, int printDebug ){
23          // the constructor for the class
24          
6        
25          configConnectionRetryTime = 1; // one second
26          debug = printDebug;
27 <        MAX_CONNECTION_ATTEMPTS = 10; //
27 >        MAX_CONNECTION_ATTEMPTS = 10;
28          
29          configName = serverName;
30          configPort = serverPort;
31          
32          if ( debug == 1 ){
33                  std::cout << "Config Constructor\n";
34 <        }
34 >        } // if
35          
36          
37          // make a reference to smallnet
# Line 21 | Line 39 | Config::Config( string serverName, int serverPort, int
39                  std::cout << "Config::Constructor::Constructing SmallNet\n";
40          }
41          net = new SmallNet(debug);
42 <        // net->setDebug(1);
25 <        
26 <        // read the values which we want to retrieve from the
27 <        // config manager from the "config.values.txt" file
28 <        //propertyNames = new string[20];
29 <        //propertyValues = new string[20];
30 <        
31 <        // FIX ME
42 >                
43          // sod that we are using defined values now..
44          propertyNames[0] = "UDPUpdateTime";
45          propertyNames[1] = "TCPUpdateTime";
# Line 38 | Line 49 | Config::Config( string serverName, int serverPort, int
49          propertyNames[5] = "MAXTCPFilterRetries";
50          numProperties = 5;
51          
41        // read the Chat dialog we 'expect' to have with the config
42        // manager from disk. This is a new idea so that the client
43        // won't have to be hard coded with the dialog (incase it changes)
44        
45        // FIX ME
46        
52          if ( loadConfig() == 0 ){
53                  // successful just continue
54                  if ( debug == 1 ){
55                          std::cout << "Config::Constructor::loadConfig() Successful\n";
56 <                }
57 <        }
53 <        else {
56 >                } // if
57 >        } else {
58                  if ( debug == 1 ){
59                          std::cout << "Config::Constructor::loadConfig() failed-retrying\n";
60 <                }
60 >                } // if
61 >                
62                  // woops something went wrong. we'll just keep retrying
63                  // and increasing the time between trys
64                  int loadConfigResult = -1;
# Line 64 | Line 69 | Config::Config( string serverName, int serverPort, int
69                  while ( loadConfigResult != 0 ){
70                          if ( retrys > MAX_CONNECTION_ATTEMPTS ){
71                                  std::cout << "Maxium number of retries reached, Quitting";
72 <                                // exit("Failed to connect");
68 <                        }
72 >                        } // if
73                          // make the connection retry time greater
74                          configConnectionRetryTime = configConnectionRetryTime * 2;
75                          std::cout << "Waiting " << configConnectionRetryTime << " seconds before retrying\n";
# Line 74 | Line 78 | Config::Config( string serverName, int serverPort, int
78                          retrys++;
79                          loadConfigResult = loadConfig();
80                  } // while
77                
78        
81          } // if
82          
83          if ( debug == 1 ){
84                  std::cout << "Config::Constructor - Finished!\n";
85 <        }
85 >        } // if
86          
87   } // Config
88  
# Line 90 | Line 92 | int Config::loadConfig(){
92          
93          if ( debug == 1 ){
94                  std::cout << "Config::loadConfig()\n";
95 <        }
95 >        } // if
96          
97          // make a connection
98          
99          if ( debug == 1 ){
100                  std::cout << "Config::loadConfig::establishing config connection\n";
101 <        }
101 >        } // if
102 >        
103          int established = establishConfig();
104          if ( established != 0 ){
105 +            destroyConfig();
106                  return established;
107 <        }
107 >        } // if
108          
109          // do the talk ;)
110          
111          if ( debug == 1 ){
112                  std::cout << "Config::loadConfig::Processing chat script\n";
113 <        }
113 >        } // if
114 >        
115          int chat = chatConfig();
116          if ( chat != 0 ){
117                  // and close the connection
118                  destroyConfig();
119 <                // return chat;
115 <        }
119 >        } // if
120          
121          // and close the connection
118        
122          if ( debug == 1 ){
123                  std::cout << "Config::loadConfig::closing config connection\n";
124 <        }
124 >        } // if
125          destroyConfig();
126          
127          // return everything ok
# Line 130 | Line 133 | int Config::establishHeartbeat(){
133          // just an interface onto smallnet
134          if ( debug == 1 ){
135                  std::cout << "Config::establishHeartbeat()\n";
136 <        }
136 >        } // if
137          
138 <        int establish = net->connectHeartBeat(configName, configPort);
139 <        
138 >        int establish =  net->connectHeartBeat(configName, configPort);
139 >            
140          if ( debug == 1 ){
141                  std::cout << "->" << establish << "\n";
142 <        }
142 >        } // if
143          
144          return establish;
145                  
146   } // establishHeartBeat
147  
145
148   int Config::destroyHeartbeat(){
149          // just hooks into the smallnet interface
150          if ( debug == 1 ){
151                  std::cout << "Config::destroyHeartbeat()\n";
152 <        }
152 >        } // if
153          
154          net->closeHeartBeatConnection();
155          
# Line 160 | Line 162 | int Config::chatHeartBeat(){
162          response = net->heartBeatSend("HEARTBEAT");
163          if ( response != "OK" ){
164                  // something went wrong
163                return -1;
165                  if ( debug == 1 ){
166                          std::cout << "Config::chatHeartBeat::ERROR in HEARTBEAT\n";
167 <                }
168 <        }
167 >                } // if
168 >                return -1;
169 >        } // if
170          
171          response = net->heartBeatSend("CONFIG");
172          if ( response != "OK" ){
173                  // something went wrong
172                return -1;
174                  if ( debug == 1 ){
175                          std::cout << "Config::chatHeartBeat::ERROR in CONFIG\n";
176 <                }
177 <        }
176 >                } // if
177 >                return -1;
178 >        } // if
179          
180          response = net->heartBeatSend(fileList);
181          if ( response != "OK" ){
182                  // something went wrong
181                return -1;
183                  if ( debug == 1 ){
184                          std::cout << "Config::chatHeartBeat::ERROR in fileList\n";
185 <                }
186 <        }
185 >                } // if
186 >                return -1;
187 >        } // if
188          
189          response = net->heartBeatSend(lastModified);
190          if ( response != "OK" ){
191                  // something went wrong
190                return -1;
192                  if ( debug == 1 ){
193                          std::cout << "Config::chatHeartBeat::ERROR in lastModified\n";
194 <                }
195 <        }
194 >                } // if
195 >                return -1;
196 >        } // if
197          
198          response = net->heartBeatSend("ENDHEARTBEAT");
199          if ( response != "OK" ){
200                  // something went wrong
199                return -1;
201                  if ( debug == 1 ){
202                          std::cout << "Config::chatHeartBeat::ERROR in ENDHEARTBEAT\n";
203 <                }
204 <        }
203 >                } // if
204 >                return -1;
205 >        } // if
206          
207          // seems ok to me
208          return 0;
# Line 215 | Line 217 | int Config::establishConfig(){
217                  std::cout << "Config::establishConfig()\n";
218          }
219          
218        
219        /* MODIFY THIS */
220          int response = net->connectConfig(configName, configPort);
221          
222          if ( debug == 1 ){
223                  std::cout << "->" << response << "\n";
224 <        }
224 >        } // if
225          
226          return response;
227          
# Line 232 | Line 232 | int Config::chatConfig(){
232          // do some funky jibble.. ;)
233          if ( debug == 1 ){
234                  std::cout << "Config::chatConfig()\n";
235 <        }
235 >        } // if
236          
237          string response;
238 <        
239 <        
238 >
239          // hard coeded for the moment
240          if ( debug == 1 ){
241                  std::cout << "Config::chatConfig::STARTCONFIG\n";
242 <        }
242 >        } // if
243 >        
244          response = net->heartBeatSend("STARTCONFIG");
245          if ( response != "OK" ){
246                  // something went wrong
247                return -1;
247                  if ( debug == 1 ){
248                          std::cout << "Config::chatConfig::ERROR\n";
249 <                }
250 <        }
249 >                } // if
250 >                return -1;      
251 >        } // if
252          
253          if ( debug == 1 ){
254                  std::cout << "Config::chatConfig::LASTMODIFIED\n";
255 <        }
255 >        } // if
256          lastModified = net->heartBeatSend("LASTMODIFIED");
257          if ( debug == 1 ){
258                  std::cout << "Config::chatConfig::FILELIST\n";
259 <        }
259 >        } // if
260          fileList = net->heartBeatSend("FILELIST");
261          
262          fQDN = net->heartBeatSend("FQDN");
# Line 265 | Line 265 | int Config::chatConfig(){
265          
266          if ( debug == 1 ){
267                  std::cout << "Config::chatConfig::requesting properties\n";
268 <        }
268 >        } // if
269          if ( numProperties > 0 ){
270                  // we actually need to look for some properties
271                  for ( int i=0; i < numProperties; i++ ){
272                          // lets hope that this works! ;)
273                          if ( debug == 1 ){
274                                  std::cout << "Config::chatConfig::" << propertyNames[i] << "\n";
275 <                        }
275 >                        } // if
276                          propertyValues[i] = net->heartBeatSend(propertyNames[i]);
277                  } // for        
278          } // if
279          
280          if ( debug == 1 ){
281                  std::cout << "Config::chatConfig::ENDCONFIG\n";
282 <        }
282 >        } // if
283          response = net->heartBeatSend("ENDCONFIG");
284          // doesn't matter what it returns
285          
286          if ( debug == 1 ){
287                  std::cout << "Config::chatConfig::FILTER\n";
288 <        }
288 >        } // if
289 >        
290          response = net->heartBeatSend("FILTER");
291          // now we need to pull repsonse apart to get the filter information out
292          int first = response.find(";",0);
# Line 296 | Line 297 | int Config::chatConfig(){
297          
298          if ( debug == 1 ){
299                  std::cout << "Config::chatConfig::END\n";
300 <        }
300 >        } // if
301          response = net->heartBeatSend("END");
302          
303          return 0;      
# Line 306 | Line 307 | int Config::chatConfig(){
307   int Config::destroyConfig(){
308          if ( debug == 1 ){
309                  std::cout << "Config::destroyConfig()\n";
310 <        }
310 >        } // if
311          
312          net->closeConfigConnection();
313          
# Line 317 | Line 318 | string Config::getStrProperty(string propertyName){
318          
319          if ( debug == 1 ){
320                  std::cout << "Config::getProperty()\n";
321 <        }
321 >        } // if
322          
323          for ( int i=0; i<20; i++ ){
324                  if ( propertyName == propertyNames[i] ){
# Line 336 | Line 337 | int Config::getIntProperty( string propertyName ){
337          
338          if ( debug == 1 ){
339                  std::cout << "Config::getProperty()\n";
340 <        }
340 >        } // if
341          
342          string response = getStrProperty( propertyName );
343          if ( response == "ERROR" ){
# Line 346 | Line 347 | int Config::getIntProperty( string propertyName ){
347          int i = atoi(response.c_str());
348          
349          if ( i > 0 ){
350 +            // valid
351                  return i;
352 <        }
352 >        } // if
353                                          
354          // otherwise return ERROR
355          return -1;

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines