version 1.30.10.2, 2006/03/07 18:45:57
|
version 1.36, 2006/07/11 18:39:35
|
|
|
#include <Pegasus/Common/CIMMessage.h> | #include <Pegasus/Common/CIMMessage.h> |
#include <Pegasus/Common/OperationContextInternal.h> | #include <Pegasus/Common/OperationContextInternal.h> |
#include <Pegasus/Common/AutoPtr.h> | #include <Pegasus/Common/AutoPtr.h> |
|
#include <Pegasus/Common/List.h> |
|
#include <Pegasus/Common/Mutex.h> |
#include <Pegasus/Repository/CIMRepository.h> | #include <Pegasus/Repository/CIMRepository.h> |
#include <Pegasus/Server/ProviderRegistrationManager/ProviderRegistrationManager.h> | #include <Pegasus/Server/ProviderRegistrationManager/ProviderRegistrationManager.h> |
| |
#include <Pegasus/ProviderManager2/SafeQueue.h> |
|
#include <Pegasus/ProviderManager2/ProviderManagerRouter.h> | #include <Pegasus/ProviderManager2/ProviderManagerRouter.h> |
| |
#include <Pegasus/ProviderManager2/Linkage.h> | #include <Pegasus/ProviderManager2/Linkage.h> |
|
|
public: | public: |
ProviderManagerService( | ProviderManagerService( |
ProviderRegistrationManager* providerRegistrationManager, | ProviderRegistrationManager* providerRegistrationManager, |
CIMRepository* repository); |
CIMRepository* repository, |
|
ProviderManager* (*createDefaultProviderManagerCallback)()); |
| |
virtual ~ProviderManagerService(); | virtual ~ProviderManagerService(); |
| |
|
|
static void responseChunkCallback( | static void responseChunkCallback( |
CIMRequestMessage* request, CIMResponseMessage* response); | 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: | private: |
ProviderManagerService(); | ProviderManagerService(); |
| |
|
|
| |
void _updateProviderModuleStatus( | void _updateProviderModuleStatus( |
CIMInstance& providerModule, | CIMInstance& providerModule, |
Uint16 fromStatus, |
const Array<Uint16>& removeStatus, |
Uint16 toStatus); |
const Array<Uint16>& appendStatus); |
| |
static ProviderManagerService* providerManagerService; | static ProviderManagerService* providerManagerService; |
| |
CIMRepository* _repository; | CIMRepository* _repository; |
| |
SafeQueue<AsyncOpNode *> _incomingQueue; |
List<AsyncOpNode,Mutex> _incomingQueue; |
SafeQueue<AsyncOpNode *> _outgoingQueue; |
List<AsyncOpNode,Mutex> _outgoingQueue; |
| |
ProviderManagerRouter* _basicProviderManagerRouter; | ProviderManagerRouter* _basicProviderManagerRouter; |
ProviderManagerRouter* _oopProviderManagerRouter; | ProviderManagerRouter* _oopProviderManagerRouter; |