From 5ecbb4b604221f2667d98e15bde87fa0102c79b7 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Mon, 15 Oct 2007 11:56:09 +0000 Subject: Include information on the client connection in io traces. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@584755 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/sys/AsynchIOAcceptor.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'cpp/src/qpid/sys/AsynchIOAcceptor.cpp') diff --git a/cpp/src/qpid/sys/AsynchIOAcceptor.cpp b/cpp/src/qpid/sys/AsynchIOAcceptor.cpp index 42272a4ac9..78b156877a 100644 --- a/cpp/src/qpid/sys/AsynchIOAcceptor.cpp +++ b/cpp/src/qpid/sys/AsynchIOAcceptor.cpp @@ -211,7 +211,7 @@ void AsynchIOHandler::readbuff(AsynchIO& , AsynchIO::BufferBase* buff) { framing::AMQFrame frame; try{ while(frame.decode(in)) { - QPID_LOG(debug, "RECV: " << frame); + QPID_LOG(debug, "RECV [" << aio->getSocket().getPeerAddress() << "]: " << frame); inputHandler->received(frame); } }catch(const std::exception& e){ @@ -222,7 +222,7 @@ void AsynchIOHandler::readbuff(AsynchIO& , AsynchIO::BufferBase* buff) { }else{ framing::ProtocolInitiation protocolInit; if(protocolInit.decode(in)){ - QPID_LOG(debug, "INIT [" << aio << "]"); + QPID_LOG(debug, "INIT [" << aio->getSocket().getPeerAddress() << "]"); inputHandler->initiated(protocolInit); initiated = true; } @@ -285,7 +285,7 @@ void AsynchIOHandler::idle(AsynchIO&){ // Encode output frame frame.encode(out); buffUsed += frameSize; - QPID_LOG(debug, "SENT: " << frame); + QPID_LOG(debug, "SENT [" << aio->getSocket().getPeerAddress() << "]: " << frame); if (frameQueue.empty()) break; -- cgit v1.2.1