|
version 1.23, 2002/02/12 23:28:58
|
version 1.24, 2002/02/20 22:00:51
|
|
|
|
| #include <Pegasus/Common/IPC.h> | #include <Pegasus/Common/IPC.h> |
| #include <Pegasus/Common/Tracer.h> | #include <Pegasus/Common/Tracer.h> |
| #include "MessageQueue.h" | #include "MessageQueue.h" |
| |
#include "MessageQueueService.h" |
| PEGASUS_USING_STD; | PEGASUS_USING_STD; |
| | |
| PEGASUS_NAMESPACE_BEGIN | PEGASUS_NAMESPACE_BEGIN |
|
|
|
| return queueId; | return queueId; |
| } | } |
| | |
| |
|
| |
|
| MessageQueue::MessageQueue( | MessageQueue::MessageQueue( |
| const char* name, | const char* name, |
| Boolean async, | Boolean async, |
| Uint32 queueId) | Uint32 queueId) |
| : _queueId(queueId), _count(0), _front(0), _back(0), _async(async) |
: _queueId(queueId), _capabilities(0), _count(0), _front(0), _back(0), _async(async) |
| { | { |
| // | // |
| // Copy the name: | // Copy the name: |
|
|
|
| message->print(cout); | message->print(cout); |
| } | } |
| | |
| |
|
| _mut.lock(pegasus_thread_self()); | _mut.lock(pegasus_thread_self()); |
| if (_back) | if (_back) |
| { | { |
Return to
MessageQueue.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common