svn commit: r1341081 - /mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/channel/ChannelDirectTcpip.java

[gnodet]

Author: gnodet
Date: Mon May 21 15:41:59 2012
New Revision: 1341081

URL: http://svn.apache.org/viewvc?rev=1341081&view=rev
Log:
[SSHD-151] Direct TCP/IP Port Forward sends EOF to client after closing channel

Modified:
    
mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/channel/ChannelDirectTcpip.java

Modified: 
mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/channel/ChannelDirectTcpip.java
URL: 
http://svn.apache.org/viewvc/mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/channel/ChannelDirectTcpip.java?rev=1341081&r1=1341080&r2=1341081&view=diff
==============================================================================
--- 
mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/channel/ChannelDirectTcpip.java
 (original)
+++ 
mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/channel/ChannelDirectTcpip.java
 Mon May 21 15:41:59 2012
@@ -19,7 +19,6 @@
 package org.apache.sshd.server.channel;
 
 import java.io.IOException;
-import java.io.InterruptedIOException;
 import java.io.OutputStream;
 import java.net.ConnectException;
 import java.net.InetSocketAddress;
@@ -109,7 +108,9 @@ public class ChannelDirectTcpip extends 
 
             @Override
             public void sessionClosed(IoSession session) throws Exception {
-                sendEof();
+                if (!closing) {
+                    sendEof();
+                }
             }
         };
         connector.setHandler(handler);