|
version 1.68, 2008/11/05 05:24:34
|
version 1.69, 2008/11/12 06:04:45
|
|
|
|
| Uint32 getIncomingCount() {return _incoming.count(); } | Uint32 getIncomingCount() {return _incoming.count(); } |
| | |
| protected: | protected: |
| virtual void _shutdown_incoming_queue(); |
|
| virtual Boolean accept_async(AsyncOpNode* op); | virtual Boolean accept_async(AsyncOpNode* op); |
| virtual void handleEnqueue() = 0; | virtual void handleEnqueue() = 0; |
| virtual void handleEnqueue(Message *) = 0; | virtual void handleEnqueue(Message *) = 0; |
|
|
|
| virtual void _handle_async_callback(AsyncOpNode* operation); | virtual void _handle_async_callback(AsyncOpNode* operation); |
| virtual void _make_response(Message* req, Uint32 code); | virtual void _make_response(Message* req, Uint32 code); |
| | |
| virtual void handle_AsyncIoctl(AsyncIoctl* req); |
virtual void handle_AsyncIoClose(AsyncIoClose* req); |
| virtual void handle_CimServiceStart(CimServiceStart* req); | virtual void handle_CimServiceStart(CimServiceStart* req); |
| virtual void handle_CimServiceStop(CimServiceStop* req); | virtual void handle_CimServiceStop(CimServiceStop* req); |
| | |
|
|
|
| void* callback_ptr, | void* callback_ptr, |
| Uint32 flags); | Uint32 flags); |
| | |
| |
void _removeFromPollingList(MessageQueueService *service); |
| |
|
| static ThreadReturnType PEGASUS_THREAD_CDECL polling_routine(void *); | static ThreadReturnType PEGASUS_THREAD_CDECL polling_routine(void *); |
| | |
| AsyncQueue<AsyncOpNode> _incoming; | AsyncQueue<AsyncOpNode> _incoming; |
Return to
MessageQueueService.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common