Package org.opendaylight.protocol.pcep.impl

Class AbstractSessionNegotiator

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.opendaylight.protocol.pcep.impl.AbstractSessionNegotiator

All Implemented Interfaces:

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

Direct Known Subclasses:

AbstractPCEPSessionNegotiator, PCEPSessionNegotiator

public abstract class AbstractSessionNegotiator
extends io.netty.channel.ChannelInboundHandlerAdapter
implements SessionNegotiator

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	Description
protected io.netty.channel.Channel	channel
protected io.netty.util.concurrent.Promise<PCEPSessionImpl>	promise

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractSessionNegotiator(io.netty.util.concurrent.Promise<PCEPSessionImpl> promise, io.netty.channel.Channel channel)

Method Summary

Modifier and Type	Method	Description
void	channelActive(io.netty.channel.ChannelHandlerContext ctx)
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
protected abstract void	handleMessage(Message msg)
protected void	negotiationFailed(Throwable cause)
protected void	negotiationSuccessful(PCEPSessionImpl session)
protected void	sendMessage(Message msg)
protected abstract void	startNegotiation()

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

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

Methods inherited from interface io.netty.channel.ChannelInboundHandler

channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Field Detail

channel

protected final io.netty.channel.Channel channel

promise

protected final io.netty.util.concurrent.Promise<PCEPSessionImpl> promise

Constructor Detail

AbstractSessionNegotiator

protected AbstractSessionNegotiator(io.netty.util.concurrent.Promise<PCEPSessionImpl> promise,
                                    io.netty.channel.Channel channel)

Method Detail

negotiationSuccessful

protected final void negotiationSuccessful(PCEPSessionImpl session)

negotiationFailed

protected void negotiationFailed(Throwable cause)

sendMessage

protected final void sendMessage(Message msg)

channelActive

public final void channelActive(io.netty.channel.ChannelHandlerContext ctx)

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

channelRead

public final void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                              Object msg)

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

exceptionCaught

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

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

startNegotiation

protected abstract void startNegotiation()
                                  throws ExecutionException

Throws:

ExecutionException

handleMessage

protected abstract void handleMessage(Message msg)