diff options
Diffstat (limited to 'jetty-client/src/test/java/org/eclipse/jetty/client/ssl/SslBytesServerTest.java')
-rw-r--r-- | jetty-client/src/test/java/org/eclipse/jetty/client/ssl/SslBytesServerTest.java | 14 |
1 files changed, 11 insertions, 3 deletions
diff --git a/jetty-client/src/test/java/org/eclipse/jetty/client/ssl/SslBytesServerTest.java b/jetty-client/src/test/java/org/eclipse/jetty/client/ssl/SslBytesServerTest.java index 62699c911a..b5f169061c 100644 --- a/jetty-client/src/test/java/org/eclipse/jetty/client/ssl/SslBytesServerTest.java +++ b/jetty-client/src/test/java/org/eclipse/jetty/client/ssl/SslBytesServerTest.java @@ -54,10 +54,10 @@ import javax.servlet.http.HttpServletResponse; import org.eclipse.jetty.client.ssl.SslBytesTest.TLSRecord.Type; import org.eclipse.jetty.http.HttpParser; +import org.eclipse.jetty.io.ChannelEndPoint; import org.eclipse.jetty.io.Connection; import org.eclipse.jetty.io.EndPoint; import org.eclipse.jetty.io.ManagedSelector; -import org.eclipse.jetty.io.SelectChannelEndPoint; import org.eclipse.jetty.io.ssl.SslConnection; import org.eclipse.jetty.server.Connector; import org.eclipse.jetty.server.HttpConnection; @@ -173,9 +173,9 @@ public class SslBytesServerTest extends SslBytesTest ServerConnector connector = new ServerConnector(server, null,null,null,1,1,sslFactory, httpFactory) { @Override - protected SelectChannelEndPoint newEndPoint(SocketChannel channel, ManagedSelector selectSet, SelectionKey key) throws IOException + protected ChannelEndPoint newEndPoint(SocketChannel channel, ManagedSelector selectSet, SelectionKey key) throws IOException { - SelectChannelEndPoint endp = super.newEndPoint(channel,selectSet,key); + ChannelEndPoint endp = super.newEndPoint(channel,selectSet,key); serverEndPoint.set(endp); return endp; } @@ -367,11 +367,19 @@ public class SslBytesServerTest extends SslBytesTest System.arraycopy(doneBytes, 0, chunk, recordBytes.length, doneBytes.length); System.arraycopy(closeRecordBytes, 0, chunk, recordBytes.length + doneBytes.length, closeRecordBytes.length); proxy.flushToServer(0, chunk); + // Close the raw socket proxy.flushToServer(null); // Expect the server to send a FIN as well record = proxy.readFromServer(); + if (record!=null) + { + // Close alert snuck out // TODO check if this is acceptable + Assert.assertEquals(Type.ALERT,record.getType()); + record = proxy.readFromServer(); + } + Assert.assertNull(record); // Check that we did not spin |