Fixed some SSL code

mina-core/src/main/java/org/apache/mina/filter/ssl/SslFilter.java

@@ -857,7 +857,7 @@ public String toString() {
      * message, but not for handshake messages, which will be swallowed.
      *
      */
-    private static class EncryptedWriteRequest extends DefaultWriteRequest {
+    /* package protected */ static class EncryptedWriteRequest extends DefaultWriteRequest {
         // Thee encrypted messagee
         private final IoBuffer encryptedMessage;
 

mina-core/src/main/java/org/apache/mina/filter/ssl/SslHandler.java

@@ -33,6 +33,7 @@
 import javax.net.ssl.SSLException;
 import javax.net.ssl.SSLHandshakeException;
 
+import org.apache.mina.core.RuntimeIoException;
 import org.apache.mina.core.buffer.IoBuffer;
 import org.apache.mina.core.filterchain.IoFilter.NextFilter;
 import org.apache.mina.core.filterchain.IoFilterEvent;
@@ -42,6 +43,7 @@
 import org.apache.mina.core.session.IoSession;
 import org.apache.mina.core.write.DefaultWriteRequest;
 import org.apache.mina.core.write.WriteRequest;
+import org.apache.mina.filter.ssl.SslFilter.EncryptedWriteRequest;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -528,9 +530,34 @@ private void checkStatus(SSLEngineResult res) throws SSLException {
          * UNDERFLOW - Need to read more data from the socket. It's normal.
          * CLOSED - The other peer closed the socket. Also normal.
          */
-        if (status == SSLEngineResult.Status.BUFFER_OVERFLOW) {
-            throw new SSLException("SSLEngine error during decrypt: " + status + " inNetBuffer: " + inNetBuffer
+        switch (status) {
+            case BUFFER_OVERFLOW:
+                throw new SSLException("SSLEngine error during decrypt: " + status + " inNetBuffer: " + inNetBuffer
                     + "appBuffer: " + appBuffer);
+            case CLOSED:
+                Exception exception =new RuntimeIoException("SSL/TLS close_notify received");
+
+                // Empty the Ssl queue
+                for (IoFilterEvent event:filterWriteEventQueue) {
+                    EncryptedWriteRequest writeRequest = (EncryptedWriteRequest)event.getParameter();
+                    WriteFuture writeFuture = writeRequest.getParentRequest().getFuture();
+                    writeFuture.setException(exception);
+                    writeFuture.notifyAll();
+                }
+
+                // Empty the session queue
+                while (!session.getWriteRequestQueue().isEmpty(session)) {
+                    WriteRequest writeRequest = session.getWriteRequestQueue().poll( session );
+                    WriteFuture writeFuture = writeRequest.getFuture();
+                    writeFuture.setException(exception);
+                    writeFuture.notifyAll();
+                }
+
+                // We *must* shutdown session
+                session.closeNow();
+                break;
+            default: 
+                break;
         }
     }
 
@@ -595,8 +622,7 @@ private void checkStatus(SSLEngineResult res) throws SSLException {
                 }
 
                 // First make sure that the out buffer is completely empty.
-                // Since we
-                // cannot call wrap with data left on the buffer
+                // Since we cannot call wrap with data left on the buffer
                 if (outNetBuffer != null && outNetBuffer.hasRemaining()) {
                     return;
                 }

mina-core/src/test/java/org/apache/mina/filter/ssl/SslTest.java

@@ -152,7 +152,6 @@ private static void connectAndSend() throws Exception {
         String line = in.readLine();
         //System.out.println("Client got: " + line);
         socket.close();
-
     }
 
     private static SSLContext createSSLContext() throws IOException, GeneralSecurityException {