version 1.34, 2003/10/02 00:11:38
|
version 1.35, 2003/10/08 13:48:40
|
|
|
static QueueTable _queueTable(256); | static QueueTable _queueTable(256); |
static Mutex q_table_mut ; | static Mutex q_table_mut ; |
| |
|
void MessageQueue::remove_myself(Uint32 qid) |
|
{ |
|
q_table_mut.lock(pegasus_thread_self()); |
|
|
|
_queueTable.remove(qid); |
|
q_table_mut.unlock(); |
|
} |
|
|
|
|
Uint32 MessageQueue::getNextQueueId() throw(IPCException) | Uint32 MessageQueue::getNextQueueId() throw(IPCException) |
{ | { |
static Uint32 _nextQueueId = 2; | static Uint32 _nextQueueId = 2; |