bgp/rib-impl/src/test/java/org/opendaylight/protocol/bgp/rib/impl/AbstractAddPathTest.java

   1 /*
   2  * Copyright (c) 2016 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.protocol.bgp.rib.impl;
   9
  10 import static org.mockito.Matchers.any;
  11 import static org.mockito.Mockito.doReturn;
  12 import static org.opendaylight.protocol.bgp.rib.spi.RouterIds.createPeerId;
  13
  14 import com.google.common.base.Optional;
  15 import com.google.common.collect.ImmutableList;
  16 import com.google.common.collect.Lists;
  17 import com.google.common.net.InetAddresses;
  18 import io.netty.bootstrap.Bootstrap;
  19 import io.netty.buffer.ByteBuf;
  20 import io.netty.buffer.ByteBufUtil;
  21 import io.netty.channel.Channel;
  22 import io.netty.channel.ChannelFuture;
  23 import io.netty.channel.ChannelHandlerContext;
  24 import io.netty.channel.ChannelInitializer;
  25 import io.netty.channel.ChannelOption;
  26 import io.netty.channel.SimpleChannelInboundHandler;
  27 import io.netty.channel.epoll.Epoll;
  28 import io.netty.channel.epoll.EpollEventLoopGroup;
  29 import io.netty.channel.nio.NioEventLoopGroup;
  30 import io.netty.channel.socket.SocketChannel;
  31 import io.netty.util.concurrent.DefaultPromise;
  32 import java.net.InetAddress;
  33 import java.net.InetSocketAddress;
  34 import java.util.Collections;
  35 import java.util.List;
  36 import java.util.concurrent.ExecutionException;
  37 import javassist.ClassPool;
  38 import org.junit.After;
  39 import org.junit.Assert;
  40 import org.junit.Before;
  41 import org.mockito.Mockito;
  42 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
  43 import org.opendaylight.controller.md.sal.binding.impl.BindingToNormalizedNodeCodec;
  44 import org.opendaylight.controller.md.sal.binding.test.AbstractDataBrokerTest;
  45 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  46 import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService;
  47 import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider;
  48 import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceRegistration;
  49 import org.opendaylight.protocol.bgp.inet.RIBActivator;
  50 import org.opendaylight.protocol.bgp.parser.impl.BGPActivator;
  51 import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionProviderContext;
  52 import org.opendaylight.protocol.bgp.parser.spi.pojo.SimpleBGPExtensionProviderContext;
  53 import org.opendaylight.protocol.bgp.rib.impl.spi.BGPPeerRegistry;
  54 import org.opendaylight.protocol.bgp.rib.impl.spi.BGPSessionPreferences;
  55 import org.opendaylight.protocol.bgp.rib.spi.BGPSessionListener;
  56 import org.opendaylight.protocol.bgp.rib.spi.RIBExtensionProviderContext;
  57 import org.opendaylight.protocol.bgp.rib.spi.SimpleRIBExtensionProviderContext;
  58 import org.opendaylight.protocol.concepts.KeyMapping;
  59 import org.opendaylight.protocol.util.InetSocketAddressUtil;
  60 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber;
  61 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
  62 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
  63 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Prefix;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev150305.bgp.rib.rib.loc.rib.tables.routes.Ipv4RoutesCase;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev150305.ipv4.prefixes.DestinationIpv4Builder;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev150305.ipv4.prefixes.destination.ipv4.Ipv4PrefixesBuilder;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev150305.ipv4.routes.ipv4.routes.Ipv4Route;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev150305.update.attributes.mp.reach.nlri.advertized.routes.destination.type.DestinationIpv4Case;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev150305.update.attributes.mp.reach.nlri.advertized.routes.destination.type.DestinationIpv4CaseBuilder;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.PathId;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.Update;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.UpdateBuilder;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.message.BgpParameters;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.message.BgpParametersBuilder;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.message.bgp.parameters.OptionalCapabilities;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.message.bgp.parameters.OptionalCapabilitiesBuilder;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.message.bgp.parameters.optional.capabilities.CParametersBuilder;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.AttributesBuilder;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.AsPathBuilder;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.ClusterIdBuilder;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.LocalPrefBuilder;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.OriginBuilder;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.OriginatorIdBuilder;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.Attributes1;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.Attributes1Builder;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.CParameters1;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.CParameters1Builder;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.SendReceive;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.mp.capabilities.AddPathCapabilityBuilder;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.mp.capabilities.MultiprotocolCapability;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.mp.capabilities.MultiprotocolCapabilityBuilder;
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.mp.capabilities.add.path.capability.AddressFamiliesBuilder;
  93 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.MpReachNlri;
  94 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.MpReachNlriBuilder;
  95 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.mp.reach.nlri.AdvertizedRoutes;
  96 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.mp.reach.nlri.AdvertizedRoutesBuilder;
  97 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.BgpRib;
  98 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.PeerId;
  99 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.PeerRole;
 100 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.bgp.rib.rib.Peer;
 101 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.BgpId;
 102 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.BgpOrigin;
 103 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.ClusterIdentifier;
 104 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.Ipv4AddressFamily;
 105 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.UnicastSubsequentAddressFamily;
 106 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.next.hop.c.next.hop.Ipv4NextHopCaseBuilder;
 107 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.next.hop.c.next.hop.ipv4.next.hop._case.Ipv4NextHopBuilder;
 108 import org.opendaylight.yangtools.binding.data.codec.gen.impl.StreamWriterGenerator;
 109 import org.opendaylight.yangtools.binding.data.codec.impl.BindingNormalizedNodeCodecRegistry;
 110 import org.opendaylight.yangtools.sal.binding.generator.impl.GeneratedClassLoadingStrategy;
 111 import org.opendaylight.yangtools.sal.binding.generator.impl.ModuleInfoBackedContext;
 112 import org.opendaylight.yangtools.sal.binding.generator.util.JavassistUtils;
 113 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 114 import org.opendaylight.yangtools.yang.binding.util.BindingReflections;
 115 import org.opendaylight.yangtools.yang.model.api.SchemaContext;
 116
 117 public class AbstractAddPathTest extends AbstractDataBrokerTest {
 118
 119     protected static final String RIB_ID = "127.0.0.1";
 120     private static final ClusterIdentifier CLUSTER_ID = new ClusterIdentifier(RIB_ID);
 121     protected static final Ipv4Address PEER1 = new Ipv4Address("127.0.0.2");
 122     protected static final Ipv4Address PEER2 = new Ipv4Address("127.0.0.3");
 123     protected static final Ipv4Address PEER3 = new Ipv4Address("127.0.0.4");
 124     protected static final Ipv4Address PEER4 = new Ipv4Address("127.0.0.5");
 125     protected static final Ipv4Address PEER5 = new Ipv4Address("127.0.0.6");
 126
 127     protected static final PeerId PEER1_ID = createPeerId(PEER1);
 128     protected static final PeerId PEER2_ID = createPeerId(PEER2);
 129     protected static final PeerId PEER3_ID = createPeerId(PEER3);
 130     protected static final PeerId PEER4_ID = createPeerId(PEER4);
 131     protected static final PeerId PEER5_ID = createPeerId(PEER5);
 132
 133     protected static final AsNumber AS_NUMBER = new AsNumber(72L);
 134     protected static final int HOLDTIMER = 180;
 135
 136     protected static final int PORT = InetSocketAddressUtil.getRandomPort();
 137
 138     protected static final Ipv4Prefix PREFIX1 = new Ipv4Prefix("1.1.1.1/32");
 139     protected static final Ipv4Address NH1 = new Ipv4Address("2.2.2.2");
 140     protected static final Update UPD_100 = createSimpleUpdate(PREFIX1, new PathId(1l), CLUSTER_ID, 100);
 141     protected static final Update UPD_50 = createSimpleUpdate(PREFIX1, new PathId(2l), CLUSTER_ID, 50);
 142     protected static final Update UPD_200 = createSimpleUpdate(PREFIX1, new PathId(3l), CLUSTER_ID, 200);
 143     protected static final Update UPD_20 = createSimpleUpdate(PREFIX1, new PathId(1l), CLUSTER_ID, 20);
 144
 145     protected BindingToNormalizedNodeCodec mappingService;
 146     protected BGPDispatcherImpl dispatcher;
 147     protected RIBExtensionProviderContext ribExtension;
 148     protected BGPExtensionProviderContext context;
 149     protected SchemaContext schemaContext;
 150     private RIBActivator ribActivator;
 151     private BGPActivator bgpActivator;
 152     private NioEventLoopGroup worker;
 153     private NioEventLoopGroup boss;
 154     protected ClusterSingletonServiceProvider clusterSingletonServiceProvider;
 155     private org.opendaylight.protocol.bgp.inet.BGPActivator inetActivator;
 156
 157     @Before
 158     public void setUp() throws Exception {
 159         this.ribActivator = new RIBActivator();
 160         this.ribExtension = new SimpleRIBExtensionProviderContext();
 161
 162         this.ribActivator.startRIBExtensionProvider(this.ribExtension);
 163
 164         this.bgpActivator = new BGPActivator();
 165         this.inetActivator = new org.opendaylight.protocol.bgp.inet.BGPActivator();
 166         this.context = new SimpleBGPExtensionProviderContext();
 167         this.bgpActivator.start(this.context);
 168         this.inetActivator.start(this.context);
 169
 170         this.mappingService = new BindingToNormalizedNodeCodec(GeneratedClassLoadingStrategy.getTCCLClassLoadingStrategy(),
 171                 new BindingNormalizedNodeCodecRegistry(StreamWriterGenerator.create(JavassistUtils.forClassPool(ClassPool.getDefault()))));
 172         final ModuleInfoBackedContext moduleInfoBackedContext = ModuleInfoBackedContext.create();
 173         moduleInfoBackedContext.registerModuleInfo(BindingReflections.getModuleInfo(BgpParameters.class));
 174         moduleInfoBackedContext.registerModuleInfo(BindingReflections.getModuleInfo(MultiprotocolCapability.class));
 175         moduleInfoBackedContext.registerModuleInfo(BindingReflections.getModuleInfo(DestinationIpv4Case.class));
 176         moduleInfoBackedContext.registerModuleInfo(BindingReflections.getModuleInfo(AdvertizedRoutes.class));
 177         moduleInfoBackedContext.registerModuleInfo(BindingReflections.getModuleInfo(BgpRib.class));
 178         moduleInfoBackedContext.registerModuleInfo(BindingReflections.getModuleInfo(Attributes1.class));
 179         moduleInfoBackedContext.registerModuleInfo(BindingReflections.getModuleInfo(MpReachNlri.class));
 180         this.mappingService.onGlobalContextUpdated(moduleInfoBackedContext.tryToCreateSchemaContext().get());
 181         this.schemaContext = moduleInfoBackedContext.getSchemaContext();
 182
 183         this.worker = new NioEventLoopGroup();
 184         this.boss = new NioEventLoopGroup();
 185         this.dispatcher = new BGPDispatcherImpl(this.context.getMessageRegistry(), this.boss, this.worker);
 186
 187         this.clusterSingletonServiceProvider = Mockito.mock(ClusterSingletonServiceProvider.class);
 188         doReturn(Mockito.mock(ClusterSingletonServiceRegistration.class)).when(this.clusterSingletonServiceProvider).registerClusterSingletonService(any(ClusterSingletonService.class));
 189     }
 190
 191     @After
 192     public void tearDown() {
 193         this.dispatcher.close();
 194         this.worker.shutdownGracefully().awaitUninterruptibly();
 195         this.boss.shutdownGracefully().awaitUninterruptibly();
 196         this.mappingService.close();
 197         this.ribActivator.close();
 198         this.inetActivator.close();
 199         this.bgpActivator.close();
 200     }
 201
 202     void checkRibOut(final int nAddPathRoutesExpected) throws ExecutionException, InterruptedException {
 203         final ReadOnlyTransaction rTx = getDataBroker().newReadOnlyTransaction();
 204         final BgpRib bgpRib = rTx.read(LogicalDatastoreType.OPERATIONAL, InstanceIdentifier.create(BgpRib.class)).get().get();
 205         rTx.close();
 206
 207         //check peer's rib-out
 208         for (final Peer peer : bgpRib.getRib().get(0).getPeer()) {
 209             final int ribOut = getPeerRibOutSize(peer);
 210             if (peer.getPeerId().equals(PEER1_ID)) {
 211                 Assert.assertEquals(0, ribOut);
 212             } else if (peer.getPeerId().equals(PEER2_ID)) {
 213                 Assert.assertEquals(0, ribOut);
 214             } else if (peer.getPeerId().equals(PEER3_ID)) {
 215                 Assert.assertEquals(0, ribOut);
 216             } else if (peer.getPeerId().equals(PEER4_ID)) {
 217                 Assert.assertEquals(1, ribOut);
 218             } else if (peer.getPeerId().equals(PEER5_ID)) {
 219                 Assert.assertEquals(nAddPathRoutesExpected, ribOut);
 220             } else {
 221                 Assert.fail("Failed to verify " + peer);
 222             }
 223         }
 224     }
 225
 226     void sendRouteAndCheckIsOnDS(final Channel session, final Ipv4Prefix prefix, final long localPreference, final int expectedRoutesOnDS)
 227             throws InterruptedException, ExecutionException {
 228         session.writeAndFlush(createSimpleUpdate(prefix, null, null, localPreference));
 229         Thread.sleep(2000);
 230
 231         final ReadOnlyTransaction rTx = getDataBroker().newReadOnlyTransaction();
 232         final BgpRib bgpRib = rTx.read(LogicalDatastoreType.OPERATIONAL, InstanceIdentifier.create(BgpRib.class)).get().get();
 233         rTx.close();
 234         final Ipv4RoutesCase routes = ((Ipv4RoutesCase) bgpRib.getRib().get(0).getLocRib().getTables().get(0).getRoutes());
 235         final List<Ipv4Route> routeList = routes.getIpv4Routes().getIpv4Route();
 236         Assert.assertEquals(expectedRoutesOnDS, routeList.size());
 237     }
 238
 239     void checkPeersPresentOnDataStore(final int numberOfPeers) throws ExecutionException, InterruptedException {
 240         Thread.sleep(1000);
 241         final ReadOnlyTransaction rTx = getDataBroker().newReadOnlyTransaction();
 242         final BgpRib bgpRib = rTx.read(LogicalDatastoreType.OPERATIONAL, InstanceIdentifier.create(BgpRib.class)).get().get();
 243         rTx.close();
 244
 245         //check 5 peers present in the DS
 246         Assert.assertEquals(numberOfPeers, bgpRib.getRib().get(0).getPeer().size());
 247     }
 248
 249     Channel createPeerSession(final Ipv4Address peer, final PeerRole peerRole, final BgpParameters nonAddPathParams, final RIBImpl ribImpl,
 250             final BGPHandlerFactory hf, final SimpleSessionListener sessionListsner) throws InterruptedException, ExecutionException {
 251         configurePeer(peer, ribImpl, nonAddPathParams, peerRole);
 252         return connectPeer(peer, ribImpl, nonAddPathParams, this.dispatcher, hf, sessionListsner);
 253     }
 254
 255     private static int getPeerRibOutSize(final Peer peer) {
 256         return ((org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev150305.bgp.rib.rib.peer.adj.rib.out.tables.routes.Ipv4RoutesCase) peer.getAdjRibOut().getTables().get(0).getRoutes()).getIpv4Routes().getIpv4Route().size();
 257     }
 258
 259     private static ChannelFuture createClient(final BGPDispatcherImpl dispatcher, final InetSocketAddress remoteAddress,
 260             final BGPPeerRegistry registry, final InetSocketAddress localAddress, final BGPHandlerFactory hf) throws InterruptedException {
 261         final BGPClientSessionNegotiatorFactory snf = new BGPClientSessionNegotiatorFactory(registry);
 262
 263         final Bootstrap bootstrap = dispatcher.createClientBootStrap(Optional.<KeyMapping>absent(), Epoll.isAvailable() ? new EpollEventLoopGroup() : new NioEventLoopGroup());
 264         bootstrap.localAddress(localAddress);
 265         bootstrap.option(ChannelOption.SO_REUSEADDR, true);
 266         bootstrap.handler(new ChannelInitializer<SocketChannel>() {
 267             @Override
 268             protected void initChannel(final SocketChannel ch) throws Exception {
 269                 ch.pipeline().addLast(hf.getDecoders());
 270                 ch.pipeline().addLast("negotiator", snf.getSessionNegotiator(ch, new DefaultPromise<BGPSessionImpl>(ch.eventLoop())));
 271                 ch.pipeline().addLast(hf.getEncoders());
 272             }
 273         });
 274         return bootstrap.connect(remoteAddress).sync();
 275     }
 276
 277     private static void configurePeer(final Ipv4Address localAddress, final RIBImpl ribImpl, final BgpParameters bgpParameters, final PeerRole peerRole) {
 278         final InetAddress inetAddress = InetAddresses.forString(localAddress.getValue());
 279
 280         final BGPPeer bgpPeer = new BGPPeer(inetAddress.getHostAddress(), ribImpl, peerRole, null);
 281         final List<BgpParameters> tlvs = Lists.newArrayList(bgpParameters);
 282         StrictBGPPeerRegistry.GLOBAL.addPeer(new IpAddress(new Ipv4Address(inetAddress.getHostAddress())), bgpPeer,
 283                 new BGPSessionPreferences(AS_NUMBER, HOLDTIMER, new BgpId(RIB_ID),
 284                         AS_NUMBER,  tlvs, Optional.<byte[]>absent()));
 285         bgpPeer.instantiateServiceInstance();
 286     }
 287
 288     private static Channel connectPeer(final Ipv4Address localAddress, final RIBImpl ribImpl, final BgpParameters bgpParameters,
 289             final BGPDispatcherImpl dispatcherImpl, final BGPHandlerFactory hf, final BGPSessionListener sessionListsner) throws InterruptedException, ExecutionException {
 290         final BGPPeerRegistry peerRegistry = new StrictBGPPeerRegistry();
 291         peerRegistry.addPeer(new IpAddress(new Ipv4Address(RIB_ID)), sessionListsner,
 292                 new BGPSessionPreferences(AS_NUMBER, HOLDTIMER, new BgpId(localAddress),
 293                         AS_NUMBER, Lists.newArrayList(bgpParameters),Optional.<byte[]>absent()));
 294
 295         final ChannelFuture createClient = createClient(dispatcherImpl, new InetSocketAddress(RIB_ID, PORT), peerRegistry, new InetSocketAddress(localAddress.getValue(), PORT), hf);
 296         Thread.sleep(1000);
 297         return createClient.channel();
 298     }
 299
 300     protected static BgpParameters createParameter(final boolean addPath) {
 301         final OptionalCapabilities mp = new OptionalCapabilitiesBuilder().setCParameters(
 302                 new CParametersBuilder().addAugmentation(CParameters1.class,
 303                         new CParameters1Builder().setMultiprotocolCapability(
 304                                 new MultiprotocolCapabilityBuilder().setAfi(Ipv4AddressFamily.class).setSafi(UnicastSubsequentAddressFamily.class)
 305                                 .build()).build()).build()).build();
 306         final List<OptionalCapabilities> capabilities = Lists.newArrayList(mp);
 307         if (addPath) {
 308             final OptionalCapabilities addPathCapa = new OptionalCapabilitiesBuilder().setCParameters(
 309                     new CParametersBuilder().addAugmentation(CParameters1.class,
 310                             new CParameters1Builder().setAddPathCapability(
 311                                     new AddPathCapabilityBuilder().setAddressFamilies(Lists.newArrayList(
 312                                             new AddressFamiliesBuilder()
 313                                             .setAfi(Ipv4AddressFamily.class)
 314                                             .setSafi(UnicastSubsequentAddressFamily.class)
 315                                             .setSendReceive(SendReceive.Both)
 316                                             .build()))
 317                                             .build()).build()).build()).build();
 318             capabilities.add(addPathCapa);
 319         }
 320         return new BgpParametersBuilder().setOptionalCapabilities(capabilities).build();
 321     }
 322
 323     private static Update createSimpleUpdate(final Ipv4Prefix prefix, final PathId pathId, final ClusterIdentifier clusterId,
 324             final long localPreference) {
 325      final AttributesBuilder attBuilder = new AttributesBuilder();
 326         attBuilder.setLocalPref(new LocalPrefBuilder().setPref(localPreference).build());
 327         attBuilder.setOrigin(new OriginBuilder().setValue(BgpOrigin.Igp).build());
 328         attBuilder.setAsPath(new AsPathBuilder().setSegments(Collections.emptyList()).build());
 329         if (clusterId != null) {
 330             attBuilder.setClusterId(new ClusterIdBuilder().setCluster(Collections.singletonList(clusterId)).build());
 331             attBuilder.setOriginatorId(new OriginatorIdBuilder().setOriginator(new Ipv4Address(clusterId)).build());
 332         }
 333         attBuilder.setUnrecognizedAttributes(Collections.emptyList());
 334         attBuilder.addAugmentation(Attributes1.class,
 335                 new Attributes1Builder().setMpReachNlri(
 336                         new MpReachNlriBuilder()
 337                         .setCNextHop(new Ipv4NextHopCaseBuilder().setIpv4NextHop(new Ipv4NextHopBuilder().setGlobal(NH1).build()).build())
 338                         .setAfi(Ipv4AddressFamily.class)
 339                         .setSafi(UnicastSubsequentAddressFamily.class)
 340                         .setAdvertizedRoutes(new AdvertizedRoutesBuilder().setDestinationType(
 341                                 new DestinationIpv4CaseBuilder().setDestinationIpv4(
 342                                         new DestinationIpv4Builder().setIpv4Prefixes(Collections.singletonList(
 343                                                 new Ipv4PrefixesBuilder().setPathId(pathId).setPrefix(new Ipv4Prefix(prefix)).build())).build())
 344                                                 .build()).build())
 345                                                 .build()).build());
 346         return new UpdateBuilder().setAttributes(attBuilder.build()).build();
 347     }
 348 }