(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.54 and 1.200

version 1.54, 2002/05/28 18:47:11 version 1.200, 2007/06/05 10:22:40
Line 1 
Line 1 
 //%/////////////////////////////////////////////////////////////////////////////  //%2006////////////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001 The Open group, BMC Software, Tivoli Systems, IBM  // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development
   // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.
   // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.;
   // IBM Corp.; EMC Corporation, The Open Group.
   // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;
   // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
   // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
   // EMC Corporation; VERITAS Software Corporation; The Open Group.
   // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;
   // EMC Corporation; Symantec Corporation; The Open Group.
 // //
 // Permission is hereby granted, free of charge, to any person obtaining a copy // Permission is hereby granted, free of charge, to any person obtaining a copy
 // of this software and associated documentation files (the "Software"), to // of this software and associated documentation files (the "Software"), to
Line 20 
Line 29 
 // //
 //============================================================================== //==============================================================================
 // //
 // Author: Mike Brasher (mbrasher@bmc.com)  
 //  
 // Modified By: Mike Day (mdday@us.ibm.com)  
 //  
 // 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)  
 //  
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
  
 ////////////////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////
 // //
 // Notes on deamon operation (Unix) and service operation (Win 32):  // Notes on daemon operation (Unix) and service operation (Win 32):
   //
   // To run pegasus as a daemon on Unix platforms:
   //
   // cimserver
 // //
 // To run pegasus as a daemon on Unix platforms, use the -d option:  // To NOT run pegasus as a daemon on Unix platforms, set the daemon config
   // property to false:
 // //
 // cimserver -d  // cimserver daemon=false
 // //
 // The -d option has no effect on windows operation.  // The daemon config property has no effect on windows operation.
 // //
 // To shutdown pegasus, use the -s option: // To shutdown pegasus, use the -s option:
 // //
 // cimserver -s [-t timeout_value]  // 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 62 
Line 64 
 // To START the Pegasus service, // To START the Pegasus service,
 // //
 // net start cimserver // net start cimserver
   // or
   // cimserver -start
 // //
 // To STOP the Pegasus service, // To STOP the Pegasus service,
 // //
 // net stop cimserver // net stop cimserver
   // or
   // cimserver -stop
 // //
 // Alternatively, you can use the windows service manager. Pegasus shows up // Alternatively, you can use the windows service manager. Pegasus shows up
 // in the service database as "Pegasus CIM Object Manager" // in the service database as "Pegasus CIM Object Manager"
 // //
 // Mike Day, mdday@us.ibm.com  
 //  
 ////////////////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////
  
  
 #include <Pegasus/Common/Config.h> #include <Pegasus/Common/Config.h>
 #include <Pegasus/suballoc/suballoc.h>  #include <Pegasus/Common/Constants.h>
 #include <iostream>  #include <Pegasus/Common/PegasusAssert.h>
 #include <cassert>  
 #include <cstdlib>  
 #include <fstream>  
 #include <Pegasus/Common/FileSystem.h> #include <Pegasus/Common/FileSystem.h>
 #include <Pegasus/Common/Monitor.h> #include <Pegasus/Common/Monitor.h>
 #include <Pegasus/Server/CIMServer.h>  
 #include <Pegasus/Common/PegasusVersion.h> #include <Pegasus/Common/PegasusVersion.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/Common/Tracer.h>
   #include <Pegasus/Common/LanguageParser.h>
 #include <Pegasus/Config/ConfigManager.h> #include <Pegasus/Config/ConfigManager.h>
 #include <Pegasus/Client/CIMClient.h> #include <Pegasus/Client/CIMClient.h>
 #include <Pegasus/Server/ShutdownService.h>  #include <Pegasus/Server/CIMServer.h>
 #include <Pegasus/Common/Destroyer.h>  #include <Service/ServerProcess.h>
 #if !defined(PEGASUS_OS_ZOS) && ! defined(PEGASUS_OS_HPUX)  #include <Service/ServerShutdownClient.h>
 #include <slp/slp.h>  #include <Service/ServerRunStatus.h>
   
   #if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)
   #include <Service/ARM_zOS.h>
   # ifdef PEGASUS_ZOS_SECURITY
   // This include file will not be provided in the OpenGroup CVS for now.
   // Do NOT try to include it in your compile
   #  include <Pegasus/Common/safCheckzOS_inline.h>
   # endif
 #endif #endif
  
   #if defined(PEGASUS_OS_TYPE_UNIX)
   # include <unistd.h>
   # include <sys/types.h>
   # include <sys/stat.h>
   # include <fcntl.h>
   #endif
  
 #if defined(PEGASUS_OS_TYPE_WINDOWS)  #ifdef PEGASUS_ENABLE_PRIVILEGE_SEPARATION
 # include "cimserver_windows.cpp"  # define PEGASUS_PROCESS_NAME "cimservermain"
 #elif defined(PEGASUS_OS_TYPE_UNIX)  
 # include "cimserver_unix.cpp"  
 #else #else
 # error "Unsupported platform"  # define PEGASUS_PROCESS_NAME "cimserver"
 #endif #endif
  
   #include <Pegasus/Common/Executor.h>
   
 PEGASUS_USING_PEGASUS; PEGASUS_USING_PEGASUS;
 PEGASUS_USING_STD; PEGASUS_USING_STD;
  
   //Windows service variables are not defined elsewhere in the product
   //enable ability to override these
   #ifndef PEGASUS_SERVICE_NAME
   #define PEGASUS_SERVICE_NAME "Pegasus CIM Object Manager";
   #endif
   #ifndef PEGASUS_SERVICE_DESCRIPTION
   #define PEGASUS_SERVICE_DESCRIPTION "Pegasus CIM Object Manager Service";
   #endif
   
   class CIMServerProcess : public ServerProcess
   {
   public:
   
       CIMServerProcess(void)
       {
           cimserver_set_process(this);
       }
   
       virtual ~CIMServerProcess(void)
       {
       }
   
       //defined in PegasusVersion.h
       virtual const char* getProductName() const
       {
           return PEGASUS_PRODUCT_NAME;
       }
   
       virtual const char* getExtendedName() const
       {
           return PEGASUS_SERVICE_NAME;
       }
   
       virtual const char* getDescription() const
       {
           return PEGASUS_SERVICE_DESCRIPTION;
       }
   
       //defined in PegasusVersion.h
       virtual const char* getCompleteVersion() const
       {
         if (*PEGASUS_PRODUCT_STATUS == '\0' )
           return PEGASUS_PRODUCT_VERSION;
         else
           return PEGASUS_PRODUCT_VERSION " " PEGASUS_PRODUCT_STATUS;
       }
   
       //defined in PegasusVersion.h
       virtual const char* getVersion() const
       {
           return PEGASUS_PRODUCT_VERSION;
       }
   
       virtual const char* getProcessName() const
       {
           return PEGASUS_PROCESS_NAME;
       }
   
       //defined in Constants.h
       virtual const char* getPIDFileName() const
       {
           return PEGASUS_CIMSERVER_START_FILE;
       }
   
       int cimserver_run(
           int argc,
           char** argv,
           Boolean shutdownOption,
           Boolean debugOutputOption);
   
       void cimserver_stop(void);
   };
   
   ServerRunStatus _serverRunStatus(
       PEGASUS_PROCESS_NAME, PEGASUS_CIMSERVER_START_FILE);
   AutoPtr<CIMServerProcess> _cimServerProcess(new CIMServerProcess());
   static CIMServer* _cimServer = 0;
   static Monitor* _monitor = 0;
   static Thread* dummyInitialThread = 0;
 // //
 //  The command name. //  The command name.
 // //
Line 129 
Line 223 
  
 static const char OPTION_SHUTDOWN    = 's'; static const char OPTION_SHUTDOWN    = 's';
  
 static const char OPTION_FORCE       = 'f';  static const char   LONG_HELP []  = "help";
  
 static const char OPTION_TIMEOUT     = 't';  static const char   LONG_VERSION []  = "version";
  
 #if defined(PEGASUS_OS_HPUX)  static const char OPTION_DEBUGOUTPUT = 'X';
 static const char OPTION_BINDVERBOSE = 'X';  
 #endif  
  
 static const String NAMESPACE = "root/PG_Internal";  
 static const String CLASSNAME_SHUTDOWNSERVICE = "PG_ShutdownService";  
 static const String PROPERTY_TIMEOUT = "shutdownTimeout"; static const String PROPERTY_TIMEOUT = "shutdownTimeout";
 static const String CIMSERVERSTART_FILE = "/etc/wbem/cimserver_start.conf";  
  
 ConfigManager*    configManager; 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 config manager.     and sets up the options from that table using the config manager.
   
       Some possible exceptions:  NoSuchFile, FileNotReadable, CannotRenameFile,
       ConfigFileSyntaxError, UnrecognizedConfigProperty, InvalidPropertyValue,
       CannotOpenFile.
 */ */
 void GetOptions( void GetOptions(
     ConfigManager* cm,     ConfigManager* cm,
     int& argc,     int& argc,
     char** argv,     char** argv,
     const String& pegasusHome)      Boolean shutdownOption)
 {  
     try  
     {  
         cm->mergeConfigFiles();  
   
         cm->mergeCommandLine(argc, argv);  
     }  
     catch (NoSuchFile nsf)  
     {  
         throw nsf;  
     }  
     catch (FileNotReadable fnr)  
     {  
         throw fnr;  
     }  
     catch (CannotRenameFile ftrf)  
     {     {
         throw ftrf;      if (shutdownOption)
     }  
     catch (ConfigFileSyntaxError cfse)  
     {  
         throw cfse;  
     }  
     catch(UnrecognizedConfigProperty ucp)  
     {     {
         throw ucp;          cm->loadConfigFiles();
     }     }
     catch(InvalidPropertyValue ipv)      else
     {     {
         throw ipv;          cm->mergeConfigFiles();
     }     }
   
       // Temporarily disable updates to the current configuration
       // file if shutdownOption is true
       cm->useConfigFiles = (shutdownOption==false);
   
       cm->mergeCommandLine(argc, argv);
   
       // Enable updates again
       cm->useConfigFiles = true;
 } }
  
 /* 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 191 
Line 271 
 */ */
 void PrintHelp(const char* arg0) void PrintHelp(const char* arg0)
 { {
     /**  
         Build the usage string for the config command.  
     */  
     String usage = String (USAGE);     String usage = String (USAGE);
     usage.append (COMMAND_NAME);     usage.append (COMMAND_NAME);
     usage.append (" [ [ options ] | [ configProperty=value, ... ] ]\n");     usage.append (" [ [ options ] | [ configProperty=value, ... ] ]\n");
     usage.append ("  options\n");     usage.append ("  options\n");
     usage.append ("    -v          - displays pegasus version number\n");      usage.append ("    -v, --version   - displays CIM Server version number\n");
     usage.append ("    -h          - prints this help message\n");      usage.append ("    -h, --help      - prints this help message\n");
       usage.append ("    -s              - shuts down CIM Server\n");
   #if !defined(PEGASUS_USE_RELEASE_DIRS)
     usage.append ("    -D [home]   - sets pegasus home directory\n");     usage.append ("    -D [home]   - sets pegasus home directory\n");
     usage.append ("    -d          - runs pegasus as a daemon\n");  #endif
     usage.append ("    -s [-t timeout] \n");  #if defined(PEGASUS_OS_TYPE_WINDOWS)
     usage.append ("                - shuts down pegasus\n");      usage.append ("    -install [name] - installs pegasus as a Windows Service\n");
 #if !defined(PEGASUS_OS_HPUX)      usage.append ("                      [name] is optional and overrides the\n");
     usage.append ("    -cleanlogs  - clears the log files at startup\n");      usage.append ("                      default CIM Server Service Name\n");
     usage.append ("    -install    - installs pegasus as a Windows NT Service\n");      usage.append ("                      by appending [name]\n");
     usage.append ("    -remove     - removes pegasus as a Windows NT Service\n");      usage.append ("    -remove [name]  - removes pegasus as a Windows Service\n");
     usage.append ("    -slp        - registers pegasus as a service with SLP\n\n");      usage.append ("                      [name] is optional and overrides the\n");
     usage.append ("    -SSL        - uses SSL\n\n");      usage.append ("                      default CIM Server Service Name\n");
       usage.append ("                      by appending [name]\n");
       usage.append ("    -start [name]   - starts pegasus as a Windows Service\n");
       usage.append ("                      [name] is optional and overrides the\n");
       usage.append ("                      default CIM Server Service Name\n");
       usage.append ("                      by appending [name]\n");
       usage.append ("    -stop [name]    - stops pegasus as a Windows Service\n");
       usage.append ("                      [name] is optional and overrides the\n");
       usage.append ("                      default CIM Server Service Name\n");
       usage.append ("                      by appending [name]\n\n");
 #endif #endif
     usage.append ("  configProperty=value\n");     usage.append ("  configProperty=value\n");
     usage.append ("    port=nnnn            - sets port number to listen on\n");      usage.append ("                    - sets CIM Server configuration property\n");
     usage.append ("    logdir=/pegasus/logs - directory for log files\n");  
  
     cout << endl;     cout << endl;
     cout << PEGASUS_NAME << PEGASUS_VERSION << endl;      cout << _cimServerProcess->getProductName() << " " << _cimServerProcess->getCompleteVersion() << endl;
     cout << endl;     cout << endl;
     cout << usage << endl;  
   #if defined(PEGASUS_OS_TYPE_WINDOWS)
       MessageLoaderParms parms("src.Server.cimserver.MENU.WINDOWS", usage);
   #elif defined(PEGASUS_USE_RELEASE_DIRS)
       MessageLoaderParms parms("src.Server.cimserver.MENU.HPUXLINUXIA64GNU", usage);
   #else
       MessageLoaderParms parms("src.Server.cimserver.MENU.STANDARD", usage);
   #endif
       cout << MessageLoader::getMessage(parms) << endl;
 } }
  
 void shutdownCIMOM(Uint32 timeoutValue)  //This needs to be called at various points in the code depending on the platform and error conditions.
   //We need to delete the _cimServer reference on exit in order for the destructors to get called.
   void deleteCIMServer()
 { {
     //      if (_cimServer)
     // Create CIMClient object      {
     //          delete _cimServer;
     CIMClient client;          _cimServer = 0;
   
     //  
     // Get local host name  
     //  
     String hostStr = System::getHostName();  
  
   #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_OS_LINUX) \
   || defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM) || defined(PEGASUS_OS_AIX) \
   || defined(PEGASUS_OS_SOLARIS) || defined(PEGASUS_OS_VMS)
     //     //
     // open connection to CIMOM          //  Remove the PID file to indicate CIMServer termination
     //     //
     try          FileSystem::removeFile(_cimServerProcess->getPIDFileName());
   #endif
       }
       delete _monitor;
      if (dummyInitialThread)
     {     {
         client.connectLocal();          Thread::clearLanguages();
           delete dummyInitialThread;
      }
   }
  
   // l10n
         //         //
         // set client timeout to 2 seconds more than the shutdown timeout  // Dummy function for the Thread object associated with the initial thread.
         // so that the command client does not timeout before the cimserver  // Since the initial thread is used to process CIM requests, this is
         // terminates  // needed to localize the exceptions thrown during CIM request processing.
   // Note: This function should never be called!
         //         //
         Uint32 clientTimeout;  ThreadReturnType PEGASUS_THREAD_CDECL dummyThreadFunc(void *parm)
         if (timeoutValue == 0)  
         {         {
             String configTimeout =     return((ThreadReturnType)0);
                 configManager->getCurrentValue("shutdownTimeout");  
            ArrayDestroyer<char> timeoutCString(configTimeout.allocateCString());  
             clientTimeout =  
                 ((strtol(timeoutCString.getPointer(), (char **)0,10))+2)*1000;  
         }         }
         else  
   #ifdef PEGASUS_ENABLE_PRIVILEGE_SEPARATION
   
   static int _extractExecutorSockOpt(int& argc, char**& argv)
         {         {
             clientTimeout = (timeoutValue + 2)*1000;      // Extract the "--executor-socket <sock>" option if any. This indicates
         }      // that the e[x]ecutor is running. The option argument is the socket used
       // to communicate with the executor. Remove the option from the
       // argv list and decrease argc by two.
  
         client.setTimeOut(clientTimeout);      int sock = -1;
     }      const char OPT[] = "--executor-socket";
     catch(CIMClientException& e)  
       for (int i = 1; i < argc; i++)
     {     {
         PEGASUS_STD(cerr) << "Unable to connect to CIM Server." << PEGASUS_STD(endl);          if (strcmp(argv[i], OPT) == 0)
         PEGASUS_STD(cerr) << "CIM Server may not be running." << PEGASUS_STD(endl);          {
         exit(0);              // Check for missing option argument.
     }  
  
     try              if (i + 1 == argc)
     {     {
         //                  MessageLoaderParms parms(
         // construct CIMObjectPath                      "src.Server.cimserver.MISSING_OPTION_ARGUMENT",
         //                      "Missing argument for $0 option.",
         String referenceStr = "//";                      OPT);
         referenceStr.append(hostStr);                  cerr << argv[0] << ": " << MessageLoader::getMessage(parms) <<
         referenceStr.append(PEGASUS_NAMESPACENAME_CIMV2);                      endl;
         referenceStr.append(":");                  exit(1);
         referenceStr.append(PEGASUS_CLASSNAME_SHUTDOWN);              }
         CIMObjectPath reference(referenceStr);  
  
         //              // Convert argument to positive integer.
         // issue the invokeMethod request on the shutdown method  
         //  
         Array<CIMParamValue> inParams;  
         Array<CIMParamValue> outParams;  
  
         // set force option to true for now              char* end;
         inParams.append(CIMParamValue("force",              unsigned long x = strtoul(argv[i+1], &end, 10);
             CIMValue(Boolean(true))));  
  
         inParams.append(CIMParamValue("timeout",              // Check whether option argument will fit in a signed integer.
             CIMValue(Uint32(timeoutValue))));  
  
         CIMValue retValue = client.invokeMethod(              if (*end != '\0' || x > 2147483647)
             NAMESPACE,  
             reference,  
             "shutdown",  
             inParams,  
             outParams);  
     }  
     catch(CIMClientCIMException& e)  
     {     {
         PEGASUS_STD(cerr) << "Failed to shutdown server: ";                  MessageLoaderParms parms(
         PEGASUS_STD(cerr) << e.getMessage() << PEGASUS_STD(endl);                      "src.Server.cimserver.BAD_OPTION_ARGUMENT",
                       "Bad $0 option argument: $1.",
                       OPT,
                       argv[i+1]);
                   cerr << argv[0] << ": " << MessageLoader::getMessage(parms) <<
                       endl;
         exit(1);         exit(1);
     }     }
     catch(CIMClientException& e)  
     {  
         //  
         // This may mean the CIM Server has been terminated and returns a  
         // "Empty HTTP response message" HTTP error response.  To be sure  
         // CIM Server gets shutdown, if CIM Server is still running at  
         // this time, we will kill the cimserver process.  
         //  
   
 #if defined(PEGASUS_OS_HPUX)  
  
         // give cimom some time to finish up              sock = int(x);
         System::sleep(1);  
  
         // add code to kill cimom if it is still running              // Remove "-x <sock>" from argv-argc.
  
 #endif              memmove(argv + i, argv + i + 2, sizeof(char*) * (argc - i - 1));
               argc -= 2;
               break;
     }     }
     catch(Exception& e)      }
   
       if (sock == -1)
     {     {
         PEGASUS_STD(cerr) << "Failed to shutdown server: ";          MessageLoaderParms parms(
         PEGASUS_STD(cerr) << e.getMessage() << PEGASUS_STD(endl);              "src.Server.cimserver.MISSING_OPTION",
               "Missing $0 option.",
               OPT);
           cerr << argv[0] << ": " << MessageLoader::getMessage(parms) << endl;
         exit(1);         exit(1);
     }     }
  
     return;      return sock;
 } }
  
   #endif /* PEGASUS_ENABLE_PRIVILEGE_SEPARATION */
  
 ///////////////////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////////////////////
 //  MAIN //  MAIN
 ////////////////////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////////
   
 int main(int argc, char** argv) int main(int argc, char** argv)
 { {
     String pegasusHome  = String::EMPTY;      String pegasusHome;
     Boolean pegasusIOLog = false;  
     String httpPort = String::EMPTY;  
     String httpsPort = String::EMPTY;  
     String logsDirectory = String::EMPTY;  
     Boolean useSLP = false;  
     Boolean useSSL = false;  
     Boolean daemonOption = false;  
     Boolean shutdownOption = false;     Boolean shutdownOption = false;
     Boolean timeoutOption = false;      Boolean debugOutputOption = false;
     String  timeoutStr  = String::EMPTY;  
     long timeoutValue  = 0;  //l10n
   // Set Message loading to process locale
   MessageLoader::_useProcessLocale = true;
   //l10n
   
   //l10n
   #if defined(PEGASUS_OS_AIX) && defined(PEGASUS_HAS_MESSAGES)
   setlocale(LC_ALL, "");
   #endif
  
   #ifndef PEGASUS_OS_TYPE_WINDOWS
     //     //
     // Get environment variables:     // Get environment variables:
     //     //
     #if defined(PEGASUS_OS_AIX) && defined(PEGASUS_USE_RELEASE_DIRS)
       pegasusHome = AIX_RELEASE_PEGASUS_HOME;
     #elif !defined(PEGASUS_USE_RELEASE_DIRS) || defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)
     const char* tmp = getenv("PEGASUS_HOME");     const char* tmp = getenv("PEGASUS_HOME");
  
     if (tmp)     if (tmp)
     {     {
         pegasusHome = tmp;         pegasusHome = tmp;
     }     }
     #endif
  
     FileSystem::translateSlashes(pegasusHome);     FileSystem::translateSlashes(pegasusHome);
   #else
   
     // windows only
     //setHome(pegasusHome);
     pegasusHome = _cimServerProcess->getHome();
   #endif
   
   #ifdef PEGASUS_ENABLE_PRIVILEGE_SEPARATION
   
       // If invoked with "--executor-socket <socket>" option, then use executor.
  
     // on Windows NT if there are no command-line options, run as a service      Executor::setSock(_extractExecutorSockOpt(argc, argv));
  
     if (argc == 1 )      // Ping executor to verify the specified socket is valid.
   
       if (Executor::ping() != 0)
     {     {
       cim_server_service(argc, argv);          MessageLoaderParms parms("src.Server.cimserver.EXECUTOR_PING_FAILED",
               "Failed to ping the executor on the specified socket.");
           cerr << argv[0] << ": " << MessageLoader::getMessage(parms) << endl;
           exit(1);
     }     }
     else  
     {  #endif /* !defined(PEGASUS_ENABLE_PRIVILEGE_SEPARATION) */
         // Get help, version and home options  
           // Get help, version, and shutdown options
  
         for (int i = 1; i < argc; )         for (int i = 1; i < argc; )
         {         {
             const char* arg = argv[i];             const char* arg = argv[i];
               if(String::equal(arg,"--help"))
               {
                       PrintHelp(argv[0]);
                       exit(0);
               }
               else if(String::equal(arg,"--version"))
               {
                   cout << _cimServerProcess->getCompleteVersion() << endl;
                   exit(0);
               }
             // Check for -option             // Check for -option
             if (*arg == '-')              else if (*arg == '-')
             {             {
                 // Get the option                 // Get the option
                 const char* option = arg + 1;                 const char* option = arg + 1;
Line 388 
Line 512 
                 //                 //
                 // Check to see if user asked for the version (-v option):                 // Check to see if user asked for the version (-v option):
                 //                 //
                 if (*option == OPTION_VERSION)                  if (*option == OPTION_VERSION &&
                       strlen(option) == 1)
                 {                 {
                     cout << PEGASUS_VERSION << endl;                      cout << _cimServerProcess->getCompleteVersion() << endl;
                     exit(0);                     exit(0);
                 }                 }
                 //                 //
                 // Check to see if user asked for help (-h option):                 // Check to see if user asked for help (-h option):
                 //                 //
                 else if (*option == OPTION_HELP)                  else if (*option == OPTION_HELP &&
                           (strlen(option) == 1))
                 {                 {
                     PrintHelp(argv[0]);                     PrintHelp(argv[0]);
                     exit(0);                     exit(0);
                 }                 }
                 else if (*option == OPTION_HOME)  #if !defined(PEGASUS_USE_RELEASE_DIRS)
                   else if (*option == OPTION_HOME &&
                           (strlen(option) == 1))
                 {                 {
                     if (i + 1 < argc)                     if (i + 1 < argc)
                     {                     {
Line 409 
Line 537 
                     }                     }
                     else                     else
                     {                     {
                         cout << "Missing argument for option -" << option << endl;                          //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);
                     }                     }
  
                     memmove(&argv[i], &argv[i + 2], (argc-i-1) * sizeof(char*));                     memmove(&argv[i], &argv[i + 2], (argc-i-1) * sizeof(char*));
                     argc -= 2;                     argc -= 2;
                 }                 }
 #if defined(PEGASUS_OS_HPUX)  #endif
                 //                 //
                 // Check to see if user asked for the version (-X option):                  // Check to see if user asked for debug output (-X option):
                 //                 //
                 if (*option == OPTION_BINDVERBOSE)                  else if (*option == OPTION_DEBUGOUTPUT &&
                           (strlen(option) == 1))
                 {                 {
                       MessageLoaderParms parms(
                           "src.Server.cimserver.UNSUPPORTED_DEBUG_OPTION",
                           "Unsupported debug output option is enabled.");
                       cout << MessageLoader::getMessage(parms) << endl;
   
                       debugOutputOption = true;
   
   #if defined(PEGASUS_OS_HPUX)
                     System::bindVerbose = true;                     System::bindVerbose = true;
                     cout << "Unsupported debug option, BIND_VERBOSE, enabled."  #endif
                          << endl;  
                     // remove the option from the command line                     // remove the option from the command line
                     memmove(&argv[i], &argv[i + 1], (argc-i) * sizeof(char*));                     memmove(&argv[i], &argv[i + 1], (argc-i) * sizeof(char*));
                     argc--;                     argc--;
                 }                 }
 #endif  
                 //                 //
                 // Check to see if user asked for shutdown (-s option):                 // Check to see if user asked for shutdown (-s option):
                 //                 //
                 else if (*option == OPTION_SHUTDOWN)                  else if (*option == OPTION_SHUTDOWN &&
                 {                          (strlen(option) == 1))
   
                     //  
                     // check to see if user is root  
                     //  
                     if (!System::isPrivilegedUser())  
                     {                     {
                         cout << "You must have superuser privilege to run ";  
                         cout << "cimserver." << endl;  
                         exit(0);  
                     }  
   
                     //                     //
                     // Check to see if shutdown has already been specified:                     // Check to see if shutdown has already been specified:
                     //                     //
                     if (shutdownOption)                     if (shutdownOption)
                     {                     {
                         cout << "Duplicate shutdown option specified." << endl;                          //l10n
                           //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);
                     }                     }
  
Line 461 
Line 598 
                     memmove(&argv[i], &argv[i + 1], (argc-i) * sizeof(char*));                     memmove(&argv[i], &argv[i + 1], (argc-i) * sizeof(char*));
                     argc--;                     argc--;
                 }                 }
                 else if (*option == OPTION_TIMEOUT)  
                 {  
                     //  
                     // Check to see if shutdown has been specified:  
                     //  
                     if (!shutdownOption)  
                     {  
                         cout << "Invalid option -" << option << endl;  
                         exit(0);  
                     }  
   
                     if (timeoutOption)  
                     {  
                         cout << "Duplicate timeout option specified." << endl;  
                         exit(0);  
                     }  
   
                     timeoutOption = true;  
   
                     if (i + 1 < argc)  
                     {  
                         // get timeout value  
                         timeoutStr.assign(argv[i + 1]);  
   
                         // validate timeout value string  
                         char* tmp = timeoutStr.allocateCString();  
                         char* end = 0;  
                         timeoutValue  = strtol(tmp, &end, 10);  
   
                         if (!end || *end != '\0')  
                         {  
                             cout << "invalid timeout value specified: ";  
                             cout << timeoutStr << endl;  
                             delete [] tmp;  
                             exit(0);  
                         }  
                     }  
                     else  
                     {  
                         cout << "Missing argument for option -";  
                         cout << option << endl;  
                         exit(0);  
                     }  
   
                     // remove the option from the command line  
                     memmove(&argv[i], &argv[i + 2], (argc-i-1) * sizeof(char*));  
                     argc -= 2;  
                 }  
                 else                 else
                     i++;                     i++;
             }             }
             else             else
                 i++;                 i++;
         }         }
     }  
  
     //     //
     // Set the value for pegasusHome property     // Set the value for pegasusHome property
Line 523 
Line 611 
     ConfigManager::setPegasusHome(pegasusHome);     ConfigManager::setPegasusHome(pegasusHome);
  
     //     //
       // Do the platform specific run
       //
   
       return _cimServerProcess->platform_run(
           argc, argv, shutdownOption, debugOutputOption);
   }
   
   void CIMServerProcess::cimserver_stop()
   {
       _cimServer->shutdownSignal();
   }
   
   //
   // The main, common, running code
   //
   // NOTE: Do NOT call exit().  Use return(), otherwise some platforms
   // will fail to shutdown properly/cleanly.
   //
   // TODO: Current change minimal for platform "service" shutdown bug fixes.
   // Perhaps further extract out common stuff and put into main(), put
   // daemon stuff into platform specific platform_run(), etc.
   // Note: make sure to not put error handling stuff that platform
   // specific runs may need to deal with better (instead of exit(), etc).
   //
   
   int CIMServerProcess::cimserver_run(
       int argc,
       char** argv,
       Boolean shutdownOption,
       Boolean debugOutputOption)
   {
       String logsDirectory;
       Boolean daemonOption = false;
   
       //
     // Get an instance of the Config Manager.     // Get an instance of the Config Manager.
     //     //
     configManager = ConfigManager::getInstance();     configManager = ConfigManager::getInstance();
       configManager->useConfigFiles = true;
  
     //     //
     // Get options (from command line and from configuration file); this     // Get options (from command line and from configuration file); this
Line 534 
Line 658 
     //     //
     try     try
     {     {
         GetOptions(configManager, argc, argv, pegasusHome);          // If current process is "cimserver -s" (shutdown option = true) the contents
           // of current config should not be overwriten by planned config
           GetOptions(configManager, argc, argv, shutdownOption);
     }     }
     catch (Exception& e)     catch (Exception& e)
     {     {
         cerr << argv[0] << ": " << e.getMessage() << endl;          Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
         exit(1);              "src.Server.cimserver.SERVER_NOT_STARTED",
               "cimserver not started:  $0", e.getMessage());
   
           MessageLoaderParms parms("src.Server.cimserver.SERVER_NOT_STARTED",
               "cimserver not started: $0", e.getMessage());
   
           PEGASUS_STD(cerr) << argv[0] << ": " << MessageLoader::getMessage(parms)
               << PEGASUS_STD(endl);
   
           return(1);
       }
   
   // l10n
       // Set the home directory, msg sub-dir, into the MessageLoader.
       // This will be the default directory where the resource bundles
       // are found.
       MessageLoader::setPegasusMsgHome(ConfigManager::getHomedPath(
           ConfigManager::getInstance()->getCurrentValue("messageDir")));
   
       Boolean enableHttpConnection = ConfigManager::parseBooleanValue(
           configManager->getCurrentValue("enableHttpConnection"));
       Boolean enableHttpsConnection = ConfigManager::parseBooleanValue(
           configManager->getCurrentValue("enableHttpsConnection"));
   
       // Make sure at least one connection is enabled
   #ifdef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET
       if (!enableHttpConnection && !enableHttpsConnection)
       {
           //l10n
           //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;
           return(1);
     }     }
   #endif
  
     try     try
     {     {
         //         //
         // Check to see if we should (can) install as a NT service          // Check to see if we should start Pegasus as a daemon
         //         //
  
         if (String::equal(configManager->getCurrentValue("install"), "true"))          daemonOption = ConfigManager::parseBooleanValue(
         {              configManager->getCurrentValue("daemon"));
             if( 0 != cimserver_install_nt_service( pegasusHome ))  
             {  #if !defined(PEGASUS_USE_SYSLOGS)
                 cout << "\nPegasus installed as NT Service";          logsDirectory =
                 exit(0);          ConfigManager::getHomedPath(configManager->getCurrentValue("logdir"));
             }  #endif
         }  
           // Set up the Logger. This does not open the logs
           // Might be more logical to clean before set.
           // ATTN: Need tool to completely disable logging.
   
   #if !defined(PEGASUS_OS_HPUX) && !defined(PEGASUS_PLATFORM_LINUX_IA64_GNU) && \
   !defined(PEGASUS_USE_SYSLOGS)
           Logger::setHomeDirectory(logsDirectory);
   #endif
  
         //         //
         // Check to see if we should (can) remove Pegasus as an NT service          // Check to see if we need to shutdown CIMOM
         //         //
           if (shutdownOption)
         if (String::equal(configManager->getCurrentValue("remove"), "true"))  
         {  
             if( 0 != cimserver_remove_nt_service() )  
             {             {
                 cout << "\nPegasus removed as NT Service";              String configTimeout =
                 exit(0);                  configManager->getCurrentValue("shutdownTimeout");
               Uint32 timeoutValue = strtol(configTimeout.getCString(), (char **)0, 10);
   // To deregister Pegasus with SLP
   #ifdef PEGASUS_SLP_REG_TIMEOUT
               unregisterPegasusFromSLP();
   #endif
   
               ServerShutdownClient serverShutdownClient(&_serverRunStatus);
               serverShutdownClient.shutdown(timeoutValue);
   
               MessageLoaderParms parms(
                   "src.Server.cimserver.SERVER_STOPPED",
                   "CIM Server stopped.");
   
               cout << MessageLoader::getMessage(parms) << endl;
               return(0);
           }
   
   #if defined(PEGASUS_DEBUG) && !defined(PEGASUS_USE_SYSLOGS)
           // Leave this in until people get familiar with the logs.
           MessageLoaderParms parms("src.Server.cimserver.LOGS_DIRECTORY",
                                    "Logs Directory = ");
           cout << MessageLoader::getMessage(parms) << logsDirectory << endl;
   #endif
             }             }
       catch (UnrecognizedConfigProperty& e)
       {
           // UnrecognizedConfigProperty is already translated
           // thus, just output the message
           Logger::put(Logger::ERROR_LOG,
                       System::CIMSERVER,
                       Logger::SEVERE,
                       e.getMessage());
           cout << e.getMessage() << endl;
       }
       catch (Exception& ex)
       {
           Logger::put(Logger::ERROR_LOG,
                         System::CIMSERVER,
                         Logger::SEVERE,
                         ex.getMessage());
           cout << ex.getMessage() << endl;
           exit(1);
         }         }
  
   #if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM) && defined(PEGASUS_ZOS_SECURITY)
       startupCheckBPXServer(true);
       startupCheckProfileCIMSERVclassWBEM();
       startupEnableMSC();
   #endif
   
       // Bug 2148 - Here is the order of operations for determining the server HTTP and HTTPS ports.
       // 1) If the user explicitly specified a port, use it.
       // 2) If the user did not specify a port, get the port from the services file.
       // 3) If no value is specified in the services file, use the IANA WBEM default port.
       // Note that 2 and 3 are done within the System::lookupPort method
       // An empty string from the ConfigManager implies that the user did not specify a port.
   
       Uint32 portNumberHttps=0;
       Uint32 portNumberHttp=0;
       Uint32 portNumberExportHttps=0;
   
       if (enableHttpsConnection)
       {
           String httpsPort = configManager->getCurrentValue("httpsPort");
           if (httpsPort == String::EMPTY)
           {
         //         //
         // Check to see if we should Pegasus as a daemon              // Look up the WBEM-HTTPS port number
         //         //
               portNumberHttps = System::lookupPort(WBEM_HTTPS_SERVICE_NAME, WBEM_DEFAULT_HTTPS_PORT);
  
         if (String::equal(configManager->getCurrentValue("daemon"), "true"))          } else
         {         {
             daemonOption = true;  
         }  
   
         //         //
         // Check the log trace options and set global variable              // user-specified
         //         //
               CString portString = httpsPort.getCString();
         if (String::equal(configManager->getCurrentValue("logtrace"), "true"))              char* end = 0;
               portNumberHttps = strtol(portString, &end, 10);
               if(!(end != 0 && *end == '\0'))
         {         {
             pegasusIOLog = true;                  InvalidPropertyValue e("httpsPort", httpsPort);
                   Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                                 "src.Server.cimserver.SERVER_NOT_STARTED",
                                 "cimserver not started:  $0", e.getMessage());
                   MessageLoaderParms parms("src.Server.cimserver.SERVER_NOT_STARTED",
                                            "cimserver not started: $0", e.getMessage());
                   PEGASUS_STD(cerr) << argv[0] << ": " << MessageLoader::getMessage(parms)
                                     << PEGASUS_STD(endl);
                   exit(1);
               }
           }
         }         }
  
         // Get the log file directory definition.      if (enableHttpConnection)
         // We put String into Cstring because      {
         // Directory functions only handle Cstring.          String httpPort = configManager->getCurrentValue("httpPort");
         // ATTN-KS: create String based directory functions.          if (httpPort == String::EMPTY)
           {
         logsDirectory = configManager->getCurrentValue("logdir");  
         logsDirectory =  
             ConfigManager::getHomedPath(configManager->getCurrentValue("logdir"));  
   
         // Set up the Logger. This does not open the logs  
         // Might be more logical to clean before set.  
         // ATTN: Need tool to completely disable logging.  
   
         Logger::setHomeDirectory(logsDirectory);  
   
         //         //
         // Check to see if we need to shutdown CIMOM              // Look up the WBEM-HTTP port number
         //         //
         if (shutdownOption)              portNumberHttp = System::lookupPort(WBEM_HTTP_SERVICE_NAME, WBEM_DEFAULT_HTTP_PORT);
   
           } else
         {         {
             //             //
             // if timeout was specified, validate the timeout value              // user-specified
             //             //
             if (timeoutOption)              CString portString = httpPort.getCString();
             {              char* end = 0;
                 Boolean valid = configManager->validatePropertyValue(              portNumberHttp = strtol(portString, &end, 10);
                                              PROPERTY_TIMEOUT,              if(!(end != 0 && *end == '\0'))
                                              timeoutStr);  
                 if (!valid)  
                 {                 {
                     cout << "Invalid timeout value specified: " << timeoutValue;                  InvalidPropertyValue e("httpPort", httpPort);
                     cout << endl;                  Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
                                 "src.Server.cimserver.SERVER_NOT_STARTED",
                                 "cimserver not started:  $0", e.getMessage());
                   MessageLoaderParms parms("src.Server.cimserver.SERVER_NOT_STARTED",
                                                "cimserver not started: $0", e.getMessage());
                   PEGASUS_STD(cerr) << argv[0] << ": " << MessageLoader::getMessage(parms)
                                     << PEGASUS_STD(endl);
                     exit(1);                     exit(1);
                 }                 }
             }             }
       }
   #if defined(PEGASUS_DEBUG)
       // Put out startup up message.
       cout << _cimServerProcess->getProductName() << " " << _cimServerProcess->getCompleteVersion() << endl;
       //l10n
       //cout << "Built " << __DATE__ << " " << __TIME__ << endl;
       //cout <<"Starting..."
       MessageLoaderParms parms("src.Server.cimserver.STARTUP_MESSAGE",
                                "Built $0 $1\nStarting...",
                                __DATE__,
                                __TIME__);
   #endif
  
             shutdownCIMOM(timeoutValue);  //l10n
   // reset message loading to NON-process locale
   MessageLoader::_useProcessLocale = false;
   //l10n
  
             cout << "Pegasus CIM Server stopped." << endl;      // Get the parent's PID before forking
             exit(0);      _serverRunStatus.setParentPid(System::getPID());
   
   // Do not fork when using privilege separation (executor will daemonize itself
   // later).
       if (daemonOption)
       {
           if(-1 == _cimServerProcess->cimserver_fork())
               return(-1);
           else
               return(0);
         }         }
  
         //  // l10n
         // Get the port numbers      // Now we are after the fork...
         //      // Create a dummy Thread object that can be used to store the
       // AcceptLanguageList 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,
       dummyInitialThread = new Thread(dummyThreadFunc, NULL, false);
       Thread::setCurrent(dummyInitialThread);
       AcceptLanguageList default_al;
       try{
            default_al = LanguageParser::getDefaultAcceptLanguages();
            Thread::setLanguages(new AcceptLanguageList(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());
       }
  
         httpPort = configManager->getCurrentValue("httpPort");  #ifndef PEGASUS_OS_TYPE_WINDOWS
       umask(S_IRWXG|S_IRWXO);
   #endif
  
         httpsPort = configManager->getCurrentValue("httpsPort");  
  
         // Leave this in until people get familiar with the logs.  #if defined(PEGASUS_OS_TYPE_UNIX)
         cout << "Logs Directory = " << logsDirectory << endl;    //
     // CRITICAL SECTION BEGIN
     //
     // This is the beginning of the critical section regarding the
     // access to pidfile (file to indicate that the cimserver has started).
     // Sometimes, when 2 or more cimserver processes are started at the same
     // time, they can't detect the concurrent process execution because the
     // logic fails when pidfile is accessed concurrently.
   
     FILE *startupLockFile;
  
         if (String::equal(configManager->getCurrentValue("cleanlogs"), "true"))    if ((startupLockFile = fopen(ConfigManager::getHomedPath(
             CIMSERVER_LOCK_FILE).getCString(), "w")) != 0)
         {         {
             Logger::clean(logsDirectory);;        lockf(fileno(startupLockFile), F_LOCK, 0);
         }         }
   #endif
  
         if (String::equal(configManager->getCurrentValue("slp"), "true"))  #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU) \
   || defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM) || defined(PEGASUS_OS_AIX) \
   || defined(PEGASUS_OS_SOLARIS) || defined (PEGASUS_OS_VMS)
   
       //
       // 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 (_serverRunStatus.isServerRunning())
         {         {
             useSLP =  true;          MessageLoaderParms parms(
         }              "src.Server.cimserver.UNABLE_TO_START_SERVER_ALREADY_RUNNING",
               "Unable to start CIMServer. CIMServer is already running.");
           PEGASUS_STD(cerr) << MessageLoader::getMessage(parms) <<
               PEGASUS_STD(endl);
           Logger::put(Logger::ERROR_LOG,System::CIMSERVER,Logger::INFORMATION,
               MessageLoader::getMessage(parms));
  
         if (String::equal(configManager->getCurrentValue("SSL"), "true"))          //
           // notify parent process (if there is a parent process) to terminate
           //
           if (daemonOption)
         {         {
             useSSL =  true;              _cimServerProcess->notify_parent(1);
         }  
     }     }
     catch (UnrecognizedConfigProperty e)  
     {          return 1;
         cout << "Error: " << e.getMessage() << endl;  
     }     }
  
     Uint32 portNumber;  #endif
  
     char address[32];      // try loop to bind the address, and run the server
       try
       {
           _monitor = new Monitor();
           _cimServer = new CIMServer(_monitor);
  
     if (useSSL)          if (enableHttpConnection)
     {     {
         char* p = httpsPort.allocateCString();              _cimServer->addAcceptor(false, portNumberHttp, false);
         char* end = 0;  
         Uint32 port = strtol(p, &end, 10);  
         assert(end != 0 && *end == '\0');  
         delete [] p;  
  
         //              Logger::put_l(
         // Look up the WBEM-HTTPS port number                  Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
         //                  "src.Server.cimserver.LISTENING_ON_HTTP_PORT",
         portNumber = System::lookupPort(WBEM_HTTPS_SERVICE_NAME, port);                  "Listening on HTTP port $0.", portNumberHttp);
         sprintf(address, "%u", portNumber);  
     }     }
     else  
           if (enableHttpsConnection)
     {     {
         char* p = httpPort.allocateCString();              _cimServer->addAcceptor(false, portNumberHttps, true);
         char* end = 0;  
         Uint32 port = strtol(p, &end, 10);  
         assert(end != 0 && *end == '\0');  
         delete [] p;  
  
         //              Logger::put_l(
         // Look up the WBEM-HTTP port number                  Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
         //                  "src.Server.cimserver.LISTENING_ON_HTTPS_PORT",
         portNumber = System::lookupPort(WBEM_HTTP_SERVICE_NAME, port);                  "Listening on HTTPS port $0.", portNumberHttps);
         sprintf(address, "%u", portNumber);  
     }     }
  
     // Put out startup up message.  #ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET
     cout << PEGASUS_NAME << PEGASUS_VERSION <<          _cimServer->addAcceptor(true, 0, false);
          " on port " << address << endl;  
     cout << "Built " << __DATE__ << " " << __TIME__ << endl;  
     cout <<"Starting..."  
          << (pegasusIOLog ? " Tracing to Log ": " ")  
          << (useSLP ? " SLP reg. " : " No SLP ")  
          << (useSSL ? " Use SSL " : " No SSL ")  
         << endl;  
  
     // do we need to run as a daemon ?          Logger::put_l(
     if (daemonOption)              Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,
               "src.Server.cimserver.LISTENING_ON_LOCAL",
               "Listening on local connection socket.");
   #endif
   
   #if defined(PEGASUS_DEBUG)
           if (enableHttpConnection)
     {     {
         if(-1 == cimserver_fork())              MessageLoaderParms parms(
           exit(-1);                  "src.Server.cimserver.LISTENING_ON_HTTP_PORT",
     }                  "Listening on HTTP port $0.", portNumberHttp);
               cout << MessageLoader::getMessage(parms) << endl;
           }
           if (enableHttpsConnection)
           {
               MessageLoaderParms parms(
                   "src.Server.cimserver.LISTENING_ON_HTTPS_PORT",
                   "Listening on HTTPS port $0.", portNumberHttps);
               cout << MessageLoader::getMessage(parms) << endl;
           }
   
   # ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET
           MessageLoaderParms parms(
               "src.Server.cimserver.LISTENING_ON_LOCAL",
               "Listening on local connection socket.");
           cout << MessageLoader::getMessage(parms) << endl;
   # endif
   #endif
  
     // Put server starting message to the logger          _cimServer->bind();
     Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::INFORMATION,  
         "Starting $0 version $1 on port $2 $3 $4 $5",  
                 PEGASUS_NAME,  
                 PEGASUS_VERSION,  
                 address,  
                 (useSLP ? " SLP on " : " SLP off "),  
                 (useSSL ? " Use SSL " : " No SSL "));  
  
     // try loop to bind the address, and run the server          // notify parent process (if there is a parent process) to terminate
     try          // so user knows that there is cimserver ready to serve CIM requests.
           if (daemonOption)
     {     {
 #if !defined(PEGASUS_OS_ZOS) && ! defined(PEGASUS_OS_HPUX)  #if defined(PEGASUS_ENABLE_PRIVILEGE_SEPARATION)
         slp_client *discovery = new slp_client() ;;              Executor::daemonizeExecutor();
         String serviceURL;  
         serviceURL.assign("service:cim.pegasus://");  
         String host_name = slp_get_host_name();  
         serviceURL += host_name;  
         serviceURL += ":";  
         serviceURL += address;  
         char *url = serviceURL.allocateCString();  
         //      free(host_name);  
 #endif  
   
         Monitor monitor;  
         CIMServer server(&monitor, useSSL);  
   
         // bind throws an exception if the bind fails  
 #ifdef PEGASUS_LOCAL_DOMAIN_SOCKET  
         cout << "Binding to domain socket" << endl;  
 #else #else
         cout << "Binding to " << address << endl;              _cimServerProcess->notify_parent(0);
 #endif #endif
           }
  
         server.bind(portNumber);  #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_OS_LINUX) || \
       defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM) || defined(PEGASUS_OS_AIX) || \
       defined(PEGASUS_OS_SOLARIS) || defined(PEGASUS_OS_VMS)
           //
           // create a file to indicate that the cimserver has started and
           // save the process id of the cimserver process in the file
           //
           _serverRunStatus.setServerRunning();
   #endif
  
         time_t last = 0;  #if defined(PEGASUS_DEBUG)
       cout << "Started. " << endl;
   #endif
  
 #if defined(PEGASUS_OS_HPUX)  #if defined(PEGASUS_OS_TYPE_UNIX)
         //  
         // create a file to indicate that the cimserver has started  
         //         //
         fstream fs;      // CRITICAL SECTION END
         ArrayDestroyer<char> p(CIMSERVERSTART_FILE.allocateCString());  
         fs.open(p.getPointer(), ios::in | ios::out);  
         if (!fs)  
         {  
             //             //
             // failed to create the file, write an entry to the log file      // Here is the unlock of file 'lock_file'. It closes the
             // and proceed      // the critical section that guarantees the non concurrent access to
       // pid file (file to indicate that the cimserver has started).
             //             //
             //Logger::put(Logger::STANDARD_LOG, "CIMServer",  
             //    Logger::INFORMATION,      if (startupLockFile)
             //    "Failed to open the $0 file needed by cimserverd.",  
             //    CIMSERVERSTART_FILE);  
         }  
         else  
         {         {
             fs.close();         lockf(fileno(startupLockFile), F_ULOCK, 0);
          fclose(startupLockFile);
         }         }
 #endif #endif
         cout << "Started. " << endl;  
  
         // Put server started message to the logger         // Put server started message to the logger
         Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::INFORMATION,          Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER,
             "$0 started.", PEGASUS_NAME);              Logger::INFORMATION,
               "src.Server.cimserver.STARTED_VERSION",
               "Started $0 version $1.",
               _cimServerProcess->getProductName(),
               _cimServerProcess->getCompleteVersion());
   
   #if defined(PEGASUS_OS_TYPE_UNIX) && !defined(PEGASUS_OS_ZOS)
           if (daemonOption && !debugOutputOption)
           {
               // Direct standard input, output, and error to /dev/null,
               // since we are running as a daemon.
               close(0);
               open("/dev/null", O_RDONLY);
               close(1);
               open("/dev/null", O_RDWR);
               close(2);
               open("/dev/null", O_RDWR);
           }
   #endif
   
   #if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)
   
           // ARM is a z/OS internal restart facility.
           // This is a z/OS specific change.
   
           // Instatiating the automatic restart manager for zOS
           ARM_zOS automaticRestartManager;
   
           // register to zOS ARM
           automaticRestartManager.Register();
   
   #endif
  
         //         //
         // Loop to call CIMServer's runForever() method until CIMServer         // Loop to call CIMServer's runForever() method until CIMServer
         // has been shutdown         // has been shutdown
         //         //
         while( !server.terminated() )      while( !_cimServer->terminated() )
         {  
 #if !defined(PEGASUS_OS_ZOS) && ! defined(PEGASUS_OS_HPUX)  
           if(useSLP  )  
           {  
             if(  (time(NULL) - last ) > 60 )  
             {             {
               if( discovery != NULL && url != NULL )  
                 discovery->srv_reg_all(url,  
                                        "(namespace=root/cimv2)",  
                                        "service:cim.pegasus",  
                                        "DEFAULT",  
                                        70) ;  
               time(&last);  
             }  
  
             discovery->service_listener();        _cimServer->runForever();
           }  
 #endif  
           server.runForever();  
         }         }
  
         //         //
         // normal termination         // normal termination
         //         //
         // Put server shutdown message to the logger  #if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)
         Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::INFORMATION,  
             "$0 stopped.", PEGASUS_NAME);  
  
 #if defined(PEGASUS_OS_HPUX)          // ARM is a z/OS internal restart facility.
           // This is a z/OS specific change.
   
           // register to zOS ARM
           automaticRestartManager.DeRegister();
   
   #endif
   
           // Put server shutdown message to the logger
           Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER,
               Logger::INFORMATION, "src.Server.cimserver.STOPPED",
               "$0 stopped.", _cimServerProcess->getProductName());
   
   #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_OS_LINUX) \
   || defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM) || defined(PEGASUS_OS_AIX) \
   || defined(PEGASUS_OS_SOLARIS) || defined(PEGASUS_OS_VMS)
         //         //
         // close the file at startup time to indicate that the cimserver          //  Note: do not remove the PID file created at startup time, since
         // has terminated normally.          //  shutdown is not complete until the CIMServer destructor completes.
         //         //
         FileSystem::removeFile(CIMSERVERSTART_FILE);  
 #endif #endif
     }     }
       catch(BindFailedException& e)
       {
           Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
               "src.Server.cimserver.SERVER_NOT_STARTED",
               "cimserver not started:  $0", e.getMessage());
           MessageLoaderParms parms("src.Server.cimserver.SERVER_NOT_STARTED",
               "cimserver not started: $0", e.getMessage());
   
           cerr << MessageLoader::getMessage(parms) << endl;
   
       //
           // notify parent process (if there is a parent process) to terminate
           //
           if (daemonOption)
                   _cimServerProcess->notify_parent(1);
   
           deleteCIMServer();
           return 1;
       }
     catch(Exception& e)     catch(Exception& e)
     {     {
         Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::INFORMATION,      Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::WARNING,
             "$0 Abnormal Termination.", e.getMessage());              "src.Server.cimserver.ERROR",
               "Error: $0", e.getMessage());
       MessageLoaderParms parms("src.Server.cimserver.ERROR",
                                "Error: $0", e.getMessage());
       PEGASUS_STD(cerr) << MessageLoader::getMessage(parms) << PEGASUS_STD(endl);
           //
           // notify parent process (if there is a parent process) to terminate
           //
           if (daemonOption)
                   _cimServerProcess->notify_parent(1);
  
         PEGASUS_STD(cerr) << "Error: " << e.getMessage() << PEGASUS_STD(endl);          deleteCIMServer();
         return 1;         return 1;
     }     }
  
       deleteCIMServer();
     return 0;     return 0;
 } }


Legend:
Removed from v.1.54  
changed lines
  Added in v.1.200

No CVS admin address has been configured
Powered by
ViewCVS 0.9.2