version 1.31.2.2, 2006/05/23 18:23:40
|
version 1.36.2.1, 2006/07/27 23:12:06
|
|
|
#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(); |
| |
|
|
| |
virtual void _handle_async_request(AsyncRequest* request); | virtual void _handle_async_request(AsyncRequest* request); |
| |
static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL handleCimOperation( |
static ThreadReturnType PEGASUS_THREAD_CDECL handleCimOperation( |
void* arg) ; | void* arg) ; |
| |
void handleCimRequest(AsyncOpNode* op, Message* message); | void handleCimRequest(AsyncOpNode* op, Message* message); |
| |
Message* _processMessage(CIMRequestMessage* request); | Message* _processMessage(CIMRequestMessage* request); |
| |
static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL |
static ThreadReturnType PEGASUS_THREAD_CDECL |
_unloadIdleProvidersHandler(void* arg) throw(); | _unloadIdleProvidersHandler(void* arg) throw(); |
| |
void _updateProviderModuleStatus( | void _updateProviderModuleStatus( |
|
|
| |
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; |