(file) Return to cimserver.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Server

Diff for /pegasus/src/Server/cimserver.cpp between version 1.23 and 1.109

version 1.23, 2001/06/16 15:58:19 version 1.109, 2003/09/15 14:32:25
Line 1 
Line 1 
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000 The Open Group, BMC Software, Tivoli Systems, IBM  // Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM,
   // The Open Group, Tivoli Systems
 // //
 // Permission is hereby granted, free of charge, to any person obtaining a  // Permission is hereby granted, free of charge, to any person obtaining a copy
 // copy of this software and associated documentation files (the "Software"),  // of this software and associated documentation files (the "Software"), to
 // to deal in the Software without restriction, including without limitation  // deal in the Software without restriction, including without limitation the
 // the rights to use, copy, modify, merge, publish, distribute, sublicense,  // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
 // and/or sell copies of the Software, and to permit persons to whom the  // sell copies of the Software, and to permit persons to whom the Software is
 // Software is furnished to do so, subject to the following conditions:  // furnished to do so, subject to the following conditions:
 //  //
 // The above copyright notice and this permission notice shall be included in  // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN
 // all copies or substantial portions of the Software.  // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
 //  // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
 //  // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR  // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,  // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
 // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL  // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 // THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER  // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING  
 // FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER  
 // DEALINGS IN THE SOFTWARE.  
 // //
 //============================================================================== //==============================================================================
 // //
 // Author: Mike Brasher (mbrasher@bmc.com) // Author: Mike Brasher (mbrasher@bmc.com)
 // //
 // Modified By: Mike Day (mdday@us.ibm.com) // Modified By: Mike Day (mdday@us.ibm.com)
 // =======  //
 // Modified By: Karl Schopmeyer (k.schopmeyer@opengroup.org) // Modified By: Karl Schopmeyer (k.schopmeyer@opengroup.org)
 // //
   // Modified By: Nag Boranna (nagaraja_boranna@hp.com)
   //
   // Modified By: Jenny Yu (jenny_yu@hp.com)
   //
   // Modified By: Sushma Fernandes (sushma_fernandes@hp.com)
   //              Carol Ann Krug Graves, Hewlett-Packard Company
   //                (carolann_graves@hp.com)
   //              Yi Zhou, Hewlett-Packard Company (yi_zhou@hp.com)
   //
   // Modified By: Dave Rosckes (rosckes@us.ibm.com)
   //
   // Modified By: Humberto Rivero (hurivero@us.ibm.com)
   //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
  
Line 36 
Line 47 
 // //
 // Notes on deamon operation (Unix) and service operation (Win 32): // Notes on deamon operation (Unix) and service operation (Win 32):
 // //
 // To run pegasus as a daemon on Unix platforms, use the -d option:  // To run pegasus as a daemon on Unix platforms:
   //
   // cimserver
 // //
 // cimserver -d  // To NOT run pegasus as a daemon on Unix platforms, set the daemon config
   // property to false:
 // //
 // The -d option has no effect on windows operation.  // cimserver daemon=false
   //
   // The daemon config property has no effect on windows operation.
   //
   // To shutdown pegasus, use the -s option:
   //
   // cimserver -s
 // //
 // To run pegasus as an NT service, there are FOUR  different possibilities: // To run pegasus as an NT service, there are FOUR  different possibilities:
 // //
Line 68 
Line 88 
 ////////////////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////
  
  
   #include <Pegasus/Common/Config.h>
   #include <Pegasus/Common/Constants.h>
 #include <iostream> #include <iostream>
   #include <cassert>
 #include <cstdlib> #include <cstdlib>
   #include <fstream>
 #include <Pegasus/Common/FileSystem.h> #include <Pegasus/Common/FileSystem.h>
 #include <Pegasus/Common/Selector.h>  #include <Pegasus/Common/Monitor.h>
 #include <Pegasus/Common/OptionManager.h>  
 #include <Pegasus/Server/CIMServer.h> #include <Pegasus/Server/CIMServer.h>
 #include <Pegasus/Common/PegasusVersion.h> #include <Pegasus/Common/PegasusVersion.h>
 #include <Pegasus/Protocol/Handler.h>  
 #include <Pegasus/Common/Logger.h> #include <Pegasus/Common/Logger.h>
 #include <Pegasus/Common/System.h> #include <Pegasus/Common/System.h>
   #include <Pegasus/Common/Tracer.h>
   #include <Pegasus/Config/ConfigManager.h>
   #include <Pegasus/Client/CIMClient.h>
   #include <Pegasus/Server/ShutdownService.h>
   #include <Pegasus/Common/Destroyer.h>
   #if !defined(PEGASUS_OS_ZOS) && ! defined(PEGASUS_OS_HPUX) && ! defined(PEGASUS_NO_SLP)
   #include <slp/slp.h>
   #endif
  
  
 #if defined(PEGASUS_OS_TYPE_WINDOWS) #if defined(PEGASUS_OS_TYPE_WINDOWS)
 # include "cimserver_windows.cpp" # include "cimserver_windows.cpp"
 #elif defined(PEGASUS_OS_TYPE_UNIX) #elif defined(PEGASUS_OS_TYPE_UNIX)
   # if defined(PEGASUS_OS_OS400)
   #  include "OS400ConvertChar.h"
   #  include "cimserver_os400.cpp"
   # else
 # include "cimserver_unix.cpp" # include "cimserver_unix.cpp"
   #endif
 #else #else
 # error "Unsupported platform" # error "Unsupported platform"
 #endif #endif
Line 92 
Line 126 
 PEGASUS_USING_PEGASUS; PEGASUS_USING_PEGASUS;
 PEGASUS_USING_STD; PEGASUS_USING_STD;
  
 void GetEnvironmentVariables(  //
     const char* arg0,  //  The command name.
     String& pegasusHome)  //
 {  static const char COMMAND_NAME []    = "cimserver";
     // Get environment variables:  
  
     const char* tmp = getenv("PEGASUS_HOME");  //
   //  The constant defining usage string.
   //
   static const char USAGE []           = "Usage: ";
  
     if (!tmp)  /**
     {  Constants representing the command line options.
         cerr << arg0 << ": PEGASUS_HOME environment variable undefined" << endl;  */
         exit(1);  static const char OPTION_VERSION     = 'v';
     }  
  
     pegasusHome = tmp;  static const char OPTION_HELP        = 'h';
     FileSystem::translateSlashes(pegasusHome);  
 }  static const char OPTION_HOME        = 'D';
   
   static const char OPTION_SHUTDOWN    = 's';
   
   static const char OPTION_INSTALL[]   = "install";
   
   static const char OPTION_REMOVE[]   = "remove";
   
   static const char OPTION_START[]   = "start";
   
   static const char OPTION_STOP[]   = "stop";
   
   #if defined(PEGASUS_OS_HPUX)
   static const char OPTION_BINDVERBOSE = 'X';
   #endif
   
   static const String PROPERTY_TIMEOUT = "shutdownTimeout";
   
   ConfigManager*    configManager;
  
 /** GetOptions function - This function defines the Options Table /** GetOptions function - This function defines the Options Table
     and sets up the options from that table using the option manager.      and sets up the options from that table using the config manager.
 */ */
 void GetOptions( void GetOptions(
     OptionManager& om,      ConfigManager* cm,
     int& argc,     int& argc,
     char** argv,     char** argv,
     const String& pegasusHome)     const String& pegasusHome)
 { {
     static struct OptionRow optionsTable[] =      try
     {     {
         {"port", "5988", false, Option::WHOLE_NUMBER, 0, 0, "port",          cm->mergeConfigFiles();
                         "specifies port number to listen on" },  
         {"trace", "false", false, Option::BOOLEAN, 0, 0, "t",  
                         "turns on trace of Client IO to console "},  
         {"logtrace", "false", false, Option::BOOLEAN, 0, 0, "l",  
                         "Turns on trace of Client IO to trace log "},  
         {"options", "false", false, Option::BOOLEAN, 0, 0, "options",  
                         " Displays the settings of the Options "},  
         {"severity", "ALL", false, Option::STRING, 0, 0, "s",  
   
                     "Sets the severity level that will be logged "},  
         {"logs", "ALL", false, Option::STRING, 0, 0, "X",  
                         "Not Used "},  
         {"daemon", "false", false, Option::BOOLEAN, 0, 0, "d",  
                         "Detach Pegasus from the console and run it in the background "},  
         {"logdir", "./logs", false, Option::STRING, 0, 0, "logdir",  
                         "Directory for log files"},  
         {"cleanlogs", "false", false, Option::BOOLEAN, 0, 0, "clean",  
                         "Clears the log files at startup"},  
         {"version", "false", false, Option::BOOLEAN, 0, 0, "v",  
                         "Displays Pegasus Version "},  
         {"help", "false", false, Option::BOOLEAN, 0, 0, "h",  
                     "Prints help message with command line options "},  
         {"install", "false", false, Option::BOOLEAN, 0, 0, "install",  
                     "Installs Pegasus as a Windows NT Service "},  
         {"remove", "false", false, Option::BOOLEAN, 0, 0, "remove",  
                     "Removes Pegasus as a Windows NT Service "},  
         {"debug", "false", false, Option::BOOLEAN, 0, 0, "d",  
                         "Not Used "},  
         {"slp", "true", false, Option::BOOLEAN, 0, 0, "slp",  
                         "Register Pegasus as a Service with SLP"}  
     };  
     const Uint32 NUM_OPTIONS = sizeof(optionsTable) / sizeof(optionsTable[0]);  
   
     om.registerOptions(optionsTable, NUM_OPTIONS);  
   
     String configFile = pegasusHome + "/testclient.conf";  
   
     cout << "Config file from " << configFile << endl;  
   
     if (FileSystem::exists(configFile))  
         om.mergeFile(configFile);  
     if(argc && argv != NULL)  
       om.mergeCommandLine(argc, argv);  
  
     om.checkRequiredOptions();          cm->mergeCommandLine(argc, argv);
       }
       catch (NoSuchFile nsf)
       {
           throw nsf;
       }
       catch (FileNotReadable fnr)
       {
           throw fnr;
       }
       catch (CannotRenameFile ftrf)
       {
           throw ftrf;
       }
       catch (ConfigFileSyntaxError cfse)
       {
           throw cfse;
       }
       catch(UnrecognizedConfigProperty ucp)
       {
           throw ucp;
       }
       catch(InvalidPropertyValue ipv)
       {
           throw ipv;
       }
 } }
  
 /* PrintHelp - This is temporary until we expand the options manager to allow /* PrintHelp - This is temporary until we expand the options manager to allow
Line 175 
Line 210 
 */ */
 void PrintHelp(const char* arg0) void PrintHelp(const char* arg0)
 { {
     cout << '\n';      /**
           Build the usage string for the config command.
       */
       /* l10n
       String usage = String (USAGE);
       usage.append (COMMAND_NAME);
       usage.append (" [ [ options ] | [ configProperty=value, ... ] ]\n");
       usage.append ("  options\n");
       usage.append ("    -v              - displays CIM Server version number\n");
       usage.append ("    -h              - prints this help message\n");
       usage.append ("    -s              - shuts down CIM Server\n");
   #if !defined(PEGASUS_OS_HPUX) && !defined(PEGASUS_PLATFORM_LINUX_IA64_GNU)
       usage.append ("    -D [home]       - sets pegasus home directory\n");
   #endif
   #if defined(PEGASUS_OS_TYPE_WINDOWS)
       usage.append ("    -install [name] - installs pegasus as a Windows NT Service\n");
       usage.append ("                      [name] is optional and overrides the\n");
       usage.append ("                      default CIM Server Service Name\n");
       usage.append ("    -remove [name]  - removes pegasus as a Windows NT Service\n");
       usage.append ("                      [name] is optional and overrides the\n");
       usage.append ("                      default CIM Server Service Name\n");
       usage.append ("    -start [name]   - starts pegasus as a Windows NT Service\n");
       usage.append ("                      [name] is optional and overrides the\n");
       usage.append ("                      default CIM Server Service Name\n");
       usage.append ("    -stop [name]    - stops pegasus as a Windows NT Service\n");
       usage.append ("                      [name] is optional and overrides the\n");
       usage.append ("                      default CIM Server Service Name\n\n");
   #endif
       usage.append ("  configProperty=value\n");
       usage.append ("                    - sets CIM Server configuration property\n");
   
       cout << endl;
   #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_IA64_GNU)
       cout << PLATFORM_PRODUCT_NAME << " " << PLATFORM_PRODUCT_VERSION << endl;
   #else
     cout << PEGASUS_NAME << PEGASUS_VERSION << endl;     cout << PEGASUS_NAME << PEGASUS_VERSION << endl;
     cout << '\n';  #endif
     cout << "Usage: " << arg0 << endl;      cout << endl;
       cout << usage << endl;
       */
   
       String usage = String (USAGE);
       usage.append (COMMAND_NAME);
       usage.append (" [ [ options ] | [ configProperty=value, ... ] ]\n");
       usage.append ("  options\n");
       usage.append ("    -v              - displays CIM Server version number\n");
       usage.append ("    -h              - prints this help message\n");
       usage.append ("    -s              - shuts down CIM Server\n");
   #if !defined(PEGASUS_OS_HPUX) && !defined(PEGASUS_PLATFORM_LINUX_IA64_GNU)
       //usage.append ("    -D [home]       - sets pegasus home directory\n");
       usage.append("$0");
   #endif
   #if defined(PEGASUS_OS_TYPE_WINDOWS)
       usage.append ("    -install [name] - installs pegasus as a Windows NT Service\n");
       usage.append ("                      [name] is optional and overrides the\n");
       usage.append ("                      default CIM Server Service Name\n");
       usage.append ("    -remove [name]  - removes pegasus as a Windows NT Service\n");
       usage.append ("                      [name] is optional and overrides the\n");
       usage.append ("                      default CIM Server Service Name\n");
       usage.append ("    -start [name]   - starts pegasus as a Windows NT Service\n");
       usage.append ("                      [name] is optional and overrides the\n");
       usage.append ("                      default CIM Server Service Name\n");
       usage.append ("    -stop [name]    - stops pegasus as a Windows NT Service\n");
       usage.append ("                      [name] is optional and overrides the\n");
       usage.append ("                      default CIM Server Service Name\n\n");
   #endif
       usage.append ("  configProperty=value\n");
       usage.append ("                    - sets CIM Server configuration property\n");
   
     cout << endl;     cout << endl;
   #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_IA64_GNU)
       cout << PLATFORM_PRODUCT_NAME << " " << PLATFORM_PRODUCT_VERSION << endl;
   #else
       cout << PEGASUS_NAME << PEGASUS_VERSION << endl;
   #endif
       cout << endl;
   
   #if defined(PEGASUS_OS_TYPE_WINDOWS)
       MessageLoaderParms parms("src.Server.cimserver.MENU.WINDOWS", usage);
   #elif defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_IA64_GNU)
           MessageLoaderParms parms("src.Server.cimserver.MENU.HPUXLINUXIA64GNU", usage);
   #else
           MessageLoaderParms parms("src.Server.cimserver.MENU.STANDARD", usage);
   #endif
       //cout << usage << endl;
       cout << MessageLoader::getMessage(parms) << endl;
 } }
  
 //////////////////////////////////////////////////////////////////////////  // l10n
 //  MAIN  //
 //////////////////////////////////////////////////////////////////////////  // Dummy function for the Thread object associated with the initial thread.
 int main(int argc, char** argv)  // Since the initial thread is used to process CIM requests, this is
   // needed to localize the exceptions thrown during CIM request processing.
   // Note: This function should never be called!
   //
   PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL dummyThreadFunc(void *parm)
 { {
     // on Windows NT if there are no command-line options, run as a service     return((PEGASUS_THREAD_RETURN)0);
   }
     if (argc == 1 )  
       cim_server_service(argc, argv) ;  
  
     // Get environment variables:  //
   // cimserver_exit: platform specific exit routine calls
   //
   void cimserver_exit( int rc ){
   #ifdef PEGASUS_OS_OS400
       cimserver_exitRC(rc);
   #endif
       exit(rc);
   }
  
     String pegasusHome;  void shutdownCIMOM(Uint32 timeoutValue)
   {
       //
       // Create CIMClient object
       //
       CIMClient client;
  
     GetEnvironmentVariables(argv[0], pegasusHome);      //
       // Get local host name
       //
       String hostStr = System::getHostName();
  
     // Get options (from command line and from configuration file); this      //
     // removes corresponding options and their arguments fromt he command      // open connection to CIMOM
     // line.      //
       try
       {
           client.connectLocal();
  
     OptionManager om;          //
           // set client timeout to 2 seconds
           //
           client.setTimeout(2000);
       }
       catch(Exception& e)
       {
   #ifdef PEGASUS_OS_OS400
           //l10n
           //Logger::put(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                       //"Unable to connect to CIM Server.  CIM Server may not be running." );
           Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                           "src.Server.cimserver.UNABLE_CONNECT_SERVER_MAY_NOT_BE_RUNNING",
                       "Unable to connect to CIM Server.  CIM Server may not be running." );
           // The server job may still be active but not responding.
           // Kill the job if it exists.
           if(cimserver_kill() == -1)
              cimserver_exit(2);
           cimserver_exit(1);
   #else
           //l10n
           //PEGASUS_STD(cerr) << "Unable to connect to CIM Server." << PEGASUS_STD(endl);
           //PEGASUS_STD(cerr) << "CIM Server may not be running." << PEGASUS_STD(endl);
           MessageLoaderParms parms("src.Server.cimserver.UNABLE_CONNECT_SERVER_MAY_NOT_BE_RUNNING",
                                                            "Unable to connect to CIM Server.\nCIM Server may not be running.\n");
           PEGASUS_STD(cerr) << MessageLoader::getMessage(parms);
   #endif
           cimserver_exit(1);
       }
  
     try     try
     {     {
         GetOptions(om, argc, argv, pegasusHome);          //
         // om.print();          // construct CIMObjectPath
           //
           String referenceStr = "//";
           referenceStr.append(hostStr);
           referenceStr.append("/");
           referenceStr.append(PEGASUS_NAMESPACENAME_SHUTDOWN.getString());
           referenceStr.append(":");
           referenceStr.append(PEGASUS_CLASSNAME_SHUTDOWN.getString());
           CIMObjectPath reference(referenceStr);
   
           //
           // issue the invokeMethod request on the shutdown method
           //
           Array<CIMParamValue> inParams;
           Array<CIMParamValue> outParams;
   
           // set force option to true for now
           inParams.append(CIMParamValue("force",
               CIMValue(Boolean(true))));
   
           inParams.append(CIMParamValue("timeout",
               CIMValue(Uint32(timeoutValue))));
   
           CIMValue retValue = client.invokeMethod(
               PEGASUS_NAMESPACENAME_SHUTDOWN,
               reference,
               "shutdown",
               inParams,
               outParams);
       }
       catch(CIMException& e)
       {
   #ifdef PEGASUS_OS_OS400
   
           if (e.getCode() == CIM_ERR_INVALID_NAMESPACE)
           {
               //l10n
               //Logger::put(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                       //"Failed to shutdown server: $0", "The repository may be empty.");
                   Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                           "src.Server.cimserver.SHUTDOWN_FAILED_REPOSITORY_EMPTY",
                       "Error in server shutdown: The repository may be empty.");
           }
           else
           {
               //l10n
               //Logger::put(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                           //"Failed to shutdown server: $0", e.getMessage());
                   Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                           "src.Server.cimserver.SHUTDOWN_FAILED",
                           "Error in server shutdown: $0", e.getMessage());
           }
           // Kill the server job.
           if(cimserver_kill() == -1)
              cimserver_exit(2);
   #else
           //l10n - TODO
           MessageLoaderParms parms("src.Server.cimserver.SHUTDOWN_FAILED",
                                    "Error in server shutdown: ");
           PEGASUS_STD(cerr) << MessageLoader::getMessage(parms);
           if (e.getCode() == CIM_ERR_INVALID_NAMESPACE)
           {
               //
               // Repository may be empty.
               //
               //l10n - TODO
               Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                   "src.Server.cimserver.SHUTDOWN_FAILED_REPOSITORY_EMPTY",
                   "Error in server shutdown: The repository may be empty.");
               MessageLoaderParms parms("src.Server.cimserver.REPOSITORY_EMPTY",
                                        "The repository may be empty.");
               PEGASUS_STD(cerr) << MessageLoader::getMessage(parms) << PEGASUS_STD(endl);
           }
           else
           {
               //l10n - TODO
               Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                   "src.Server.cimserver.SHUTDOWN_FAILED",
                   "Error in server shutdown: $0", e.getMessage());
               PEGASUS_STD(cerr) << e.getMessage() << PEGASUS_STD(endl);
           }
   
           // Kill the cimserver process
           if (cimserver_kill() == 0)
           {
               //l10n - TODO
               Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                   "src.Server.cimserver.SERVER_FORCED_SHUTDOWN",
                           "Forced shutdown initiated.");
               MessageLoaderParms parms("src.Server.cimserver.SERVER_FORCED_SHUTDOWN",
                                        "Forced shutdown initiated.");
               PEGASUS_STD(cerr) << MessageLoader::getMessage(parms) << PEGASUS_STD(endl);
           }
   #endif
           cimserver_exit(1);
   
     }     }
     catch (Exception& e)     catch (Exception& e)
     {     {
         cerr << argv[0] << ": " << e.getMessage() << endl;          //
         exit(1);          // This may mean that the CIM Server has terminated, causing this
           // client to get a "Empty HTTP response message" exception.  It may
           // also mean that the CIM Server is taking longer than 2 seconds
           // (client timeout value) to terminate, causing this client to
           // timeout with a "connection timeout" exception.
           //
           // Check to see if CIM Server is still running.  If CIM Server
           // is still running and the shutdown timeout has not expired,
           // loop and wait one second until either the CIM Server is
           // terminated or timeout expires.  If timeout expires and
           // the CIM Server is still running, kill the CIMServer process.
           //
           Uint32 maxWaitTime = timeoutValue - 2;
           Boolean running = isCIMServerRunning();
           while ( running && maxWaitTime > 0 )
           {
               System::sleep(1);
               running = isCIMServerRunning();
               maxWaitTime = maxWaitTime - 1;
     }     }
  
     // At this point, all options should have been extracted; print an          if (running)
     // error if there are any remaining:          {
               int kill_rc = cimserver_kill();
   #ifdef PEGASUS_OS_OS400
               if(kill_rc == -1)
                   cimserver_exit(2);
               cimserver_exit(1);
   #endif
  
     if (argc != 1)  #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU) || defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)
               if (kill_rc != -1)
     {     {
         cerr << argv[0] << ": unrecognized options: ";                  //l10n - TODO
                   Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                       "src.Server.cimserver.TIMEOUT_EXPIRED_SERVER_KILLED",
                       "Shutdown timeout expired.  Forced shutdown initiated.");
                   MessageLoaderParms parms("src.Server.cimserver.TIMEOUT_EXPIRED_SERVER_KILLED",
                       "Shutdown timeout expired.  Forced shutdown initiated.");
                   cout << MessageLoader::getMessage(parms) << endl;
                   exit(0);
               }
   #endif
           }
       }
  
         for (int i = 1; i < argc; i++)      return;
             cerr << argv[i] << ' ';  }
         cout << endl;  
         exit(1);  
   /////////////////////////////////////////////////////////////////////////
   //  MAIN
   //////////////////////////////////////////////////////////////////////////
   int main(int argc, char** argv)
   {
       String pegasusHome  = String::EMPTY;
       String logsDirectory = String::EMPTY;
       Boolean useSLP = false;
       Boolean daemonOption = false;
       Boolean shutdownOption = false;
       Uint32 timeoutValue  = 0;
   
   //l10n
   // Set Message loading to process locale
   MessageLoader::_useProcessLocale = true;
   //l10n
   
   #ifdef PEGASUS_OS_OS400
       // Convert the args to ASCII
       for(Uint32 i = 0;i< argc;++i)
       {
           EtoA(argv[i]);
       }
   
       // Initialize Pegasus home to the shipped OS/400 directory.
       pegasusHome = OS400_DEFAULT_PEGASUS_HOME;
   #endif
   
   #ifndef PEGASUS_OS_TYPE_WINDOWS
       //
       // Get environment variables:
       //
   #ifdef PEGASUS_OS_OS400
   #pragma convert(37)
       const char* tmp = getenv("PEGASUS_HOME");
   #pragma convert(0)
       char home[256] = {0};
       if (tmp && strlen(tmp) < 256)
       {
           strcpy(home, tmp);
           EtoA(home);
           pegasusHome = home;
       }
   #else
       const char* tmp = getenv("PEGASUS_HOME");
   
       if (tmp)
       {
           pegasusHome = tmp;
     }     }
   #endif
  
     // Check to see if we should (can) install as a NT service      FileSystem::translateSlashes(pegasusHome);
   #else
   
     // windows only
     setHome(pegasusHome);
   #endif
       // on Windows NT if there are no command-line options, run as a service
  
     String installOption;      if (argc == 1 )
     if(om.lookupValue("install", installOption) && installOption == "true")      {
         cim_server_service(argc, argv);
       }
       else
       {       {
         if( 0 != cimserver_install_nt_service( pegasusHome ))          // Get help, version, and shutdown options
           cout << "\nPegasus installed as NT Service";  
           for (int i = 1; i < argc; )
           {
               const char* arg = argv[i];
   
               // Check for -option
               if (*arg == '-')
               {
                   // Get the option
                   const char* option = arg + 1;
   
                   //
                   // Check to see if user asked for the version (-v option):
                   //
                   if (*option == OPTION_VERSION &&
                       strlen(option) == 1)
                   {
   #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_IA64_GNU)
                       cout << PLATFORM_PRODUCT_VERSION << endl;
   #else
                       cout << PEGASUS_VERSION << endl;
   #endif
                       exit(0);
                   }
                   //
                   // Check to see if user asked for help (-h option):
                   //
                   else if (*option == OPTION_HELP &&
                           (strlen(option) == 1))
                   {
                       PrintHelp(argv[0]);
                       exit(0);
                   }
   #if !defined(PEGASUS_OS_HPUX) && !defined(PEGASUS_PLATFORM_LINUX_IA64_GNU)
                   else if (*option == OPTION_HOME &&
                           (strlen(option) == 1))
                   {
                       if (i + 1 < argc)
                       {
                           pegasusHome.assign(argv[i + 1]);
                       }
                       else
                       {
                           //l10n
                           //cout << "Missing argument for option -" << option << endl;
                           String opt(option);
                           MessageLoaderParms parms("src.Server.cimserver.MISSING_ARGUMENT",
                                                                    "Missing argument for option -$0",
                                                                    opt);
                                   cout << MessageLoader::getMessage(parms) << endl;
         exit(0);         exit(0);
       }       }
  
     // Check to see if we should (can) remove Pegasus as an NT service                      memmove(&argv[i], &argv[i + 2], (argc-i-1) * sizeof(char*));
                       argc -= 2;
                   }
   #endif
   #if defined(PEGASUS_OS_HPUX)
                   //
                   // Check to see if user asked for the version (-X option):
                   //
                   if (*option == OPTION_BINDVERBOSE &&
                           (strlen(option) == 1))
                   {
                       System::bindVerbose = true;
                       //l10n
                       //cout << "Unsupported debug option, BIND_VERBOSE, enabled."
                            //<< endl;
                       MessageLoaderParms parms("src.Server.cimserver.UNSUPPORTED_DEBUG_OPTION",
                                                                    "Unsupported debug option, BIND_VERBOSE, enabled.");
                           cout << MessageLoader::getMessage(parms) << endl;
                       // remove the option from the command line
                       memmove(&argv[i], &argv[i + 1], (argc-i) * sizeof(char*));
                       argc--;
                   }
   #endif
                   //
                   // Check to see if user asked for shutdown (-s option):
                   //
                   else if (*option == OPTION_SHUTDOWN &&
                           (strlen(option) == 1))
                   {
                       //
                       // check to see if user is root
                       //
   #ifndef PEGASUS_OS_OS400
                       if (!System::isPrivilegedUser(System::getEffectiveUserName()))
                       {
                           //l10n
                           //cout << "You must have superuser privilege to run ";
                           //cout << "cimserver." << endl;
                           MessageLoaderParms parms("src.Server.cimserver.SUPERVISOR_PRIVILEGE_TO_RUN_SERVER",
                                                                            "You must have superuser privilege to run cimserver.");
  
     String removeOption;                          cout << MessageLoader::getMessage(parms) << endl;
     if(om.lookupValue("remove", removeOption) && removeOption == "true")                          exit(0);
                       }
   #endif
   
                       //
                       // Check to see if shutdown has already been specified:
                       //
                       if (shutdownOption)
       {       {
         if( 0 != cimserver_remove_nt_service() )                          //l10n
           cout << "\nPegasus removed as NT Service";                          //cout << "Duplicate shutdown option specified." << endl;
                           MessageLoaderParms parms("src.Server.cimserver.DUPLICATE_SHUTDOWN_OPTION",
                                                                            "Duplicate shutdown option specified.");
   
                           cout << MessageLoader::getMessage(parms) << endl;
         exit(0);         exit(0);
                       }
   
                       shutdownOption = true;
  
                       // remove the option from the command line
                       memmove(&argv[i], &argv[i + 1], (argc-i) * sizeof(char*));
                       argc--;
       }       }
   #ifdef PEGASUS_OS_TYPE_WINDOWS
                   else if (strcmp(option, OPTION_INSTALL) == 0)
                   {
                     //
                     // Install as a NT service
                     //
                     char *opt_arg = NULL;
                     if (i+1 < argc)
                     {
                       opt_arg = argv[i+1];
  
     // Check to see if user asked for the version (-v otpion):                    }
                     if(cimserver_install_nt_service(opt_arg))
                     {
                        //l10n
                         //cout << "\nPegasus installed as NT Service";
                         MessageLoaderParms parms("src.Server.cimserver.INSTALLED_NT_SERVICE",
                                                  "\nPegasus installed as NT Service");
  
     String versionOption;                        cout << MessageLoader::getMessage(parms) << endl;
                         exit(0);
                     }
                     else
                     {
                         exit(0);
                     }
                   }
                   else if (strcmp(option, OPTION_REMOVE) == 0)
                   {
                     //
                     // Remove Pegasus as an NT service
                     //
                     char *opt_arg = NULL;
                     if (i+1 < argc)
                     {
                       opt_arg = argv[i+1];
                     }
                     if(cimserver_remove_nt_service(opt_arg))
                     {
                         //l10n
                         //cout << "\nPegasus removed as NT Service";
                         MessageLoaderParms parms("src.Server.cimserver.REMOVED_NT_SERVICE",
                                                  "\nPegasus removed as NT Service");
  
     if (om.lookupValue("version", versionOption) && versionOption == "true")                        cout << MessageLoader::getMessage(parms) << endl;
                         exit(0);
                     }
                     else
     {     {
         cerr << PEGASUS_VERSION << endl;  
         exit(0);         exit(0);
     }     }
  
     // Check to see if user asked for help (-h otpion):                  }
     String helpOption;                  else if (strcmp(option, OPTION_START) == 0)
                   {
                     //
                     // Start as a NT service
                     //
                     char *opt_arg = NULL;
                     if (i+1 < argc)
                     {
                       opt_arg = argv[i+1];
                     }
                     if(cimserver_start_nt_service(opt_arg))
                     {
                         //l10n
                         //cout << "\nPegasus started as NT Service";
                         MessageLoaderParms parms("src.Server.cimserver.STARTED_NT_SERVICE",
                                                  "\nPegasus started as NT Service");
  
     if (om.lookupValue("help", helpOption) && helpOption == "true")                        cout << MessageLoader::getMessage(parms) << endl;
                         exit(0);
                     }
                     else
                     {
                         exit(0);
                     }
                   }
                   else if (strcmp(option, OPTION_STOP) == 0)
                   {
                     //
                     // Stop as a NT service
                     //
                     char *opt_arg = NULL;
                     if (i+1 < argc)
                     {
                       opt_arg = argv[i+1];
                     }
                     if(cimserver_stop_nt_service(opt_arg))
                     {
                         //l10n
                         //cout << "\nPegasus stopped as NT Service";
                         MessageLoaderParms parms("src.Server.cimserver.STOPPED_NT_SERVICE",
                                                  "\nPegasus stopped as NT Service");
   
                         cout << MessageLoader::getMessage(parms) << endl;
                         exit(0);
                     }
                     else
     {     {
         PrintHelp(argv[0]);  
         om.printHelp();  
         exit(0);         exit(0);
     }     }
                   }
   #endif
                   else
                       i++;
               }
               else
                   i++;
           }
       }
   
       //
       // Set the value for pegasusHome property
       //
       ConfigManager::setPegasusHome(pegasusHome);
  
     // Check the trace options and set global variable      //
     Boolean pegasusIOTrace = false;      // Get an instance of the Config Manager.
     if (om.valueEquals("trace", "true"))      //
       configManager = ConfigManager::getInstance();
   
       //
       // Get options (from command line and from configuration file); this
       // removes corresponding options and their arguments from the command
       // line.
       //
       try
     {     {
         Handler::setMessageTrace(true);          GetOptions(configManager, argc, argv, pegasusHome);
         pegasusIOTrace = true;  
     }     }
       catch (Exception& e)
       {
   #ifdef PEGASUS_OS_OS400
           Logger::put(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                           "$0: $1",argv[0] ,e.getMessage());
   #else
           cerr << argv[0] << ": " << e.getMessage() << endl;
   #endif
           exit(1);
       }
   
   // l10n
           // Set the home directory, msg sub-dir, into the MessageLoader.
           // This will be the default directory where the resource bundles
           // are found.
           String messagesDir = String::EMPTY;
   #ifdef PEGASUS_PLATFORM_OS400_ISERIES_IBM
           messagesDir = OS400_DEFAULT_MESSAGE_SOURCE;
   #else
           messagesDir = ConfigManager::getHomedPath("msg");
   #endif
           MessageLoader::setPegasusMsgHome(messagesDir);
  
     Boolean pegasusIOLog = false;      Boolean enableHttpConnection = String::equal(
     if (om.valueEquals("logtrace", "true"))          configManager->getCurrentValue("enableHttpConnection"), "true");
       Boolean enableHttpsConnection = String::equal(
           configManager->getCurrentValue("enableHttpsConnection"), "true");
   
       // Make sure at least one connection is enabled
   #ifndef PEGASUS_LOCAL_DOMAIN_SOCKET
       if (!enableHttpConnection && !enableHttpsConnection)
     {     {
         Handler::setMessageLogTrace(true);          //l10n
         pegasusIOLog = true;          //Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::WARNING,
               //"Neither HTTP nor HTTPS connection is enabled.  "
               //"CIMServer will not be started.");
           Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::WARNING,
                   "src.Server.cimserver.HTTP_NOT_ENABLED_SERVER_NOT_STARTING",
               "Neither HTTP nor HTTPS connection is enabled.  CIMServer will not be started.");
           //cerr << "Neither HTTP nor HTTPS connection is enabled.  "
               //"CIMServer will not be started." << endl;
           MessageLoaderParms parms("src.Server.cimserver.HTTP_NOT_ENABLED_SERVER_NOT_STARTING",
                                                            "Neither HTTP nor HTTPS connection is enabled.  CIMServer will not be started.");
           cerr << MessageLoader::getMessage(parms) << endl;
           exit(1);
     }     }
   #endif
  
     // Grab the port otpion:      try
       {
           //
           // Check to see if we should Pegasus as a daemon
           //
  
     String portOption;          if (String::equal(configManager->getCurrentValue("daemon"), "true"))
     om.lookupValue("port", portOption);          {
               daemonOption = true;
           }
  
     // Get the log file directory definition.     // Get the log file directory definition.
     // We put String into Cstring because     // We put String into Cstring because
     // Directory functions only handle Cstring.     // Directory functions only handle Cstring.
     // ATTN-KS: create String based directory functions.     // ATTN-KS: create String based directory functions.
     String logsDirectory;  
     om.lookupValue("logdir", logsDirectory);          logsDirectory = configManager->getCurrentValue("logdir");
           logsDirectory =
               ConfigManager::getHomedPath(configManager->getCurrentValue("logdir"));
  
     // Set up the Logger. This does not open the logs     // Set up the Logger. This does not open the logs
     // Might be more logical to clean before set.     // Might be more logical to clean before set.
     // ATTN: Need tool to completely disable logging.     // ATTN: Need tool to completely disable logging.
   
   #if !defined(PEGASUS_OS_HPUX) && !defined(PEGASUS_PLATFORM_LINUX_IA64_GNU) && \
   !defined(PEGASUS_OS_OS400)
     Logger::setHomeDirectory(logsDirectory);     Logger::setHomeDirectory(logsDirectory);
   #endif
  
     if (om.valueEquals("cleanlogs", "true"))          //
           // Check to see if we need to shutdown CIMOM
           //
           if (shutdownOption)
     {     {
         Logger::clean(logsDirectory);;              String configTimeout =
                   configManager->getCurrentValue("shutdownTimeout");
               timeoutValue = strtol(configTimeout.getCString(), (char **)0, 10);
   
               shutdownCIMOM(timeoutValue);
   
   #ifdef PEGASUS_OS_OS400
               //l10n
               //Logger::put(Logger::ERROR_LOG, System::CIMSERVER, Logger::INFORMATION,
                           //"CIM Server stopped.");
                   Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::INFORMATION,
                           "src.Server.cimserver.SERVER_STOPPED",
                           "CIM Server stopped.");
   #else
                           //l10n
               //cout << "CIM Server stopped." << endl;
               MessageLoaderParms parms("src.Server.cimserver.SERVER_STOPPED",
                                                            "CIM Server stopped.");
   
               cout << MessageLoader::getMessage(parms) << endl;
   #endif
               cimserver_exit(0);
     }     }
  
     // Leave this in until people get familiar with the logs.     // Leave this in until people get familiar with the logs.
     cout << "Logs Directory = " << logsDirectory << endl;  #if !defined(PEGASUS_OS_HPUX) && !defined(PEGASUS_PLATFORM_LINUX_IA64_GNU) && \
   !defined(PEGASUS_OS_OS400)
           //l10n
           //cout << "Logs Directory = " << logsDirectory << endl;
           MessageLoaderParms parms("src.Server.cimserver.LOGS_DIRECTORY",
                                                "Logs Directory = ");
           cout << MessageLoader::getMessage(parms) << logsDirectory << endl;
   #endif
  
           if (String::equal(configManager->getCurrentValue("slp"), "true"))
           {
               useSLP =  true;
           }
       }
       catch (UnrecognizedConfigProperty e)
       {
  
     char* address = portOption.allocateCString();  #ifdef PEGASUS_OS_OS400
           //l10n
           //Logger::put(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                       //"Error: $0",e.getMessage());
           Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                           "src.Server.cimserver.ERROR",
                       "Error: $0",e.getMessage());
   #else
           //l10n
           //cout << "Error: " << e.getMessage() << endl;
           MessageLoaderParms parms("src.Server.cimserver.ERROR",
                                                            "Error: $0",
                                                            e.getMessage());
           cout << MessageLoader::getMessage(parms) << endl;
   #endif
       }
  
     // Put out startup up message.      Uint32 portNumberHttps;
     cout << PEGASUS_NAME << PEGASUS_VERSION <<      Uint32 portNumberHttp;
          " on port " << address << endl;  
     cout << "Built " << __DATE__ << " " << __TIME__ << endl;  
     cout <<"Started..."  
          << (pegasusIOTrace ? " Tracing to Display ": " ")  
          << (pegasusIOLog ? " Tracing to Log ": " ")  
         << endl;  
  
     // Option to Display the options table.  Primarily      if (enableHttpsConnection)
     // a diagnostic tool.      {
     if (om.valueEquals("options", "true"))          String httpsPort = configManager->getCurrentValue("httpsPort");
         om.print();          CString portString = httpsPort.getCString();
           char* end = 0;
     // Put server start message to the logger          Uint32 port = strtol(portString, &end, 10);
     Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::INFORMATION,          assert(end != 0 && *end == '\0');
         "Start $0 $1 port $2 $3 ",  
                 PEGASUS_NAME,  
                 PEGASUS_VERSION,  
                 address,  
                 (pegasusIOTrace ? " Tracing": " "));  
  
     Boolean useSLP = false;;          //
           // Look up the WBEM-HTTPS port number
           //
           portNumberHttps = System::lookupPort(WBEM_HTTPS_SERVICE_NAME, port);
       }
  
     if(om.valueEquals("slp", "true"))      if (enableHttpConnection)
       useSLP = true;      {
           String httpPort = configManager->getCurrentValue("httpPort");
           CString portString = httpPort.getCString();
           char* end = 0;
           Uint32 port = strtol(portString, &end, 10);
           assert(end != 0 && *end == '\0');
   
           //
           // Look up the WBEM-HTTP port number
           //
           portNumberHttp = System::lookupPort(WBEM_HTTP_SERVICE_NAME, port);
       }
   
       // Put out startup up message.
   #if !defined(PEGASUS_OS_HPUX) && !defined(PEGASUS_PLATFORM_LINUX_IA64_GNU) && \
   !defined(PEGASUS_OS_OS400)
       cout << PEGASUS_NAME << PEGASUS_VERSION << endl;
       //l10n
       //cout << "Built " << __DATE__ << " " << __TIME__ << endl;
       //cout <<"Starting..."
       MessageLoaderParms parms("src.Server.cimserver.STARTUP_MESSAGE",
                                                    "Built $0 $1\nStarting...",
                                                    __DATE__,
                                                    __TIME__);
       cout << MessageLoader::getMessage(parms)
                    << (useSLP ? " SLP reg. " : " No SLP ")
                    << endl;
   #endif
   
   //l10n
   // reset message loading to NON-process locale
   MessageLoader::_useProcessLocale = false;
   //l10n
  
     // do we need to run as a daemon ?     // do we need to run as a daemon ?
     String daemonOption;      if (daemonOption)
     if(om.lookupValue("daemon", daemonOption) && daemonOption == "true")  
       {       {
         if(-1 == cimserver_fork())         if(-1 == cimserver_fork())
   #ifndef PEGASUS_OS_OS400
           {
           exit(-1);           exit(-1);
       }       }
   #else
           {
               return(-1);
           }
           else
           {
               return(0);
           }
   #endif
   
       }
   
   // l10n
       // Now we are after the fork...
       // Create a dummy Thread object that can be used to store the
       // AcceptLanguages object for CIM requests that are serviced
       // by this thread (initial thread of server).  Need to do this
       // because this thread is not in a ThreadPool, but is used
       // to service CIM requests.
       // The run function for the dummy Thread should never be called,
       Thread *dummyInitialThread = new Thread(dummyThreadFunc, NULL, false);
       Thread::setCurrent(dummyInitialThread);
       AcceptLanguages default_al;
       try{
            default_al = AcceptLanguages::getDefaultAcceptLanguages();
            Thread::setLanguages(new AcceptLanguages(default_al));
       }catch(InvalidAcceptLanguageHeader e){
             Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                                     "src.Server.cimserver.FAILED_TO_SET_PROCESS_LOCALE",
                             "Could not convert the system process locale into a valid AcceptLanguage format.");
                     Logger::put(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                                                    e.getMessage());
       }
  
  
   
   #ifdef PEGASUS_OS_OS400
       // Special server initialization code for OS/400.
       if (cimserver_initialize() != 0)
       {
           // do some logging here!
           //l10n
           //Logger::put(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                       //"CIM Server failed to initialize");
           Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                                     "src.Server.cimserver.SERVER_FAILED_TO_INITIALIZE",
                             "CIM Server failed to initialize");
           exit(-1);
       }
   #endif
   
   
   #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU) || defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)
       umask(S_IWGRP|S_IWOTH);
   
       //
       // check if CIMServer is already running
       // if CIMServer is already running, print message and
       // notify parent process (if there is a parent process) to terminate
       //
       if(isCIMServerRunning())
       {
           //l10n
                   //cout << "Unable to start CIMServer." << endl;
                   //cout << "CIMServer is already running." << endl;
                   MessageLoaderParms parms("src.Server.cimserver.UNABLE_TO_START_SERVER_ALREADY_RUNNING",
                                            "Unable to start CIMServer.\nCIMServer is already running.");
           PEGASUS_STD(cerr) << MessageLoader::getMessage(parms) << PEGASUS_STD(endl);
   
           //
           // notify parent process (if there is a parent process) to terminate
           //
           if (daemonOption)
                   notify_parent(1);
   
           exit(1);
       }
   
   #endif
   
     // try loop to bind the address, and run the server     // try loop to bind the address, and run the server
     try     try
     {     {
         Selector selector;  #if !defined(PEGASUS_OS_ZOS) && ! defined(PEGASUS_OS_HPUX) && ! defined(PEGASUS_NO_SLP)
         CIMServer server(&selector, pegasusHome);          char slp_address[32];
         server.setSLP(useSLP);          slp_client *discovery = new slp_client() ;;
           String serviceURL;
         // bind throws an exception of the bind fails          serviceURL.assign("service:cim.pegasus://");
         server.bind(address);          String host_name = slp_get_host_name();
         delete [] address;          serviceURL.append(host_name);
           serviceURL.append(":");
           // ATTN: Fix this to work for multiple connections
           sprintf(slp_address, "%u",
                   enableHttpConnection ? portNumberHttp : portNumberHttps);
           serviceURL.append(slp_address);
   #endif
   
           Monitor monitor(true);
           //monitor_2 monitor;
   
           CIMServer server(&monitor);
   
   
   
           if (enableHttpConnection)
           {
               server.addAcceptor(false, portNumberHttp, false);
               //l10n
               //Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                           //"Listening on HTTP port $0.", portNumberHttp);
   
               Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                                           "src.Server.cimserver.LISTENING_ON_HTTP_PORT",
                                   "Listening on HTTP port $0.", portNumberHttp);
           }
           if (enableHttpsConnection)
           {
               server.addAcceptor(false, portNumberHttps, true);
               //l10n
               //Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                           //"Listening on HTTPS port $0.", portNumberHttps);
               Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                                           "src.Server.cimserver.LISTENING_ON_HTTPS_PORT",
                                   "Listening on HTTPS port $0.", portNumberHttps);
           }
   #ifdef PEGASUS_LOCAL_DOMAIN_SOCKET
           server.addAcceptor(true, 0, false);
           //l10n
           //Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                       //"Listening on local connection socket.");
           Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                         "src.Server.cimserver.LISTENING_ON_LOCAL",
                         "Listening on local connection socket.");
   #endif
   
   #if !defined(PEGASUS_OS_HPUX) && !defined(PEGASUS_PLATFORM_LINUX_IA64_GNU) && !defined(PEGASUS_OS_OS400)
           if (enableHttpConnection)
           {
               //l10n
               //cout << "Listening on HTTP port " << portNumberHttp << endl;
             MessageLoaderParms parms("src.Server.cimserver.LISTENING_ON_HTTP_PORT",
                                      "Listening on HTTP port $0.", portNumberHttp);
                   cout << MessageLoader::getMessage(parms) << endl;
           }
           if (enableHttpsConnection)
           {
               //l10n
               //cout << "Listening on HTTPS port " << portNumberHttps << endl;
               MessageLoaderParms parms("src.Server.cimserver.LISTENING_ON_HTTPS_PORT",
                                        "Listening on HTTPS port $0.", portNumberHttps);
                   cout << MessageLoader::getMessage(parms) << endl;
           }
   # ifdef PEGASUS_LOCAL_DOMAIN_SOCKET
           //l10n
           //cout << "Listening on local connection socket" << endl;
           MessageLoaderParms parms("src.Server.cimserver.LISTENING_ON_LOCAL",
                                    "Listening on local connection socket.");
           cout << MessageLoader::getMessage(parms) << endl;
   # endif
   #endif
   
           // bind throws an exception if the bind fails
           server.bind();
   
           // notify parent process (if there is a parent process) to terminate
           // so user knows that there is cimserver ready to serve CIM requests.
           if (daemonOption)
                   notify_parent(0);
   
           time_t last = 0;
   
   #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU) || defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)
           //
           // create a file to indicate that the cimserver has started and
           // save the process id of the cimserver process in the file
           //
           // remove the old file if it exists
           System::removeFile(CIMSERVER_START_FILE);
   
           // open the file
           FILE *pid_file = fopen(CIMSERVER_START_FILE, "w");
   
           if (pid_file)
           {
               // save the pid in the file
               fprintf(pid_file, "%ld\n", (long)server_pid);
               fclose(pid_file);
           }
   #endif
   
   #if !defined(PEGASUS_OS_HPUX) && !defined(PEGASUS_PLATFORM_LINUX_IA64_GNU) && \
   !defined(PEGASUS_OS_OS400)
           cout << "Started. " << endl;
   #endif
   
           // Put server started message to the logger
   #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_IA64_GNU)
           //l10n
           //Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                       //"Started $0 version $1.",
                       //PLATFORM_PRODUCT_NAME, PLATFORM_PRODUCT_VERSION);
           Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                                   "src.Server.cimserver.STARTED_VERSION",
                       "Started $0 version $1.",
                       PLATFORM_PRODUCT_NAME, PLATFORM_PRODUCT_VERSION);
   #else
                   //l10n
           //Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                       //"Started $0 version $1.",
                       //PEGASUS_NAME, PEGASUS_VERSION);
           Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                                   "src.Server.cimserver.STARTED_VERSION",
                       "Started $0 version $1.",
                       PEGASUS_NAME, PEGASUS_VERSION);
   #endif
   
   
           //
           // Loop to call CIMServer's runForever() method until CIMServer
           // has been shutdown
           //
           while( !server.terminated() )
           {
   #if !defined(PEGASUS_OS_ZOS) && ! defined(PEGASUS_OS_HPUX) && ! defined(PEGASUS_NO_SLP)
             if(useSLP  )
             {
               if(  (time(NULL) - last ) > 60 )
               {
                 if( discovery != NULL && serviceURL.size() )
                   discovery->srv_reg_all(serviceURL.getCString(),
                                          "(namespace=root/cimv2)",
                                          "service:cim.pegasus",
                                          "DEFAULT",
                                          70) ;
                 time(&last);
               }
   
               discovery->service_listener();
             }
   #endif
         server.runForever();         server.runForever();
           }
  
         Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::INFORMATION,          //
             "Normal Termination");          // normal termination
           //
           // Put server shutdown message to the logger
   #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_IA64_GNU)
           //l10n
           //Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
               //"$0 stopped.", PLATFORM_PRODUCT_NAME);
           Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                   "src.Server.cimserver.STOPPED",
               "$0 stopped.", PLATFORM_PRODUCT_NAME);
   #else
                   //l10n
           //Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
               //"$0 stopped.", PEGASUS_NAME);
           Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
                   "src.Server.cimserver.STOPPED",
               "$0 stopped.", PEGASUS_NAME);
   #endif
  
   #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU) || defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)
           //
           // close the file created at startup time to indicate that the
           // cimserver has terminated normally.
           //
           FileSystem::removeFile(CIMSERVER_START_FILE);
   #endif
     }     }
     catch(Exception& e)     catch(Exception& e)
     {     {
         Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::INFORMATION,  
             "Abnormal Termination $0", e.getMessage());  
  
         PEGASUS_STD(cerr) << "Error: " << e.getMessage() << PEGASUS_STD(endl);          //l10n
           //Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::WARNING,
                       //"Error: $0", e.getMessage());
           Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::WARNING,
                           "src.Server.cimserver.ERROR",
                       "Error: $0", e.getMessage());
   
   #ifndef PEGASUS_OS_OS400
           //l10n
           //PEGASUS_STD(cerr) << "Error: " << e.getMessage() << PEGASUS_STD(endl);
           MessageLoaderParms parms("src.Server.cimserver.ERROR",
                                                            "Error: $0", e.getMessage());
           PEGASUS_STD(cerr) << MessageLoader::getMessage(parms) << PEGASUS_STD(endl);
   
   #endif
   
           //
           // notify parent process (if there is a parent process) to terminate
           //
           if (daemonOption)
                   notify_parent(1);
   
           return 1;
     }     }
  
     return 0;     return 0;


Legend:
Removed from v.1.23  
changed lines
  Added in v.1.109

No CVS admin address has been configured
Powered by
ViewCVS 0.9.2