org.opendaylight.protocol.bgp.rib.impl

Class BGPDispatcherImpl

java.lang.Object

org.opendaylight.protocol.bgp.rib.impl.BGPDispatcherImpl

All Implemented Interfaces:

AutoCloseable, BGPDispatcher

public class BGPDispatcherImpl
extends Object
implements BGPDispatcher, AutoCloseable

Implementation of BGPDispatcher.

Constructor Summary

Constructors

Constructor and Description
BGPDispatcherImpl(MessageRegistry messageRegistry, io.netty.channel.EventLoopGroup bossGroup, io.netty.channel.EventLoopGroup workerGroup, BGPPeerRegistry bgpPeerRegistry)

Method Summary

Modifier and Type	Method and Description
void	close()
io.netty.util.concurrent.Future<BGPSessionImpl>	createClient(InetSocketAddress localAddress, InetSocketAddress remoteAddress, int retryTimer, boolean reuseAddress)
io.netty.util.concurrent.Future<BGPSessionImpl>	createClient(InetSocketAddress remoteAddress, int retryTimer) Creates BGP client.
io.netty.util.concurrent.Future<Void>	createReconnectingClient(InetSocketAddress remoteAddress, int retryTimer, KeyMapping keys) Creates Reconnecting client.
io.netty.channel.ChannelFuture	createServer(InetSocketAddress serverAddress) Create new BGP server to accept incoming bgp connections (bound to provided socket localAddress).
BGPPeerRegistry	getBGPPeerRegistry() Return BGP Peer Registry

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opendaylight.protocol.bgp.rib.impl.spi.BGPDispatcher

createReconnectingClient

Constructor Detail

BGPDispatcherImpl

public BGPDispatcherImpl(MessageRegistry messageRegistry,
                         io.netty.channel.EventLoopGroup bossGroup,
                         io.netty.channel.EventLoopGroup workerGroup,
                         BGPPeerRegistry bgpPeerRegistry)

Method Detail

createClient

public io.netty.util.concurrent.Future<BGPSessionImpl> createClient(InetSocketAddress remoteAddress,
                                                                    int retryTimer)

Description copied from interface: BGPDispatcher

Creates BGP client.

Specified by:

createClient in interface BGPDispatcher

Parameters:

remoteAddress - remote Peer address

retryTimer - Retry timer

Returns:

Future promising a client session

createClient

public io.netty.util.concurrent.Future<BGPSessionImpl> createClient(InetSocketAddress localAddress,
                                                                    InetSocketAddress remoteAddress,
                                                                    int retryTimer,
                                                                    boolean reuseAddress)

close

public void close()
           throws InterruptedException

Specified by:

close in interface AutoCloseable

Throws:

InterruptedException

createReconnectingClient

public io.netty.util.concurrent.Future<Void> createReconnectingClient(InetSocketAddress remoteAddress,
                                                                      int retryTimer,
                                                                      KeyMapping keys)

Description copied from interface: BGPDispatcher

Creates Reconnecting client.

Specified by:

createReconnectingClient in interface BGPDispatcher

Parameters:

remoteAddress - remote Peer Address

retryTimer - Retry timer

keys - for TCPMD5

Returns:

Future promising a client session

createServer

public io.netty.channel.ChannelFuture createServer(InetSocketAddress serverAddress)

Description copied from interface: BGPDispatcher

Create new BGP server to accept incoming bgp connections (bound to provided socket localAddress).

Specified by:

createServer in interface BGPDispatcher

Parameters:

serverAddress - Peer localAddress

Returns:

ChannelFuture promising a client session

getBGPPeerRegistry

public BGPPeerRegistry getBGPPeerRegistry()

Description copied from interface: BGPDispatcher

Return BGP Peer Registry

Specified by:

getBGPPeerRegistry in interface BGPDispatcher

Returns:

BGPPeerRegistry