|
version 1.47, 2006/01/30 16:17:05
|
version 1.47.12.2, 2006/07/01 15:07:17
|
|
|
|
| #include <Pegasus/Common/HashTable.h> | #include <Pegasus/Common/HashTable.h> |
| #include <Pegasus/Common/IPC.h> | #include <Pegasus/Common/IPC.h> |
| #include <Pegasus/Common/Tracer.h> | #include <Pegasus/Common/Tracer.h> |
| #include "Stack.h" |
|
| #include "MessageQueue.h" | #include "MessageQueue.h" |
| #include "MessageQueueService.h" | #include "MessageQueueService.h" |
| |
#include "IDFactory.h" |
| |
|
| PEGASUS_USING_STD; | PEGASUS_USING_STD; |
| | |
| PEGASUS_NAMESPACE_BEGIN | PEGASUS_NAMESPACE_BEGIN |
|
|
|
| _queueTable.remove(qid); | _queueTable.remove(qid); |
| } | } |
| | |
| static Stack<Uint32> _qid_stack; |
static IDFactory _qidFactory(CIMOM_Q_ID + 1); |
| static Uint32 _qid_next = CIMOM_Q_ID + 1; |
|
| static Mutex _qid_mutex; |
|
| | |
| Uint32 MessageQueue::getNextQueueId() | Uint32 MessageQueue::getNextQueueId() |
| { | { |
| // If _qid_stack is empty, return _qid_next (and then increment _qid_next). |
return _qidFactory.getID(); |
| // Else return the top of the stack. |
|
| |
|
| AutoMutex autoMutex(_qid_mutex); |
|
| |
|
| if (_qid_stack.isEmpty()) |
|
| return _qid_next++; |
|
| |
|
| Uint32 queueId = _qid_stack.top(); |
|
| _qid_stack.pop(); |
|
| return queueId; |
|
| } | } |
| | |
| void MessageQueue::putQueueId(Uint32 queueId) | void MessageQueue::putQueueId(Uint32 queueId) |
| { | { |
| // Put the queueId on the top of the stack. |
if (queueId != CIMOM_Q_ID) |
| |
_qidFactory.putID(queueId); |
| AutoMutex autoMutex(_qid_mutex); |
|
| // Ignore an attempt to return the well-known queue id (CIMOM_Q_ID). |
|
| // This id is reserved for the CIMOM queue. |
|
| |
|
| if (queueId == CIMOM_Q_ID) |
|
| return; |
|
| |
|
| _qid_stack.push(queueId); |
|
| } | } |
| | |
| MessageQueue::MessageQueue( | MessageQueue::MessageQueue( |
Return to
MessageQueue.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common