org.waarp.ftp.core.data.handler

Class FtpDataModeCodec

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelDuplexHandler

io.netty.handler.codec.ByteToMessageCodec<DataBlock>

org.waarp.ftp.core.data.handler.FtpDataModeCodec

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler

public class FtpDataModeCodec
extends io.netty.handler.codec.ByteToMessageCodec<DataBlock>

First CODEC :
- encode : takes a DataBlock and transforms it to a ByteBuf
- decode : takes a ByteBuf and transforms it to a DataBlock
STREAM and BLOCK mode are implemented. COMPRESSED mode is not implemented.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
FtpDataModeCodec(FtpArgumentCode.TransferMode mode, FtpArgumentCode.TransferStructure structure)

Method Summary

Modifier and Type	Method and Description
protected void	decode(io.netty.channel.ChannelHandlerContext ctx, io.netty.buffer.ByteBuf buf, List<Object> out)
protected void	decodeLast(io.netty.channel.ChannelHandlerContext ctx, io.netty.buffer.ByteBuf in, List<Object> out)
protected DataBlock	decodeRecord(io.netty.buffer.ByteBuf buf, int length)
protected DataBlock	decodeRecordStandard(io.netty.buffer.ByteBuf buf, int length)
protected void	encode(io.netty.channel.ChannelHandlerContext ctx, DataBlock msg, io.netty.buffer.ByteBuf out)
protected io.netty.buffer.ByteBuf	encode(DataBlock msg) Encode a DataBlock in the correct format for Mode
protected io.netty.buffer.ByteBuf	encodeRecord(DataBlock msg, byte[] buffer)
FtpArgumentCode.TransferMode	getMode()
FtpArgumentCode.TransferStructure	getStructure()
void	setCodecReady() Inform the Codec that DataNetworkHandler is ready (called from DataNetworkHandler after setCorrectCodec).
void	setMode(FtpArgumentCode.TransferMode mode)
void	setStructure(FtpArgumentCode.TransferStructure structure)

Methods inherited from class io.netty.handler.codec.ByteToMessageCodec

acceptOutboundMessage, channelInactive, channelRead, channelReadComplete, handlerAdded, handlerRemoved, 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, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, 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

exceptionCaught

Constructor Detail

FtpDataModeCodec

public FtpDataModeCodec(FtpArgumentCode.TransferMode mode,
                        FtpArgumentCode.TransferStructure structure)

Parameters:

mode -

structure -

Method Detail

setCodecReady

public final void setCodecReady()

Inform the Codec that DataNetworkHandler is ready (called from DataNetworkHandler after setCorrectCodec).

decodeRecordStandard

protected final DataBlock decodeRecordStandard(io.netty.buffer.ByteBuf buf,
                                               int length)

decodeRecord

protected final DataBlock decodeRecord(io.netty.buffer.ByteBuf buf,
                                       int length)

decode

protected void decode(io.netty.channel.ChannelHandlerContext ctx,
                      io.netty.buffer.ByteBuf buf,
                      List<Object> out)
               throws Exception

Specified by:

decode in class io.netty.handler.codec.ByteToMessageCodec<DataBlock>

Throws:

Exception

decodeLast

protected void decodeLast(io.netty.channel.ChannelHandlerContext ctx,
                          io.netty.buffer.ByteBuf in,
                          List<Object> out)
                   throws Exception

Overrides:

decodeLast in class io.netty.handler.codec.ByteToMessageCodec<DataBlock>

Throws:

Exception

encodeRecord

protected final io.netty.buffer.ByteBuf encodeRecord(DataBlock msg,
                                                     byte[] buffer)

encode

protected final io.netty.buffer.ByteBuf encode(DataBlock msg)
                                        throws InvalidArgumentException

Encode a DataBlock in the correct format for Mode

Parameters:

msg -

Returns:

the ByteBuf or null when the last block is already done

Throws:

InvalidArgumentException

getMode

public final FtpArgumentCode.TransferMode getMode()

Returns:

the mode

setMode

public final void setMode(FtpArgumentCode.TransferMode mode)

Parameters:

mode - the mode to set

getStructure

public final FtpArgumentCode.TransferStructure getStructure()

Returns:

the structure

setStructure

public final void setStructure(FtpArgumentCode.TransferStructure structure)

Parameters:

structure - the structure to set

encode

protected void encode(io.netty.channel.ChannelHandlerContext ctx,
                      DataBlock msg,
                      io.netty.buffer.ByteBuf out)
               throws Exception

Specified by:

encode in class io.netty.handler.codec.ByteToMessageCodec<DataBlock>

Throws:

Exception