Author: ruwan
Date: Wed Feb 24 14:29:21 2010
New Revision: 915803
URL: http://svn.apache.org/viewvc?rev=915803&view=rev
Log:
Fixing the issue https://issues.apache.org/jira/browse/SYNAPSE-613, committing for Supun
Modified:
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOSender.java
Modified: synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java?rev=915803&r1=915802&r2=915803&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java (original)
+++ synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java Wed Feb 24 14:29:21 2010
@@ -853,6 +853,15 @@
* @param conn the connection to be shutdown
*/
private void shutdownConnection(final NHttpClientConnection conn) {
+
+ if (log.isDebugEnabled() && conn instanceof HttpInetConnection) {
+ HttpInetConnection inetConnection = (HttpInetConnection) conn;
+ log.debug("Connection to remote address : " + inetConnection.getRemoteAddress()
+ + ":" + inetConnection.getRemotePort() + " from local address : "
+ + inetConnection.getLocalAddress() + ":" + inetConnection.getLocalPort() +
+ " is closed!");
+ }
+
HttpContext context = conn.getContext();
SharedOutputBuffer outputBuffer = (SharedOutputBuffer)
context.getAttribute(REQUEST_SOURCE_BUFFER);
Modified: synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOSender.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOSender.java?rev=915803&r1=915802&r2=915803&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOSender.java (original)
+++ synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOSender.java Wed Feb 24 14:29:21 2010
@@ -671,6 +671,12 @@
private SessionRequestCallback getSessionRequestCallback() {
return new SessionRequestCallback() {
public void completed(SessionRequest request) {
+ if (log.isDebugEnabled() && request.getSession() != null &&
+ request.getSession().getLocalAddress() != null) {
+ log.debug("Connected to remote address : "
+ + request.getSession().getRemoteAddress()
+ + " from local address : " + request.getSession().getLocalAddress());
+ }
}
public void failed(SessionRequest request) {