qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From g...@apache.org
Subject svn commit: r587054 - /incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp
Date Mon, 22 Oct 2007 10:28:14 GMT
Author: gsim
Date: Mon Oct 22 03:28:07 2007
New Revision: 587054

URL: http://svn.apache.org/viewvc?rev=587054&view=rev
Log:
Record peer address (for logging purposes) on initiation rather than on every logged message.


Modified:
    incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp

Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp?rev=587054&r1=587053&r2=587054&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp Mon Oct 22 03:28:07 2007
@@ -83,13 +83,14 @@
 };
 
 class AsynchIOHandler : public qpid::sys::ConnectionOutputHandler {
-	AsynchIO* aio;
-	ConnectionInputHandler* inputHandler;
-	std::queue<framing::AMQFrame> frameQueue;
-	Mutex frameQueueLock;
-	bool frameQueueClosed;
-	bool initiated;
-        bool readError;
+    AsynchIO* aio;
+    ConnectionInputHandler* inputHandler;
+    std::queue<framing::AMQFrame> frameQueue;
+    Mutex frameQueueLock;
+    bool frameQueueClosed;
+    bool initiated;
+    bool readError;
+    std::string identifier;
 
 public:
 	AsynchIOHandler() :
@@ -211,7 +212,7 @@
         framing::AMQFrame frame;
         try{
             while(frame.decode(in)) {
-                QPID_LOG(debug, "RECV [" << aio->getSocket().getPeerAddress() <<
"]: " << frame);
+                QPID_LOG(debug, "RECV [" << identifier << "]: " << frame);
                 inputHandler->received(frame);
             }
         }catch(const std::exception& e){
@@ -222,7 +223,8 @@
     }else{
         framing::ProtocolInitiation protocolInit;
         if(protocolInit.decode(in)){
-            QPID_LOG(debug, "INIT [" << aio->getSocket().getPeerAddress() <<
"]");
+            identifier = aio->getSocket().getPeerAddress();
+            QPID_LOG(debug, "INIT [" << identifier << "]");
             inputHandler->initiated(protocolInit);
             initiated = true;
         }
@@ -241,6 +243,7 @@
 }
 
 void AsynchIOHandler::eof(AsynchIO&) {
+        QPID_LOG(debug, "DISCONNECTED [" << identifier << "]");
 	inputHandler->closed();
 	aio->queueWriteClose();
 }
@@ -248,7 +251,7 @@
 void AsynchIOHandler::closedSocket(AsynchIO&, const Socket& s) {
     // If we closed with data still to send log a warning 
     if (!aio->writeQueueEmpty()) {
-        QPID_LOG(warning, "CLOSING [" << aio->getSocket().getPeerAddress() <<
"] unsent data (probably due to client disconnect)");
+        QPID_LOG(warning, "CLOSING [" << identifier << "] unsent data (probably
due to client disconnect)");
     }
 	delete &s;
 	aio->queueForDeletion();
@@ -289,7 +292,7 @@
 			// Encode output frame	
 			frame.encode(out);
 			buffUsed += frameSize;
-			QPID_LOG(debug, "SENT [" << aio->getSocket().getPeerAddress() << "]: "
<< frame);
+			QPID_LOG(debug, "SENT [" << identifier << "]: " << frame);
 			
 			if (frameQueue.empty())
 				break;



Mime
View raw message