org.waarp.ftp.core.control

Class NetworkHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<String>

org.waarp.ftp.core.control.NetworkHandler

All Implemented Interfaces:

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

Direct Known Subclasses:

SslNetworkHandler

public class NetworkHandler
extends io.netty.channel.SimpleChannelInboundHandler<String>

Main Network Handler (Control part) implementing RFC 959, 775, 2389, 2428, 3659 and supports XCRC and XMD5 commands.

Author:

Frederic Bregier

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
NetworkHandler(FtpSession session) Constructor from session

Method Summary

Methods

Modifier and Type	Method and Description
protected void	callForSnmp(String error1, String error2) To be extended to inform of an error to SNMP support
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, String e) Simply call messageRun with the received message
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause) Default exception task: close the current connection after calling exceptionLocalCaught and writing if possible the current replyCode.
BusinessHandler	getBusinessHandler()
io.netty.channel.Channel	getControlChannel()
FtpSession	getFtpSession()
io.netty.channel.ChannelFuture	writeIntermediateAnswer() Write an intermediate Answer from Business before last answer also set by the Business
io.netty.channel.ChannelFuture	writeIntermediateAnswer(io.netty.channel.ChannelHandlerContext ctx) Write an intermediate Answer from Business before last answer also set by the Business

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

Constructor Detail

NetworkHandler

public NetworkHandler(FtpSession session)

Constructor from session

Parameters:

session -

Method Detail

getBusinessHandler

public BusinessHandler getBusinessHandler()

Returns:

the businessHandler

getFtpSession

public FtpSession getFtpSession()

Returns:

the session

getControlChannel

public io.netty.channel.Channel getControlChannel()

Returns:

the Control Channel

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

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

exceptionCaught

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

Default exception task: close the current connection after calling exceptionLocalCaught and writing if possible the current replyCode.

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

channelRead0

public void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
                String e)

Simply call messageRun with the received message

Specified by:

channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<String>

writeIntermediateAnswer

public io.netty.channel.ChannelFuture writeIntermediateAnswer(io.netty.channel.ChannelHandlerContext ctx)

Write an intermediate Answer from Business before last answer also set by the Business

Returns:

the ChannelFuture associated with the write

writeIntermediateAnswer

public io.netty.channel.ChannelFuture writeIntermediateAnswer()

Write an intermediate Answer from Business before last answer also set by the Business

Returns:

the ChannelFuture associated with the write

callForSnmp

protected void callForSnmp(String error1,
               String error2)

To be extended to inform of an error to SNMP support

Parameters:

error1 -

error2 -