pegasus/src/WMIMapper/WMIServer/cimserver.cpp - diff

Return to cimserver.cpp CVS log

Up to [Pegasus] / pegasus / src / WMIMapper / WMIServer

Diff for /pegasus/src/WMIMapper/WMIServer/cimserver.cpp between version 1.31 and 1.39

version 1.31, 2007/06/05 10:25:03

version 1.39, 2008/08/14 17:30:47

Line 27

// 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.

//==============================================================================

//=============================================================================

//%/////////////////////////////////////////////////////////////////////////////

//%////////////////////////////////////////////////////////////////////////////

//////////////////////////////////////////////////////////////////////

Line 85

#include <Pegasus/Common/PegasusAssert.h>

#include <fstream>

#include <Pegasus/Common/FileSystem.h>

#include <Pegasus/Common/Monitor.h>

#include <Pegasus/Common/PegasusVersion.h>

#include <Pegasus/Common/Logger.h>

#include <Pegasus/Common/System.h>

Line 152

Line 151

return PEGASUS_PROCESS_NAME;

}

//defined in Constants.h

int cimserver_run(

virtual const char* getPIDFileName() const

int argc,

{

char** argv,

return PEGASUS_CIMSERVER_START_FILE;

Boolean shutdownOption,

}

Boolean debugOutputOption);

int cimserver_run(int argc, char** argv, bool shutdownOption);

void cimserver_stop(void);

};

Line 167

Line 164

PEGASUS_PROCESS_NAME, PEGASUS_CIMSERVER_START_FILE);

AutoPtr<CIMServerProcess> _cimServerProcess(new CIMServerProcess());

static CIMServer* _cimServer = 0;

static Monitor* _monitor = 0;

// The command name.

Line 198

Line 194

static const char OPTION_BINDVERBOSE = 'X';

#endif

static const String PROPERTY_TIMEOUT = "shutdownTimeout";

ConfigManager* configManager;

/** GetOptions function - This function defines the Options Table

and sets up the options from that table using the config manager.

Line 235

Line 227

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 Service\n");

usage.append (" -install [name] - installs pegasus as a Windows "

usage.append (" [name] is optional and overrides the\n");

"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 Service\n");

usage.append (" -remove [name] - removes pegasus as a Windows "

usage.append (" [name] is optional and overrides the\n");

"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 Service\n");

usage.append (" -start [name] - starts pegasus as a Windows "

usage.append (" [name] is optional and overrides the\n");

"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 Service\n");

usage.append (" -stop [name] - stops pegasus as a Windows "

usage.append (" [name] is optional and overrides the\n");

"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");

usage.append (" - sets CIM Server configuration "

"property\n");

cout << endl;

cout << _cimServerProcess->getProductName() << " " << _cimServerProcess->getVersion() << endl;

cout << _cimServerProcess->getProductName() << " " <<

_cimServerProcess->getVersion() << endl;

cout << 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);

MessageLoaderParms parms(

"src.Server.cimserver.MENU.HPUXLINUXIA64GNU", usage);

#else

MessageLoaderParms parms("src.Server.cimserver.MENU.STANDARD", usage);

#endif

cout << MessageLoader::getMessage(parms) << endl;

}

//This needs to be called at various points in the code depending on the platform and error conditions.

// This needs to be called at various points in the code depending on the

//We need to delete the _cimServer reference on exit in order for the destructors to get called.

// 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)

{

delete _cimServer;

_cimServer = 0;

}

if (_monitor)

{

delete _monitor;

}

// l10n

// Dummy function for the Thread object associated with the initial thread.

Line 301

Line 297

{

String pegasusHome;

Boolean shutdownOption = false;

Boolean debugOutputOption = false;

//l10n

// Set Message loading to process locale

Line 384

Line 381

}

else

{

//l10n

//cout << "Missing argument for option -" << option << endl;

String opt(option);

MessageLoaderParms parms("src.Server.cimserver.MISSING_ARGUMENT",

MessageLoaderParms parms(

"src.Server.cimserver.MISSING_ARGUMENT",

"Missing argument for option -$0",

opt);

cout << MessageLoader::getMessage(parms) << endl;

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;

}

#endif

Line 406

Line 403

(strlen(option) == 1))

{

System::bindVerbose = true;

//l10n

//cout << "Unsupported debug option, BIND_VERBOSE, enabled."

MessageLoaderParms parms(

//<< endl;

"src.Server.cimserver.UNSUPPORTED_DEBUG_OPTION",

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

Line 428

Line 424

if (shutdownOption)

{

//l10n

MessageLoaderParms parms(

//cout << "Duplicate shutdown option specified." << endl;

"src.Server.cimserver.DUPLICATE_SHUTDOWN_OPTION",

MessageLoaderParms parms("src.Server.cimserver.DUPLICATE_SHUTDOWN_OPTION",

"Duplicate shutdown option specified.");

cout << MessageLoader::getMessage(parms) << endl;

Line 459

Line 454

// Do the plaform specific run

return _cimServerProcess->platform_run( argc, argv, shutdownOption );

return _cimServerProcess->platform_run(

argc, argv, shutdownOption, debugOutputOption);

}

void CIMServerProcess::cimserver_stop()

Line 480

Line 476

// specific runs may need to deal with bettter (instead of exit(), etc).

int CIMServerProcess::cimserver_run( int argc, char** argv, Boolean shutdownOption )

int CIMServerProcess::cimserver_run(

int argc,

char** argv,

Boolean shutdownOption,

Boolean debugOutputOption)

{

String logsDirectory;

Boolean daemonOption = false;

Line 488

// Get an instance of the Config Manager.

configManager = ConfigManager::getInstance();

ConfigManager* configManager = ConfigManager::getInstance();

configManager->useConfigFiles = true;

Line 502

}

catch (Exception& 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());

PEGASUS_STD(cerr) << argv[0] << ": " << MessageLoader::getMessage(parms)

Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,

<< PEGASUS_STD(endl);

parms);

PEGASUS_STD(cerr) << argv[0] << ": " <<

MessageLoader::getMessage(parms) << PEGASUS_STD(endl);

return(1);

}

Line 531

Line 530

#ifdef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET

if (!enableHttpConnection && !enableHttpsConnection)

{

//l10n

MessageLoaderParms parms(

//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.");

"Neither HTTP nor HTTPS connection is enabled.");

//cerr << "Neither HTTP nor HTTPS connection is enabled. "

Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::WARNING,

//"CIMServer will not be started." << endl;

parms);

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);

return 1;

}

#endif

Line 574

Line 567

{

String configTimeout =

configManager->getCurrentValue("shutdownTimeout");

Uint32 timeoutValue = strtol(configTimeout.getCString(), (char **)0, 10);

Uint32 timeoutValue = strtol(

configTimeout.getCString(), (char **)0, 10);

ServerShutdownClient serverShutdownClient(&_serverRunStatus);

serverShutdownClient.shutdown(timeoutValue);

Line 604

Line 598

cout << MessageLoader::getMessage(parms) << endl;

}

// Bug 2148 - Here is the order of operations for determining the server HTTP and HTTPS ports.

// 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.

// 2) If the user did not specify a port, get the port from the

// 3) If no value is specified in the services file, use the IANA WBEM default port.

// 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.

// An empty string from the ConfigManager implies that the user did

// not specify a port.

Uint32 portNumberHttps=0;

Uint32 portNumberHttp=0;

Line 623

Line 621

// Look up the WBEM-HTTPS port number

portNumberHttps = System::lookupPort(WBEM_HTTPS_SERVICE_NAME, WBEM_DEFAULT_HTTPS_PORT);

portNumberHttps = System::lookupPort(WBEM_HTTPS_SERVICE_NAME,

WBEM_DEFAULT_HTTPS_PORT);

} else

{

Line 650

Line 649

// Look up the WBEM-HTTP port number

portNumberHttp = System::lookupPort(WBEM_HTTP_SERVICE_NAME, WBEM_DEFAULT_HTTP_PORT);

portNumberHttp = System::lookupPort(WBEM_HTTP_SERVICE_NAME,

WBEM_DEFAULT_HTTP_PORT);

} else

{

Line 671

#if defined(PEGASUS_DEBUG)

// Put out startup up message.

cout << _cimServerProcess->getProductName() << " " << _cimServerProcess->getVersion() << endl;

cout << _cimServerProcess->getProductName() << " " <<

//l10n

_cimServerProcess->getVersion() << endl;

//cout << "Built " << __DATE__ << " " << __TIME__ << endl;

//cout <<"Starting..."

MessageLoaderParms parms("src.Server.cimserver.STARTUP_MESSAGE",

"Built $0 $1\nStarting...",

__DATE__,

__TIME__);

#endif

//l10n

// reset message loading to NON-process locale

MessageLoader::_useProcessLocale = false;

//l10n

// Get the parent's PID before forking

_serverRunStatus.setParentPid(System::getPID());

Line 708

Line 700

// The run function for the dummy Thread should never be called,

Thread *dummyInitialThread = new Thread(dummyThreadFunc, NULL, false);

Thread::setCurrent(dummyInitialThread);

AcceptLanguageList default_al;

try

try{

{

default_al = LanguageParser::getDefaultAcceptLanguages();

Thread::setLanguages(LanguageParser::getDefaultAcceptLanguages());

Thread::setLanguages(new AcceptLanguageList(default_al));

}

}catch(InvalidAcceptLanguageHeader& e){

catch(InvalidAcceptLanguageHeader& e)

{

Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,

MessageLoaderParms(

"src.Server.cimserver.FAILED_TO_SET_PROCESS_LOCALE",

"Could not convert the system process locale into a valid AcceptLanguage format.");

"Could not convert the system process locale into "

"a valid AcceptLanguage format."));

Logger::put(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,

e.getMessage());

}

Line 754

Line 749

// try loop to bind the address, and run the server

try

{

_monitor = new Monitor();

_cimServer = new CIMServer();

_cimServer = new CIMServer(_monitor);

if (enableHttpConnection)

{

_cimServer->addAcceptor(false, portNumberHttp, false, false);

#ifdef PEGASUS_ENABLE_IPV6

_cimServer->addAcceptor(HTTPAcceptor::IPV6_CONNECTION,

portNumberHttp, false);

#endif

#if !defined (PEGASUS_ENABLE_IPV6) || defined (PEGASUS_OS_TYPE_WINDOWS)

_cimServer->addAcceptor(HTTPAcceptor::IPV4_CONNECTION,

portNumberHttp, false);

#endif

Logger::put_l(

Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,

MessageLoaderParms(

"src.Server.cimserver.LISTENING_ON_HTTP_PORT",

"Listening on HTTP port $0.", portNumberHttp);

"Listening on HTTP port $0.", portNumberHttp));

}

if (enableHttpsConnection)

{

_cimServer->addAcceptor(false, portNumberHttps, true, false);

#ifdef PEGASUS_ENABLE_IPV6

_cimServer->addAcceptor(HTTPAcceptor::IPV6_CONNECTION,

portNumberHttps, true);

#endif

#if !defined (PEGASUS_ENABLE_IPV6) || defined (PEGASUS_OS_TYPE_WINDOWS)

_cimServer->addAcceptor(HTTPAcceptor::IPV4_CONNECTION,

portNumberHttps, true);

#endif

Logger::put_l(

Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,

MessageLoaderParms(

"src.Server.cimserver.LISTENING_ON_HTTPS_PORT",

"Listening on HTTPS port $0.", portNumberHttps);

"Listening on HTTPS port $0.", portNumberHttps));

}

#ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET

_cimServer->addAcceptor(true, 0, false, false);

_cimServer->addAcceptor(HTTPAcceptor::LOCAL_CONNECTION, 0, false);

Logger::put_l(

Logger::STANDARD_LOG, System::CIMSERVER, Logger::INFORMATION,

MessageLoaderParms(

"src.Server.cimserver.LISTENING_ON_LOCAL",

"Listening on local connection socket.");

"Listening on local connection socket."));

#endif

#if defined(PEGASUS_DEBUG)

Line 811

Line 825

#endif

// bind throws an exception if the bind fails

try {

_cimServer->bind();

}

catch (const BindFailedException &e)

{

#ifdef PEGASUS_DEBUG

MessageLoaderParms parms("src.Server.cimserver.BIND_FAILED",

"Could not bind: $0.", e.getMessage());

cout << MessageLoader::getMessage(parms) << endl;

#endif

Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,

"src.Server.cimserver.BIND.FAILED",

"Could not bind: $0", e.getMessage());

deleteCIMServer();

return 1;

}

// 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)

Line 855

Line 854

// Put server started message to the logger

Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER,

Logger::INFORMATION,

MessageLoaderParms(

"src.Server.cimserver.STARTED_VERSION",

"Started $0 version $1.",

_cimServerProcess->getProductName(), _cimServerProcess->getVersion());

_cimServerProcess->getProductName(),

_cimServerProcess->getVersion()));

// Loop to call CIMServer's runForever() method until CIMServer

Line 876

Line 877

// Put server shutdown message to the logger

Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER,

Logger::INFORMATION, "src.Server.cimserver.STOPPED",

Logger::INFORMATION,

"$0 stopped.", _cimServerProcess->getProductName());

MessageLoaderParms(

"src.Server.cimserver.STOPPED",

#if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU) \

"$0 stopped.", _cimServerProcess->getProductName()));

|| defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM) || defined(PEGASUS_OS_AIX) \

|| defined(PEGASUS_OS_SOLARIS) || defined(PEGASUS_OS_VMS)

// close the file created at startup time to indicate that the

// cimserver has terminated normally.

FileSystem::removeFile(_cimServerProcess->getPIDFileName());

#endif

}

catch(Exception& e)

{

MessageLoaderParms parms("src.Server.cimserver.SERVER_NOT_STARTED",

//l10n

"cimserver not started: $0", e.getMessage());

//Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::WARNING,

Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,

//"Error: $0", e.getMessage());

parms);

Logger::put_l(Logger::STANDARD_LOG, System::CIMSERVER, Logger::WARNING,

cerr << MessageLoader::getMessage(parms) << endl;

"src.Server.cimserver.ERROR",

"Error: $0", e.getMessage());

//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);

// notify parent process (if there is a parent process) to terminate

Legend:

Removed from v.1.31
changed lines
	Added in v.1.39

No CVS admin address has been configured