andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix the detection of encrypted data. See #655

Browse Source
This commit is contained in:
Norman Maurer 2012-10-16 14:03:40 +02:00
parent 9e6c616c35
commit 6e98a04813
1 changed files with 19 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
example/src/main/java/io/netty/example/portunification/PortUnificationServerHandler.java
View File

@ -53,17 +53,17 @@ public class PortUnificationServerHandler extends ChannelInboundByteHandlerAdapt
@Override
public void inboundBufferUpdated(ChannelHandlerContext ctx, ByteBuf in) throws Exception {
// Will use the first two bytes to detect a protocol.
if (in.readableBytes() < 2) {
// Will use the first five bytes to detect a protocol.
if (in.readableBytes() < 5) {
return;
}
if (isSsl(in)) {
enableSsl(ctx);
} else {
final int magic1 = in.getUnsignedByte(in.readerIndex());
final int magic2 = in.getUnsignedByte(in.readerIndex() + 1);
if (isSsl(magic1)) {
enableSsl(ctx);
} else if (isGzip(magic1, magic2)) {
if (isGzip(magic1, magic2)) {
enableGzip(ctx);
} else if (isHttp(magic1, magic2)) {
switchToHttp(ctx);
@ -75,20 +75,16 @@ public class PortUnificationServerHandler extends ChannelInboundByteHandlerAdapt
ctx.close();
return;
}
}
// Forward the current read buffer as is to the new handlers.
ctx.nextInboundByteBuffer().writeBytes(in);
ctx.fireInboundBufferUpdated();
}
private boolean isSsl(int magic1) {
private boolean isSsl(ByteBuf buf) {
if (detectSsl) {
switch (magic1) {
case 20: case 21: case 22: case 23: case 255:
return true;
default:
return magic1 >= 128;
}
return SslHandler.isEncrypted(buf);
}
return false;
}