version 1.13, 2002/03/25 21:48:01
|
version 1.14, 2002/04/01 23:47:41
|
|
|
virtual void _handle_async_request(AsyncRequest * request); | virtual void _handle_async_request(AsyncRequest * request); |
| |
protected: | protected: |
Pair<String, String> _lookupProviderForClass(const CIMObjectPath & objectPath); |
virtual Pair<String, String> _lookupProviderForClass(const CIMObjectPath & objectPath); |
| |
protected: | protected: |
static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL handleServiceOperation(void * arg) throw(); | static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL handleServiceOperation(void * arg) throw(); |
|
|
| |
void handleInvokeMethodRequest(const Message * message) throw(); | void handleInvokeMethodRequest(const Message * message) throw(); |
| |
void handleEnableIndicationRequest(const Message * message) throw(); |
|
void handleModifyIndicationRequest(const Message * message) throw(); |
|
void handleDisableIndicationRequest(const Message * message) throw(); |
|
|
|
void handleCreateSubscriptionRequest(const Message * message) throw(); | void handleCreateSubscriptionRequest(const Message * message) throw(); |
void handleModifySubscriptionRequest(const Message * message) throw(); | void handleModifySubscriptionRequest(const Message * message) throw(); |
void handleDeleteSubscriptionRequest(const Message * message) throw(); | void handleDeleteSubscriptionRequest(const Message * message) throw(); |
| |
protected: | protected: |
ThreadPool _threadPool; | ThreadPool _threadPool; |
Semaphore _threadSemaphore; |
|
| |
SafeQueue<Message *> _incomingQueue; | SafeQueue<Message *> _incomingQueue; |
//SafeQueue<Message *> _outgoingQueue; | //SafeQueue<Message *> _outgoingQueue; |
| |
ProviderRegistrationManager * _providerRegistrationManager; | ProviderRegistrationManager * _providerRegistrationManager; |
|
|
}; | }; |
| |
PEGASUS_NAMESPACE_END | PEGASUS_NAMESPACE_END |