org.opendaylight.protocol.bgp.rib.impl

Class BGPSessionImpl

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<org.opendaylight.yangtools.yang.binding.Notification>

org.opendaylight.protocol.bgp.rib.impl.BGPSessionImpl

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, AutoCloseable, BGPSessionStateProvider, BGPSession

public class BGPSessionImpl
extends io.netty.channel.SimpleChannelInboundHandler<org.opendaylight.yangtools.yang.binding.Notification>
implements BGPSession, BGPSessionStateProvider, AutoCloseable

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
BGPSessionImpl(BGPSessionListener listener, io.netty.channel.Channel channel, Open remoteOpen, BGPSessionPreferences localPreferences, BGPPeerRegistry peerRegistry)
BGPSessionImpl(BGPSessionListener listener, io.netty.channel.Channel channel, Open remoteOpen, int localHoldTimer, BGPPeerRegistry peerRegistry)

Method Summary

Modifier and Type	Method and Description
protected com.google.common.base.MoreObjects.ToStringHelper	addToStringAttributes(com.google.common.base.MoreObjects.ToStringHelper toStringHelper)
void	channelInactive(io.netty.channel.ChannelHandlerContext ctx)
protected void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, org.opendaylight.yangtools.yang.binding.Notification msg)
void	close()
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
List<AddressFamilies>	getAdvertisedAddPathTableTypes() Return a list with Add Path tables supported advertised and corresponding SendReceive mode.
List<BgpTableType>	getAdvertisedGracefulRestartTableTypes() Return the list of tables which the peer has advertised to support.
Set<BgpTableType>	getAdvertisedTableTypes() Return the list of tables which the peer has advertised to support.
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber	getAsNumber() Return the AS number which the peer advertises.
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address	getBgpId() Return the BGP router ID advertised by the peer.
BGPSessionState	getBGPSessionState() BGP Operational Session State.
BGPTimersState	getBGPTimersState() BGP Operational Timers State.
BGPTransportState	getBGPTransportState() BGP Operational Transport State.
ChannelOutputLimiter	getLimiter()
State	getState()
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
void	registerMessagesCounter(BGPMessagesListener bgpMessagesListener) Register BGP Operational Messages State Listener.
void	setChannelExtMsgCoder(Open remoteOpen) Set the extend message coder for current channel The reason for separating this part from constructor is, in #channel.pipeline().replace(..), the invokeChannelRead() will be invoked after the original message coder handler got removed.
String	toString()

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.netty.channel.ChannelInboundHandler

channelActive, channelRead, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from interface io.netty.channel.ChannelHandler

handlerRemoved

Constructor Detail

BGPSessionImpl

public BGPSessionImpl(BGPSessionListener listener,
                      io.netty.channel.Channel channel,
                      Open remoteOpen,
                      BGPSessionPreferences localPreferences,
                      BGPPeerRegistry peerRegistry)

BGPSessionImpl

public BGPSessionImpl(BGPSessionListener listener,
                      io.netty.channel.Channel channel,
                      Open remoteOpen,
                      int localHoldTimer,
                      BGPPeerRegistry peerRegistry)

Method Detail

setChannelExtMsgCoder

public void setChannelExtMsgCoder(Open remoteOpen)

Set the extend message coder for current channel The reason for separating this part from constructor is, in #channel.pipeline().replace(..), the invokeChannelRead() will be invoked after the original message coder handler got removed. And there is chance that before the session instance is fully initiated (constructor returns), a KeepAlive message arrived already in the channel buffer. Thus #AbstractBGPSessionNegotiator.handleMessage(..) gets invoked again and a deadlock is caused. A BGP final state machine error will happen as BGP negotiator is still in OPEN_SENT state as the session constructor hasn't returned yet.

Parameters:

remoteOpen -

close

public void close()

Specified by:

close in interface AutoCloseable

toString

public final String toString()

Overrides:

toString in class Object

addToStringAttributes

protected com.google.common.base.MoreObjects.ToStringHelper addToStringAttributes(com.google.common.base.MoreObjects.ToStringHelper toStringHelper)

getAdvertisedTableTypes

public Set<BgpTableType> getAdvertisedTableTypes()

Description copied from interface: BGPSession

Return the list of tables which the peer has advertised to support.

Specified by:

getAdvertisedTableTypes in interface BGPSession

Returns:

Set of tables which it supports.

getAdvertisedAddPathTableTypes

public List<AddressFamilies> getAdvertisedAddPathTableTypes()

Description copied from interface: BGPSession

Return a list with Add Path tables supported advertised and corresponding SendReceive mode.

Specified by:

getAdvertisedAddPathTableTypes in interface BGPSession

Returns:

AddPathTables supported

getAdvertisedGracefulRestartTableTypes

public List<BgpTableType> getAdvertisedGracefulRestartTableTypes()

Description copied from interface: BGPSession

Return the list of tables which the peer has advertised to support. Graceful Restart.

Specified by:

getAdvertisedGracefulRestartTableTypes in interface BGPSession

Returns:

Set of tables which it supports.

getState

public State getState()

getBgpId

public final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address getBgpId()

Description copied from interface: BGPSession

Return the BGP router ID advertised by the peer.

Specified by:

getBgpId in interface BGPSession

Returns:

Peer's BGP Router ID.

getAsNumber

public final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber getAsNumber()

Description copied from interface: BGPSession

Return the AS number which the peer advertises.

Specified by:

getAsNumber in interface BGPSession

Returns:

Peer's AS Number

getLimiter

public ChannelOutputLimiter getLimiter()

channelInactive

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

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter

channelRead0

protected final void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
                                  org.opendaylight.yangtools.yang.binding.Notification msg)

Specified by:

channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<org.opendaylight.yangtools.yang.binding.Notification>

handlerAdded

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

Specified by:

handlerAdded in interface io.netty.channel.ChannelHandler

Overrides:

handlerAdded in class io.netty.channel.ChannelHandlerAdapter

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

getBGPSessionState

public BGPSessionState getBGPSessionState()

Description copied from interface: BGPSessionStateProvider

BGP Operational Session State.

Specified by:

getBGPSessionState in interface BGPSessionStateProvider

Returns:

BGPSessionState

getBGPTimersState

public BGPTimersState getBGPTimersState()

Description copied from interface: BGPSessionStateProvider

BGP Operational Timers State.

Specified by:

getBGPTimersState in interface BGPSessionStateProvider

Returns:

BGPTimersState

getBGPTransportState

public BGPTransportState getBGPTransportState()

Description copied from interface: BGPSessionStateProvider

BGP Operational Transport State.

Specified by:

getBGPTransportState in interface BGPSessionStateProvider

Returns:

BGPTransportState

registerMessagesCounter

public void registerMessagesCounter(BGPMessagesListener bgpMessagesListener)

Description copied from interface: BGPSessionStateProvider

Register BGP Operational Messages State Listener.

Specified by:

registerMessagesCounter in interface BGPSessionStateProvider

Parameters:

bgpMessagesListener - BGPMessagesListener