|
version 1.71, 2008/12/02 09:00:48
|
version 1.76, 2008/12/16 19:55:37
|
|
|
|
| Boolean update_service(Uint32 capabilities, Uint32 mask); | Boolean update_service(Uint32 capabilities, Uint32 mask); |
| Boolean deregister_service(); | Boolean deregister_service(); |
| | |
| Uint32 find_service_qid(const String &name); |
Uint32 find_service_qid(const char* name); |
| static AsyncOpNode* get_op(); | static AsyncOpNode* get_op(); |
| void return_op(AsyncOpNode* op); | void return_op(AsyncOpNode* op); |
| Boolean isRunning() const { return _isRunning; } |
|
| | |
| static ThreadPool* get_thread_pool(); | static ThreadPool* get_thread_pool(); |
| | |
|
|
|
| static Semaphore _polling_sem; | static Semaphore _polling_sem; |
| static AtomicInt _stop_polling; | static AtomicInt _stop_polling; |
| | |
| typedef List<MessageQueueService, Mutex> PollingList; |
typedef List<MessageQueueService, NullLock> PollingList; |
| static PollingList* _polling_list; | static PollingList* _polling_list; |
| static Mutex _polling_list_mutex; | static Mutex _polling_list_mutex; |
| | |
| PollingList* _get_polling_list(); |
|
| |
|
| static ThreadReturnType PEGASUS_THREAD_CDECL _req_proc(void *); | static ThreadReturnType PEGASUS_THREAD_CDECL _req_proc(void *); |
| | |
| static void _sendwait_callback(AsyncOpNode *, MessageQueue *, void *); | static void _sendwait_callback(AsyncOpNode *, MessageQueue *, void *); |
Return to
MessageQueueService.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common