pegasus/src/Pegasus/ProviderManager2/Attic/ProviderManagerService.h - diff

Return to ProviderManagerService.h CVS log

Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / Attic

Diff for /pegasus/src/Pegasus/ProviderManager2/Attic/ProviderManagerService.h between version 1.13 and 1.38

version 1.13, 2004/03/31 15:13:11

version 1.38, 2006/08/08 17:47:13

Line 1

//%2003////////////////////////////////////////////////////////////////////////

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

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

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

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

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

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

// EMC Corporation; Symantec 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"), to

Line 34

Line 40

// (carolann_graves@hp.com)

// Mike Day, IBM (mdday@us.ibm.com)

// Adrian Schuur, IBM (schuur@de.ibm.com)

// Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com)

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

Line 41

Line 48

#define Pegasus_ProviderManagerService_h

#include <Pegasus/Common/Config.h>

#include <Pegasus/Common/Thread.h>

#include <Pegasus/Common/Array.h>

#include <Pegasus/Common/Pair.h>

#include <Pegasus/Common/MessageQueueService.h>

#include <Pegasus/Common/CIMMessage.h>

#include <Pegasus/Common/OperationContextInternal.h>

#include <Pegasus/Common/AutoPtr.h>

#include <Pegasus/Common/List.h>

#include <Pegasus/Common/Mutex.h>

#include <Pegasus/Repository/CIMRepository.h>

#include <Pegasus/Server/ProviderRegistrationManager/ProviderRegistrationManager.h>

#include <Pegasus/ProviderManager2/SafeQueue.h>

#include <Pegasus/ProviderManager2/ProviderManagerRouter.h>

#include <Pegasus/ProviderManager2/ProviderManager.h>

#include <Pegasus/ProviderManager2/Linkage.h>

PEGASUS_NAMESPACE_BEGIN

#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/ProviderManager2/ProviderManagerzOS_inline.h>

#endif

#define IDLE_LIMIT 100

PEGASUS_NAMESPACE_BEGIN

class ProviderRegistrationManager;

#define IDLE_LIMIT 300

class ProviderManager;

class PEGASUS_PPM_LINKAGE ProviderManagerService : public MessageQueueService

{

friend class CMPIProviderManager;

public:

static ProviderManagerService* providerManagerService;

ProviderManagerService(

ProviderRegistrationManager* providerRegistrationManager,

ProviderManagerService(void);

CIMRepository* repository,

ProviderManagerService(ProviderRegistrationManager * providerRegistrationManager,

ProviderManager* (*createDefaultProviderManagerCallback)());

CIMRepository * repository);

virtual ~ProviderManagerService();

void unloadIdleProviders();

static void indicationCallback(CIMProcessIndicationRequestMessage* request);

static void responseChunkCallback(

CIMRequestMessage* request, CIMResponseMessage* response);

/**

Callback function to be called upon detection of failure of a

provider module.

static void providerModuleFailureCallback (const String & moduleName,

const String & userName, Uint16);

private:

ProviderManagerService();

virtual ~ProviderManagerService(void);

// temp

void unload_idle_providers(void);

protected:

virtual Boolean messageOK(const Message * message);

virtual void handleEnqueue(void);

virtual void handleEnqueue();

virtual void handleEnqueue(Message * message);

virtual void _handle_async_request(AsyncRequest * request);

static CIMRepository* _repository;

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL handleCimOperation(

void* arg) ;

private:

void handleCimRequest(AsyncOpNode* op, Message* message);

//static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL handleServiceOperation(void * arg) throw();

//void handleStartService() thorw();

Message* _processMessage(CIMRequestMessage* request);

//void handleStopService() thorw();

//void handlePauseService() thorw();

//void handleResumeService() thorw();

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL handleCimOperation(void * arg) throw();

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL

_unloadIdleProvidersHandler(void* arg) throw();

ProviderManager *locateProviderManager(const Message *m, String &itf);

void _updateProviderModuleStatus(

void handleCimRequest(AsyncOpNode *op, const Message * message);

CIMInstance& providerModule,

const Array<Uint16>& removeStatus,

const Array<Uint16>& appendStatus);

private:

static ProviderManagerService* providerManagerService;

SafeQueue<AsyncOpNode *> _incomingQueue;

SafeQueue<AsyncOpNode *> _outgoingQueue;

private:

CIMRepository* _repository;

//Array<Pair<ProviderManager *, ProviderManagerModule> > _providerManagers;

List<AsyncOpNode,Mutex> _incomingQueue;

List<AsyncOpNode,Mutex> _outgoingQueue;

Boolean _forceProviderProcesses;

ProviderManagerRouter* _basicProviderManagerRouter;

ProviderManagerRouter* _oopProviderManagerRouter;

ProviderRegistrationManager* _providerRegistrationManager;

static Uint32 _indicationServiceQueueId;

/**

Indicates the number of threads currently attempting to unload idle

providers. This value is used to prevent multiple threads from

unloading idle providers at the same time.

AtomicInt _unloadIdleProvidersBusy;

};

// Auto class to encapsulate enabling and disabling

// of the pthread_security on z/OS

// For all other platforms this should be an empty class

// Targets: avoid ifdefs and keep code readable(clean)

#ifndef PEGASUS_ZOS_THREADLEVEL_SECURITY

// not z/OS == empty class

class PEGASUS_PPM_LINKAGE AutoPThreadSecurity

{

public:

AutoPThreadSecurity(const OperationContext& context) {};

};

#else

class PEGASUS_PPM_LINKAGE AutoPThreadSecurity

{

public:

AutoPThreadSecurity(const OperationContext& context)

{

int err_num=enablePThreadSecurity(context);

if (err_num!=0)

{

// need a new CIMException for this

throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));

}

};

~AutoPThreadSecurity()

{

disablePThreadSecurity();

};

#endif

PEGASUS_NAMESPACE_END

Legend:

Removed from v.1.13
changed lines
	Added in v.1.38

No CVS admin address has been configured