TooTallNate#171

fix 100% CPU issue

Author: Eugene-Kudelevsky

src/main/java/org/java_websocket/SSLSocketChannel2.java

@@ -5,6 +5,13 @@
  */
 packageorg.java_websocket;
 
+importjavax.net.ssl.SSLEngine;
+importjavax.net.ssl.SSLEngineResult;
+importjavax.net.ssl.SSLEngineResult.HandshakeStatus;
+importjavax.net.ssl.SSLEngineResult.Status;
+importjavax.net.ssl.SSLException;
+importjavax.net.ssl.SSLSession;
+importjava.io.EOFException;
 importjava.io.IOException;
 importjava.net.Socket;
 importjava.net.SocketAddress;
@@ -20,13 +27,6 @@
 importjava.util.concurrent.ExecutorService;
 importjava.util.concurrent.Future;
 
-importjavax.net.ssl.SSLEngine;
-importjavax.net.ssl.SSLEngineResult;
-importjavax.net.ssl.SSLEngineResult.HandshakeStatus;
-importjavax.net.ssl.SSLEngineResult.Status;
-importjavax.net.ssl.SSLException;
-importjavax.net.ssl.SSLSession;
-
 /**
  * Implements the relevant portions of the SocketChannel interface with the SSLEngine wrapper.
  */
@@ -213,6 +213,9 @@ public int write( ByteBuffer src ) throws IOException{
 // createBuffers( sslEngine.getSession() );
 //}
 intnum = socketChannel.write( wrap( src ) );
+if (writeEngineResult.getStatus() == SSLEngineResult.Status.CLOSED){
+thrownewEOFException("Connection is closed");
+ }
 returnnum;
 
  }
@@ -286,6 +289,9 @@ private int readRemaining( ByteBuffer dst ) throws SSLException{
 if( inCrypt.hasRemaining() ){
 unwrap();
 intamount = transfereTo( inData, dst );
+if (readEngineResult.getStatus() == SSLEngineResult.Status.CLOSED){
+return -1;
+ }
 if( amount > 0 )
 returnamount;
  }