version 1.54, 2006/11/10 18:14:58
|
version 1.56.18.1, 2008/07/01 15:18:00
|
|
|
_name = new char[strlen(name) + 1]; | _name = new char[strlen(name) + 1]; |
strcpy(_name, name); | strcpy(_name, name); |
| |
Tracer::trace(TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3, |
PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3, |
"MessageQueue::MessageQueue name = %s, queueId = %u", name, queueId); |
"MessageQueue::MessageQueue name = %s, queueId = %u", name, queueId)); |
| |
// | // |
// Insert into queue table: | // Insert into queue table: |
|
|
{ | { |
// ATTN-A: thread safety! | // ATTN-A: thread safety! |
PEG_METHOD_ENTER(TRC_MESSAGEQUEUESERVICE,"MessageQueue::~MessageQueue()"); | PEG_METHOD_ENTER(TRC_MESSAGEQUEUESERVICE,"MessageQueue::~MessageQueue()"); |
Tracer::trace(TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3, |
PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3, |
"MessageQueue::~MessageQueue queueId = %i, name = %s", _queueId, _name); |
"MessageQueue::~MessageQueue queueId = %i, name = %s", |
|
_queueId, |
|
_name)); |
| |
{ | { |
AutoMutex autoMut(q_table_mut); | AutoMutex autoMut(q_table_mut); |
|
|
| |
PEGASUS_ASSERT(message != 0); | PEGASUS_ASSERT(message != 0); |
| |
PEG_TRACE_STRING(TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3, |
PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3, |
String("Queue name: ") + getQueueName()); |
"Queue name: [%s], Message: [%s]", |
Tracer::trace(TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3, |
getQueueName(), |
"Message: [%s]", |
MessageTypeToString(message->getType()))); |
MessageTypeToString(message->getType())); |
|
| |
_messageList.insert_back(message); | _messageList.insert_back(message); |
| |
|
|
| |
// Not found! | // Not found! |
| |
Tracer::trace(TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3, |
PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL1, |
"MessageQueue::lookup failure queueId = %u", queueId); |
"MessageQueue::lookup failure queueId = %u", queueId)); |
| |
return 0; | return 0; |
} | } |
|
|
} | } |
} | } |
| |
Tracer::trace(TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3, |
PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL1, |
"MessageQueue::lookup failure - name = %s", name); |
"MessageQueue::lookup failure - name = %s", name)); |
| |
return 0; | return 0; |
} | } |