diff options
author | Ted Ross <tross@apache.org> | 2009-07-17 13:39:26 +0000 |
---|---|---|
committer | Ted Ross <tross@apache.org> | 2009-07-17 13:39:26 +0000 |
commit | 10c869b18fbfcd9952675431cd54b1e32073aa0d (patch) | |
tree | e63d9c870e293e58056f1e4c2d52af4d85aaaa9f /cpp/src/qpid | |
parent | 9a95fdef8beee204e2a76b1895f748c1c29289de (diff) | |
download | qpid-python-10c869b18fbfcd9952675431cd54b1e32073aa0d.tar.gz |
Improved debug logging
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@795081 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid')
-rw-r--r-- | cpp/src/qpid/management/ManagementAgent.cpp | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/cpp/src/qpid/management/ManagementAgent.cpp b/cpp/src/qpid/management/ManagementAgent.cpp index bc106dbe48..3ea38ca45e 100644 --- a/cpp/src/qpid/management/ManagementAgent.cpp +++ b/cpp/src/qpid/management/ManagementAgent.cpp @@ -46,6 +46,7 @@ ManagementAgent::RemoteAgent::~RemoteAgent () { if (mgmtObject != 0) mgmtObject->resourceDestroy(); + QPID_LOG(debug, "Remote Agent removed bank=[" << brokerBank << "." << agentBank << "]"); } ManagementAgent::ManagementAgent () : @@ -345,6 +346,8 @@ void ManagementAgent::periodicProcessing (void) baseIter != managementObjects.end(); baseIter++) { ManagementObject* baseObject = baseIter->second; + uint32_t pcount = 0; + uint32_t scount = 0; // // Skip until we find a base object requiring a sent message. @@ -369,11 +372,13 @@ void ManagementAgent::periodicProcessing (void) if (object->getConfigChanged() || object->getForcePublish() || object->isDeleted()) { encodeHeader(msgBuffer, 'c'); object->writeProperties(msgBuffer); + pcount++; } if (object->hasInst() && (object->getInstChanged() || object->getForcePublish())) { encodeHeader(msgBuffer, 'i'); object->writeStatistics(msgBuffer); + scount++; } if (object->isDeleted()) @@ -391,7 +396,7 @@ void ManagementAgent::periodicProcessing (void) stringstream key; key << "console.obj.1.0." << baseObject->getPackageName() << "." << baseObject->getClassName(); sendBuffer(msgBuffer, contentSize, mExchange, key.str()); - QPID_LOG(debug, "SEND Multicast ContentInd to=" << key.str()); + QPID_LOG(debug, "SEND Multicast ContentInd to=" << key.str() << " props=" << pcount << " stats=" << scount); } } @@ -865,6 +870,8 @@ void ManagementAgent::handleAttachRequestLH (Buffer& inBuffer, string replyToKey remoteAgents[connectionRef] = agent; + QPID_LOG(debug, "Remote Agent registered bank=[" << brokerBank << "." << assignedBank << "] replyTo=" << replyToKey); + // Send an Attach Response Buffer outBuffer (outputBuffer, MA_BUFFER_SIZE); uint32_t outLen; |