org.waarp.ftp.core.data.handler

Class DataNetworkHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<org.waarp.common.file.DataBlock>

org.waarp.ftp.core.data.handler.DataNetworkHandler

All Implemented Interfaces:

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

public class DataNetworkHandler
extends io.netty.channel.SimpleChannelInboundHandler<org.waarp.common.file.DataBlock>

Network handler for Data connections

Author:

Frederic Bregier

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
protected FtpConfiguration	configuration Configuration
protected FtpSession	session Internal store for the SessionInterface

Constructor Summary

Constructors

Constructor and Description
DataNetworkHandler(FtpConfiguration configuration, DataBusinessHandler handler, boolean active) Constructor from DataBusinessHandler

Method Summary

Methods

Modifier and Type	Method and Description
void	channelActive(io.netty.channel.ChannelHandlerContext ctx) Initialize the Handler.
void	channelInactive(io.netty.channel.ChannelHandlerContext ctx) Run firstly executeChannelClosed.
void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, org.waarp.common.file.DataBlock dataBlock) Act as needed according to the receive DataBlock message
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause) Default exception task: close the current connection after calling exceptionLocalCaught.
DataBusinessHandler	getDataBusinessHandler()
FtpSession	getFtpSession()
NetworkHandler	getNetworkHandler()
void	setCorrectCodec() Set the CODEC according to the mode.
void	setFtpTransfer(FtpTransfer ftpTransfer)
protected void	setSession(io.netty.channel.Channel channel)
void	unlockModeCodec() Unlock the Mode Codec from openConnection of FtpTransferControl
boolean	writeMessage(String message) Write a simple message (like LIST) and wait for it

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, 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 Detail

configuration

protected final FtpConfiguration configuration

Configuration

session

protected FtpSession session

Internal store for the SessionInterface

Constructor Detail

DataNetworkHandler

public DataNetworkHandler(FtpConfiguration configuration,
                  DataBusinessHandler handler,
                  boolean active)

Constructor from DataBusinessHandler

Parameters:

configuration -

handler -

active -

Method Detail

getDataBusinessHandler

public DataBusinessHandler getDataBusinessHandler()
                                           throws FtpNoConnectionException

Returns:

the dataBusinessHandler

Throws:

FtpNoConnectionException

getFtpSession

public FtpSession getFtpSession()

Returns:

the session

getNetworkHandler

public NetworkHandler getNetworkHandler()

Returns:

the NetworkHandler associated with the control connection

channelInactive

public void channelInactive(io.netty.channel.ChannelHandlerContext ctx)
                     throws Exception

Run firstly executeChannelClosed.

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

setSession

protected void setSession(io.netty.channel.Channel channel)

channelActive

public void channelActive(io.netty.channel.ChannelHandlerContext ctx)
                   throws Exception

Initialize the Handler.

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

setCorrectCodec

public void setCorrectCodec()

Set the CODEC according to the mode. Must be called after each call of MODE, STRU or TYPE

unlockModeCodec

public void unlockModeCodec()

Unlock the Mode Codec from openConnection of FtpTransferControl

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
                   Throwable cause)
                     throws Exception

Default exception task: close the current connection after calling exceptionLocalCaught.

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

setFtpTransfer

public void setFtpTransfer(FtpTransfer ftpTransfer)

channelRead0

public void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
                org.waarp.common.file.DataBlock dataBlock)

Act as needed according to the receive DataBlock message

Specified by:

channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<org.waarp.common.file.DataBlock>

writeMessage

public boolean writeMessage(String message)

Write a simple message (like LIST) and wait for it

Parameters:

message -

Returns:

True if the message is correctly written