public class SocksPortUnificationServerHandler extends ByteToMessageDecoder
Socks4ServerDecoder
or Socks5InitialRequestDecoder
.ByteToMessageDecoder.Cumulator
ChannelHandler.Sharable
Modifier and Type | Field and Description |
---|---|
private static InternalLogger |
logger |
private Socks5ServerEncoder |
socks5encoder |
COMPOSITE_CUMULATOR, MERGE_CUMULATOR
Constructor and Description |
---|
SocksPortUnificationServerHandler()
Creates a new instance with the default configuration.
|
SocksPortUnificationServerHandler(Socks5ServerEncoder socks5encoder)
Creates a new instance with the specified
Socks5ServerEncoder . |
Modifier and Type | Method and Description |
---|---|
protected void |
decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
private static void |
logKnownVersion(ChannelHandlerContext ctx,
SocksVersion version) |
private static void |
logUnknownVersion(ChannelHandlerContext ctx,
byte versionVal) |
actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
ensureNotSharable, handlerAdded, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handlerAdded
private static final InternalLogger logger
private final Socks5ServerEncoder socks5encoder
public SocksPortUnificationServerHandler()
public SocksPortUnificationServerHandler(Socks5ServerEncoder socks5encoder)
Socks5ServerEncoder
.
This constructor is useful when a user wants to use an alternative Socks5AddressEncoder
.protected void decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) throws java.lang.Exception
ByteToMessageDecoder
ByteBuf
to an other. This method will be called till either the input
ByteBuf
has nothing to read when return from this method or till nothing was read from the input
ByteBuf
.decode
in class ByteToMessageDecoder
ctx
- the ChannelHandlerContext
which this ByteToMessageDecoder
belongs toin
- the ByteBuf
from which to read dataout
- the List
to which decoded messages should be addedjava.lang.Exception
- is thrown if an error occursprivate static void logKnownVersion(ChannelHandlerContext ctx, SocksVersion version)
private static void logUnknownVersion(ChannelHandlerContext ctx, byte versionVal)