version 1.119.12.7, 2006/06/30 20:25:43
|
version 1.120, 2006/07/11 18:39:28
|
|
|
| |
cimom *MessageQueueService::_meta_dispatcher = 0; | cimom *MessageQueueService::_meta_dispatcher = 0; |
AtomicInt MessageQueueService::_service_count(0); | AtomicInt MessageQueueService::_service_count(0); |
Mutex MessageQueueService::_xidMutex; |
IDFactory MessageQueueService::_xidFactory(1); |
Uint32 MessageQueueService::_xid = 1; |
|
Mutex MessageQueueService::_meta_dispatcher_mutex; | Mutex MessageQueueService::_meta_dispatcher_mutex; |
| |
static struct timeval deallocateWait = {300, 0}; | static struct timeval deallocateWait = {300, 0}; |
|
|
| |
Uint32 MessageQueueService::get_next_xid() | Uint32 MessageQueueService::get_next_xid() |
{ | { |
AutoMutex autoMut(_xidMutex); |
return _xidFactory.getID(); |
return ++_xid; |
|
} | } |
| |
MessageQueueService::PollingList* MessageQueueService::_get_polling_list() | MessageQueueService::PollingList* MessageQueueService::_get_polling_list() |