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) {
