pegasus/src/Server/cimserver.cpp - diff

Return to cimserver.cpp CVS log

Up to [Pegasus] / pegasus / src / Server

Diff for /pegasus/src/Server/cimserver.cpp between version 1.205 and 1.228

version 1.205, 2007/06/26 20:26:18

version 1.228, 2008/12/16 18:58:05

Line 1

//%2006////////////////////////////////////////////////////////////////////////

//%LICENSE////////////////////////////////////////////////////////////////

// Licensed to The Open Group (TOG) under one or more contributor license

// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.

// agreements. Refer to the OpenPegasusNOTICE.txt file distributed with

// this work for additional information regarding copyright ownership.

// IBM Corp.; EMC Corporation, The Open Group.

// Each contributor licenses this file to you under the OpenPegasus Open

// Source License; you may not use this file except in compliance with the

// IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.

// License.

// EMC Corporation; VERITAS Software Corporation; The Open Group.

// Permission is hereby granted, free of charge, to any person obtaining a

// copy of this software and associated documentation files (the "Software"),

// EMC Corporation; Symantec Corporation; The Open Group.

// to deal in the Software without restriction, including without limitation

// the rights to use, copy, modify, merge, publish, distribute, sublicense,

// Permission is hereby granted, free of charge, to any person obtaining a copy

// and/or sell copies of the Software, and to permit persons to whom the

// of this software and associated documentation files (the "Software"), to

// Software is furnished to do so, subject to the following conditions:

// deal in the Software without restriction, including without limitation the

// rights to use, copy, modify, merge, publish, distribute, sublicense, and/or

// The above copyright notice and this permission notice shall be included

// sell copies of the Software, and to permit persons to whom the Software is

// in all copies or substantial portions of the Software.

// furnished to do so, subject to the following conditions:

// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS

// THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN

// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

// ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED

// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.

// "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT

// IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY

// LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR

// CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,

// PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT

// TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE

// HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN

// SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

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

Line 43

// cimserver daemon=false

// The daemon config property has no effect on windows operation.

// The daemon config property has no effect on windows operation or when

// privilege separation is enabled.

// To shutdown pegasus, use the -s option:

Line 85

Line 84

#include <Pegasus/Common/FileSystem.h>

#include <Pegasus/Common/PegasusVersion.h>

#include <Pegasus/Common/Logger.h>

#include <Pegasus/Common/StringConversion.h>

#include <Pegasus/Common/System.h>

#include <Pegasus/Common/Tracer.h>

#include <Pegasus/Common/LanguageParser.h>

Line 95

#include <Service/ServerShutdownClient.h>

#include <Service/ServerRunStatus.h>

#if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)

#if defined(PEGASUS_OS_ZOS)

#include <Pegasus/Common/SetFileDescriptorToEBCDICEncoding.h>

#include <Service/ARM_zOS.h>

# ifdef PEGASUS_ZOS_SECURITY

// This include file will not be provided in the OpenGroup CVS for now.

Line 119

Line 120

#include <Pegasus/Common/Executor.h>

#ifdef PEGASUS_OS_PASE

# include <ILEWrapper/ILEUtilities2.h>

# include <ILEWrapper/qumemultiutil.h>

#endif

PEGASUS_USING_PEGASUS;

PEGASUS_USING_STD;

Line 131

Line 137

#define PEGASUS_SERVICE_DESCRIPTION "Pegasus CIM Object Manager Service";

#endif

#ifdef PEGASUS_OS_PASE

#include <as400_protos.h> //for _SETCCSID

#endif

class CIMServerProcess : public ServerProcess

{

public:

Line 428

Line 438

// Set Message loading to process locale

MessageLoader::_useProcessLocale = true;

#ifdef PEGASUS_OS_ZOS

// Direct standard input to /dev/null,

close(STDIN_FILENO);

open("/dev/null", O_RDONLY);

if ( setEBCDICEncoding(STDOUT_FILENO)==-1 ||

setEBCDICEncoding(STDERR_FILENO)==-1 )

{

PEG_TRACE_CSTRING(TRC_SERVER,Tracer::LEVEL1,

"Coud not set stdout or stderr to EBCDIC encoding.");

}

// Need to initialize timezone information in the

// initial processing thread (IPT)

tzset();

#endif

#if defined(PEGASUS_OS_AIX) && defined(PEGASUS_HAS_MESSAGES)

setlocale(LC_ALL, "");

#endif

Line 438

Line 464

# if defined(PEGASUS_OS_AIX) && defined(PEGASUS_USE_RELEASE_DIRS)

pegasusHome = AIX_RELEASE_PEGASUS_HOME;

# elif defined(PEGASUS_OS_PASE)

const char *tmp = getenv("PEGASUS_HOME");

pegasusHome = (tmp == 0) ? PASE_DEFAULT_PEGASUS_HOME : tmp;

# elif !defined(PEGASUS_USE_RELEASE_DIRS) || \

defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)

defined(PEGASUS_OS_ZOS)

const char* tmp = getenv("PEGASUS_HOME");

if (tmp)

Line 479

Line 508

for (int i = 1; i < argc; )

{

const char* arg = argv[i];

if (String::equal(arg,"--help"))

if (strcmp(arg, "--help") == 0)

{

PrintHelp(argv[0]);

Executor::daemonizeExecutor();

exit(0);

}

else if (String::equal(arg,"--version"))

else if (strcmp(arg, "--version") == 0)

{

cout << _cimServerProcess->getCompleteVersion() << endl;

Executor::daemonizeExecutor();

exit(0);

}

// Check for -option

Line 502

Line 533

strlen(option) == 1)

{

cout << _cimServerProcess->getCompleteVersion() << endl;

Executor::daemonizeExecutor();

exit(0);

}

Line 511

Line 543

(strlen(option) == 1))

{

PrintHelp(argv[0]);

Executor::daemonizeExecutor();

exit(0);

}

#if !defined(PEGASUS_USE_RELEASE_DIRS)

Line 529

Line 562

"Missing argument for option -$0",

opt);

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

exit(0);

exit(1);

}

memmove(&argv[i], &argv[i + 2], (argc-i-1) * sizeof(char*));

Line 573

Line 606

"Duplicate shutdown option specified.");

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

exit(0);

exit(1);

}

shutdownOption = true;

Line 628

Line 661

{

Boolean daemonOption = false;

#if defined (PEGASUS_OS_PASE) && !defined (PEGASUS_DEBUG)

// PASE have itself regular for checking privileged user

if (!System::isPrivilegedUser("*CURRENT "))

{

MessageLoaderParms parms(

"src.Server.cimserver.NO_AUTHORITY.PEGASUS_OS_PASE",

"The caller should be a privileged user,"

" or the server will not run.");

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

exit (1);

}

char jobName[11];

// this function only can be found in PASE environment

umeGetJobName(jobName, false);

if (strncmp("QUMECIMOM ", jobName, 10) != 0

&& strncmp("QUMEENDCIM", jobName, 10) != 0)

{

MessageLoaderParms parms(

"src.Server.cimserver.NOT_OFFICIAL_START.PEGASUS_OS_PASE",

"cimserver can not be started by user.\nServer will not run.");

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

exit (1);

}

// Direct standard input, output, and error to /dev/null,

// PASE run this job in background, any output in not allowed

freopen("/dev/null", "r", stdin);

freopen("/dev/null", "w", stdout);

freopen("/dev/null", "w", stderr);

#endif

// Get an instance of the Config Manager.

Line 651

Line 715

MessageLoader::setPegasusMsgHome(ConfigManager::getHomedPath(

ConfigManager::getInstance()->getCurrentValue("messageDir")));

// Check to see if we should start Pegasus as a daemon

daemonOption = ConfigManager::parseBooleanValue(

configManager->getCurrentValue("daemon"));

#if !defined(PEGASUS_USE_SYSLOGS)

String logsDirectory = ConfigManager::getHomedPath(

configManager->getCurrentValue("logdir"));

Line 666

Line 724

Logger::setHomeDirectory(logsDirectory);

#endif

#ifdef PEGASUS_OS_PASE

/* write job log to tell where pegasus log is.*/

if(logsDirectory.size() > 0)

// this function only can be found in PASE environment

logPegasusDir2joblog(logsDirectory.getCString());

else

logPegasusDir2joblog(".");

// set ccsid to unicode for entire job

// ccsid is globolization mechanism in PASE environment

if (_SETCCSID(1208) == -1)

{

MessageLoaderParms parms(

"src.Server.cimserver.SET_CCSID_ERROR.PEGASUS_OS_PASE",

"Failed to set CCSID, server will stop.");

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

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

parms);

exit (1);

}

char fullJobName[29];

umeGetJobName(fullJobName, true);

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

Logger::INFORMATION,

MessageLoaderParms(

"src.Server.cimserver.SERVER_JOB_NAME.PEGASUS_OS_PASE",

"CIM Server's Job Name is: $0", fullJobName));

#endif

#ifdef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET

// Make sure at least one connection is enabled

Boolean enableHttpConnection = ConfigManager::parseBooleanValue(

configManager->getCurrentValue("enableHttpConnection"));

Boolean enableHttpsConnection = ConfigManager::parseBooleanValue(

configManager->getCurrentValue("enableHttpsConnection"));

if (!enableHttpConnection && !enableHttpsConnection)

{

MessageLoaderParms parms(

"src.Server.cimserver.HTTP_NOT_ENABLED_SERVER_NOT_STARTING",

"Neither HTTP nor HTTPS connection is enabled."

" CIMServer will not be started.");

Logger::put_l(

Logger::STANDARD_LOG, System::CIMSERVER, Logger::WARNING,

parms);

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

return 1;

}

#endif

// Check to see if we should start Pegasus as a daemon

daemonOption = ConfigManager::parseBooleanValue(

configManager->getCurrentValue("daemon"));

if ((Executor::detectExecutor() == 0) && (daemonOption == false))

{

MessageLoaderParms parms(

"src.Server.cimserver.PRIVSEP_REQUIRES_DAEMON",

"Warning: The configuration setting daemon=false is ignored "

"with privilege separation enabled.");

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

daemonOption = true;

}

// Check to see if we need to shutdown CIMOM

Line 675

Line 802

configManager->getCurrentValue("shutdownTimeout");

Uint32 timeoutValue =

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

#ifdef PEGASUS_SLP_REG_TIMEOUT

// To deregister Pegasus with SLP

unregisterPegasusFromSLP();

#endif

ServerShutdownClient serverShutdownClient(&_serverRunStatus);

serverShutdownClient.shutdown(timeoutValue);

Line 702

Line 825

{

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

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

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

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

MessageLoader::getMessage(parms));

parms);

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

return 1;

}

#if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM) && defined(PEGASUS_ZOS_SECURITY)

#if defined(PEGASUS_OS_ZOS) && defined(PEGASUS_ZOS_SECURITY)

startupCheckBPXServer(true);

startupCheckProfileCIMSERVclassWBEM();

startupEnableMSC();

Line 744

Line 867

// 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(LanguageParser::getDefaultAcceptLanguages());

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

}

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

"AcceptLanguage format."));

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

e.getMessage());

}

Line 797

Line 919

MessageLoaderParms parms(

"src.Server.cimserver.UNABLE_TO_START_SERVER_ALREADY_RUNNING",

"Unable to start CIMServer. CIMServer is already running.");

Logger::put(

Logger::put_l(

Logger::ERROR_LOG, System::CIMSERVER, Logger::INFORMATION,

MessageLoader::getMessage(parms));

parms);

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

if (daemonOption)

Line 837

Line 959

}

#endif

Boolean addIP6Acceptor = false;

Boolean addIP4Acceptor = false;

#ifdef PEGASUS_OS_TYPE_WINDOWS

addIP4Acceptor = true;

#endif

#ifdef PEGASUS_ENABLE_IPV6

// If IPv6 stack is disabled swicth to IPv4 stack.

if (System::isIPv6StackActive())

{

addIP6Acceptor = true;

}

else

{

MessageLoaderParms parms(

"src.Server.cimserver.IPV6_STACK_NOT_ACTIVE",

"IPv6 stack is not active, using IPv4 socket.");

Logger::put_l(

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

parms);

#if defined(PEGASUS_DEBUG)

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

#endif

}

#endif

if (!addIP6Acceptor)

{

addIP4Acceptor = true;

}

// The server HTTP and HTTPS ports are determined via this algorithm:

// 1) If the user explicitly specified a port, use it.

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

Line 873

Line 1026

}

#ifdef PEGASUS_ENABLE_IPV6

if (addIP6Acceptor)

{

_cimServer->addAcceptor(HTTPAcceptor::IPV6_CONNECTION,

portNumberHttp, false);

#endif

}

if (addIP4Acceptor)

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

{

_cimServer->addAcceptor(HTTPAcceptor::IPV4_CONNECTION,

portNumberHttp, false);

#endif

}

// The port number is converted to a string to avoid the

// addition of localized characters (e.g., "5,988").

char scratchBuffer[22];

Uint32 n;

const char * portNumberHttpStr = Uint32ToString(

scratchBuffer, portNumberHttp, n);

MessageLoaderParms parms(

"src.Server.cimserver.LISTENING_ON_HTTP_PORT",

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

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

Logger::put(

Logger::put_l(

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

MessageLoader::getMessage(parms));

parms);

#if defined(PEGASUS_DEBUG)

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

#endif

Line 919

Line 1078

throw InvalidPropertyValue("httpsPort", httpsPort);

}

if (addIP6Acceptor)

#ifdef PEGASUS_ENABLE_IPV6

{

_cimServer->addAcceptor(HTTPAcceptor::IPV6_CONNECTION,

portNumberHttps, true);

#endif

}

if (addIP4Acceptor)

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

{

_cimServer->addAcceptor(HTTPAcceptor::IPV4_CONNECTION,

portNumberHttps, true);

#endif

}

// The port number is converted to a string to avoid the

// addition of localized characters (e.g., "5,989").

char scratchBuffer[22];

Uint32 n;

const char * portNumberHttpsStr = Uint32ToString(

scratchBuffer, portNumberHttps, n);

MessageLoaderParms parms(

"src.Server.cimserver.LISTENING_ON_HTTPS_PORT",

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

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

Logger::put(

Logger::put_l(

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

MessageLoader::getMessage(parms));

parms);

#if defined(PEGASUS_DEBUG)

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

#endif

Line 948

Line 1112

MessageLoaderParms parms(

"src.Server.cimserver.LISTENING_ON_LOCAL",

"Listening on local connection socket.");

Logger::put(

Logger::put_l(

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

MessageLoader::getMessage(parms));

parms);

# if defined(PEGASUS_DEBUG)

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

# endif

Line 963

Line 1127

// so user knows that there is cimserver ready to serve CIM requests.

if (daemonOption)

{

#if defined(PEGASUS_ENABLE_PRIVILEGE_SEPARATION)

Executor::daemonizeExecutor();

#else

_cimServerProcess->notify_parent(0);

#endif

}

#if defined(PEGASUS_DEBUG)

Line 977

Line 1137

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

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

close(STDIN_FILENO);

open("/dev/null", O_RDONLY);

close(1);

close(STDOUT_FILENO);

open("/dev/null", O_RDWR);

close(2);

close(STDERR_FILENO);

open("/dev/null", O_RDWR);

}

#endif

Line 1000

Line 1161

{

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

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

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

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

MessageLoader::getMessage(parms));

parms);

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

Line 1018

Line 1179

try

{

#if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)

#if defined(PEGASUS_OS_ZOS)

// ARM is a z/OS internal restart facility.

// This is a z/OS specific change.

Line 1031

Line 1192

#endif

#ifdef PEGASUS_ENABLE_SLP

_cimServer->startSLPProvider();

#endif

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

// has been shutdown

Line 1044

Line 1208

// normal termination

#if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)

#if defined(PEGASUS_OS_ZOS)

// ARM is a z/OS internal restart facility.

// This is a z/OS specific change.

Line 1055

Line 1219

#endif

// Put server shutdown message to the logger

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

Logger::put_l(

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

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

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

MessageLoaderParms(

"src.Server.cimserver.STOPPED",

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

}

catch (Exception& e)

{

Line 1065

Line 1231

"src.Server.cimserver.ERROR",

"Error: $0",

e.getMessage());

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

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

MessageLoader::getMessage(parms));

parms);

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

deleteCIMServer();

Legend:

Removed from v.1.205
changed lines
	Added in v.1.228

No CVS admin address has been configured