Class StopAndWaitArqCodec
java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.channel.ChannelDuplexHandler
io.netty.handler.codec.MessageToMessageCodec<io.netty.buffer.ByteBuf,StopAndWaitArqMessage>
org.drasyl.handler.arq.stopandwait.StopAndWaitArqCodec
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelInboundHandler
,io.netty.channel.ChannelOutboundHandler
public final class StopAndWaitArqCodec
extends io.netty.handler.codec.MessageToMessageCodec<io.netty.buffer.ByteBuf,StopAndWaitArqMessage>
Encodes
StopAndWaitArqMessage
s to ByteBuf
s and vice versa.-
Nested Class Summary
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
io.netty.channel.ChannelHandler.Sharable
-
Field Summary
Modifier and TypeFieldDescriptionstatic final int
static final int
static final int
-
Constructor Summary
-
Method Summary
Methods inherited from class io.netty.handler.codec.MessageToMessageCodec
acceptInboundMessage, acceptOutboundMessage, channelRead, write
Methods inherited from class io.netty.channel.ChannelDuplexHandler
bind, close, connect, deregister, disconnect, flush, read
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.netty.channel.ChannelHandler
handlerAdded, handlerRemoved
-
Field Details
-
MAGIC_NUMBER_DATA
public static final int MAGIC_NUMBER_DATA- See Also:
-
MAGIC_NUMBER_ACK
public static final int MAGIC_NUMBER_ACK- See Also:
-
MIN_MESSAGE_LENGTH
public static final int MIN_MESSAGE_LENGTH- See Also:
-
-
Constructor Details
-
StopAndWaitArqCodec
public StopAndWaitArqCodec()
-
-
Method Details
-
encode
protected void encode(io.netty.channel.ChannelHandlerContext ctx, StopAndWaitArqMessage msg, List<Object> out) throws io.netty.handler.codec.EncoderException - Specified by:
encode
in classio.netty.handler.codec.MessageToMessageCodec<io.netty.buffer.ByteBuf,
StopAndWaitArqMessage> - Throws:
io.netty.handler.codec.EncoderException
-
decode
protected void decode(io.netty.channel.ChannelHandlerContext ctx, io.netty.buffer.ByteBuf in, List<Object> out) throws Exception - Specified by:
decode
in classio.netty.handler.codec.MessageToMessageCodec<io.netty.buffer.ByteBuf,
StopAndWaitArqMessage> - Throws:
Exception
-