(file) Return to MessageQueue.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/MessageQueue.cpp between version 1.54 and 1.54.4.1

version 1.54, 2006/11/10 18:14:58 version 1.54.4.1, 2007/04/04 11:04:44
Line 78 
Line 78 
     _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:
Line 95 
Line 95 
 { {
     // 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);
Line 120 
Line 120 
  
     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",
     Tracer::trace(TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3,          getQueueName()));
   
       PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3,
         "Message: [%s]",         "Message: [%s]",
         MessageTypeToString(message->getType()));          MessageTypeToString(message->getType())));
  
     _messageList.insert_back(message);     _messageList.insert_back(message);
  
Line 160 
Line 162 
  
     // Not found!     // Not found!
  
     Tracer::trace(TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3,      PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3,
         "MessageQueue::lookup failure queueId = %u", queueId);          "MessageQueue::lookup failure queueId = %u", queueId));
  
     return 0;     return 0;
 } }
Line 183 
Line 185 
         }         }
     }     }
  
     Tracer::trace(TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3,      PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3,
         "MessageQueue::lookup failure - name = %s", name);          "MessageQueue::lookup failure - name = %s", name));
  
     return 0;     return 0;
 } }

Legend:
Removed from v.1.54  
changed lines
  Added in v.1.54.4.1
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2