|
version 1.57, 2006/09/13 21:05:37
|
version 1.58, 2006/10/03 18:16:03
|
|
|
|
| void *parameter); | void *parameter); |
| | |
| Boolean SendForget(Message *msg); | Boolean SendForget(Message *msg); |
| Boolean ForwardOp(AsyncOpNode *, Uint32 destination); |
|
| | |
| | |
| Boolean register_service(String name, Uint32 capabilities, Uint32 mask); | Boolean register_service(String name, Uint32 capabilities, Uint32 mask); |
|
|
|
| void return_op(AsyncOpNode *op); | void return_op(AsyncOpNode *op); |
| | |
| static ThreadPool *get_thread_pool(); | static ThreadPool *get_thread_pool(); |
| static void cleanupThreadPool(); |
|
| | |
| Uint32 _mask; | Uint32 _mask; |
| AtomicInt _die; | AtomicInt _die; |
|
|
|
| | |
| private: | private: |
| static ThreadReturnType PEGASUS_THREAD_CDECL polling_routine(void *); | static ThreadReturnType PEGASUS_THREAD_CDECL polling_routine(void *); |
| static ThreadReturnType PEGASUS_THREAD_CDECL kill_idle_threads(void *); |
|
| | |
| AsyncQueue<AsyncOpNode> _incoming; | AsyncQueue<AsyncOpNode> _incoming; |
| static Thread* _polling_thread; | static Thread* _polling_thread; |
| static Semaphore _polling_sem; | static Semaphore _polling_sem; |
| static AtomicInt _stop_polling; | static AtomicInt _stop_polling; |
| static AtomicInt _check_idle_flag; |
|
| | |
| typedef List<MessageQueueService, Mutex> PollingList; | typedef List<MessageQueueService, Mutex> PollingList; |
| static PollingList* _polling_list; | static PollingList* _polling_list; |
Return to
MessageQueueService.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common