2 * Copyright (c) 2015 Cisco Systems, Inc. and others. All rights reserved.
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
8 package org.opendaylight.protocol.bmp.impl.app;
10 import static org.junit.Assert.assertEquals;
11 import static org.junit.Assert.assertFalse;
12 import static org.junit.Assert.assertNotNull;
13 import static org.junit.Assert.assertNull;
14 import static org.junit.Assert.assertTrue;
15 import static org.mockito.ArgumentMatchers.any;
16 import static org.mockito.Mockito.doAnswer;
17 import static org.opendaylight.protocol.bmp.parser.message.TestUtil.createRouteMonMsgWithEndOfRibMarker;
18 import static org.opendaylight.protocol.bmp.parser.message.TestUtil.createRouteMonitMsg;
19 import static org.opendaylight.protocol.util.CheckTestUtil.checkNotPresentOperational;
20 import static org.opendaylight.protocol.util.CheckTestUtil.readDataOperational;
22 import com.google.common.net.InetAddresses;
23 import io.netty.bootstrap.Bootstrap;
24 import io.netty.channel.Channel;
25 import io.netty.channel.ChannelFuture;
26 import io.netty.channel.ChannelInitializer;
27 import io.netty.channel.ChannelOption;
28 import io.netty.channel.EventLoopGroup;
29 import io.netty.channel.epoll.Epoll;
30 import io.netty.channel.epoll.EpollEventLoopGroup;
31 import io.netty.channel.epoll.EpollSocketChannel;
32 import io.netty.channel.nio.NioEventLoopGroup;
33 import io.netty.channel.socket.SocketChannel;
34 import io.netty.channel.socket.nio.NioSocketChannel;
35 import java.net.InetSocketAddress;
37 import java.util.concurrent.ExecutionException;
38 import org.junit.After;
39 import org.junit.Before;
40 import org.junit.Test;
41 import org.mockito.Mock;
42 import org.mockito.MockitoAnnotations;
43 import org.opendaylight.mdsal.binding.dom.adapter.AdapterContext;
44 import org.opendaylight.mdsal.binding.dom.adapter.test.AbstractConcurrentDataBrokerTest;
45 import org.opendaylight.mdsal.binding.dom.adapter.test.AbstractDataBrokerTestCustomizer;
46 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
47 import org.opendaylight.mdsal.dom.api.DOMDataTreeWriteTransaction;
48 import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService;
49 import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider;
50 import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceRegistration;
51 import org.opendaylight.protocol.bgp.inet.RIBActivator;
52 import org.opendaylight.protocol.bgp.parser.impl.BGPActivator;
53 import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionProviderContext;
54 import org.opendaylight.protocol.bgp.parser.spi.pojo.SimpleBGPExtensionProviderContext;
55 import org.opendaylight.protocol.bgp.rib.spi.RIBExtensionProviderContext;
56 import org.opendaylight.protocol.bgp.rib.spi.SimpleRIBExtensionProviderContext;
57 import org.opendaylight.protocol.bmp.api.BmpDispatcher;
58 import org.opendaylight.protocol.bmp.impl.BmpDispatcherImpl;
59 import org.opendaylight.protocol.bmp.impl.BmpHandlerFactory;
60 import org.opendaylight.protocol.bmp.impl.config.BmpDeployerDependencies;
61 import org.opendaylight.protocol.bmp.impl.session.DefaultBmpSessionFactory;
62 import org.opendaylight.protocol.bmp.impl.spi.BmpMonitoringStation;
63 import org.opendaylight.protocol.bmp.parser.BmpActivator;
64 import org.opendaylight.protocol.bmp.parser.message.TestUtil;
65 import org.opendaylight.protocol.bmp.spi.registry.BmpMessageRegistry;
66 import org.opendaylight.protocol.bmp.spi.registry.SimpleBmpExtensionProviderContext;
67 import org.opendaylight.protocol.util.CheckUtil;
68 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddressNoZone;
69 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4AddressNoZone;
70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev180329.bmp.monitor.monitor.router.peer.pre.policy.rib.tables.routes.Ipv4RoutesCase;
71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.PeerId;
72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.rib.Tables;
73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.Ipv4AddressFamily;
74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.UnicastSubsequentAddressFamily;
75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev200120.AdjRibInType;
76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev200120.PeerType;
77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev200120.RouteMirroringMessage;
78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev200120.StatsReportsMessage;
79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev200120.stat.Tlvs;
80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.BmpMonitor;
81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.MonitorId;
82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.RouterId;
83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.Status;
84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.bmp.monitor.Monitor;
85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.bmp.monitor.MonitorKey;
86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.peers.Peer;
87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.peers.PeerKey;
88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.peers.peer.Mirrors;
89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.peers.peer.PeerSession;
90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.peers.peer.PostPolicyRib;
91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.peers.peer.PrePolicyRib;
92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.peers.peer.Stats;
93 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.routers.Router;
94 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.rev200120.routers.RouterKey;
95 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
96 import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
97 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
98 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier;
99 import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
100 import org.opendaylight.yangtools.yang.data.impl.schema.Builders;
101 import org.opendaylight.yangtools.yang.data.impl.schema.ImmutableNodes;
103 public class BmpMonitorImplTest extends AbstractConcurrentDataBrokerTest {
104 // the local port and address where the monitor (ODL) will listen for incoming BMP request
105 private static final int MONITOR_LOCAL_PORT = 12345;
106 private static final String MONITOR_LOCAL_ADDRESS = "127.0.0.10";
107 private static final String MONITOR_LOCAL_ADDRESS_2 = "127.0.0.11";
108 // the router (monitee) address where we are going to simulate a BMP request from
109 private static final String REMOTE_ROUTER_ADDRESS_1 = "127.0.0.12";
110 private static final String REMOTE_ROUTER_ADDRESS_2 = "127.0.0.13";
111 private static final Ipv4AddressNoZone PEER1 = new Ipv4AddressNoZone("20.20.20.20");
112 private static final MonitorId MONITOR_ID = new MonitorId("monitor");
113 private static final KeyedInstanceIdentifier<Monitor, MonitorKey> MONITOR_IID = InstanceIdentifier
114 .create(BmpMonitor.class).child(Monitor.class, new MonitorKey(MONITOR_ID));
115 private static final PeerId PEER_ID = new PeerId(PEER1.getValue());
116 private static final InstanceIdentifier<BmpMonitor> BMP_II = InstanceIdentifier.create(BmpMonitor.class);
117 private AdapterContext mappingService;
118 private RIBActivator ribActivator;
119 private BGPActivator bgpActivator;
120 private BmpActivator bmpActivator;
121 private BmpDispatcher dispatcher;
122 private BmpMonitoringStation bmpApp;
123 private BmpMessageRegistry msgRegistry;
124 private RIBExtensionProviderContext ribExtension;
125 private ClusterSingletonService singletonService;
126 private ClusterSingletonService singletonService2;
128 private ClusterSingletonServiceRegistration singletonServiceRegistration;
130 private ClusterSingletonServiceRegistration singletonServiceRegistration2;
132 private ClusterSingletonServiceProvider clusterSSProv;
134 private ClusterSingletonServiceProvider clusterSSProv2;
137 public void setUp() throws Exception {
140 MockitoAnnotations.initMocks(this);
142 doAnswer(invocationOnMock -> {
143 BmpMonitorImplTest.this.singletonService = (ClusterSingletonService) invocationOnMock.getArguments()[0];
144 this.singletonService.instantiateServiceInstance();
145 return BmpMonitorImplTest.this.singletonServiceRegistration;
146 }).when(this.clusterSSProv).registerClusterSingletonService(any(ClusterSingletonService.class));
148 doAnswer(invocationOnMock -> BmpMonitorImplTest.this.singletonService.closeServiceInstance())
149 .when(this.singletonServiceRegistration).close();
151 doAnswer(invocationOnMock -> {
152 this.singletonService2 = (ClusterSingletonService) invocationOnMock.getArguments()[0];
153 this.singletonService2.instantiateServiceInstance();
154 return BmpMonitorImplTest.this.singletonServiceRegistration2;
155 }).when(this.clusterSSProv2).registerClusterSingletonService(any(ClusterSingletonService.class));
157 doAnswer(invocationOnMock -> BmpMonitorImplTest.this.singletonService2.closeServiceInstance())
158 .when(this.singletonServiceRegistration2).close();
160 this.ribActivator = new RIBActivator();
161 this.ribExtension = new SimpleRIBExtensionProviderContext();
162 this.ribActivator.startRIBExtensionProvider(this.ribExtension, this.mappingService.currentSerializer());
164 this.bgpActivator = new BGPActivator();
165 final BGPExtensionProviderContext context = new SimpleBGPExtensionProviderContext();
166 this.bgpActivator.start(context);
167 final SimpleBmpExtensionProviderContext ctx = new SimpleBmpExtensionProviderContext();
168 this.bmpActivator = new BmpActivator(context);
169 this.bmpActivator.start(ctx);
170 this.msgRegistry = ctx.getBmpMessageRegistry();
172 this.dispatcher = new BmpDispatcherImpl(new NioEventLoopGroup(), new NioEventLoopGroup(),
173 ctx.getBmpMessageRegistry(), new DefaultBmpSessionFactory());
175 final InetSocketAddress inetAddress = new InetSocketAddress(InetAddresses.forString(MONITOR_LOCAL_ADDRESS),
178 final DOMDataTreeWriteTransaction wTx = getDomBroker().newWriteOnlyTransaction();
179 final ContainerNode parentNode = Builders.containerBuilder().withNodeIdentifier(
180 new NodeIdentifier(BmpMonitor.QNAME))
181 .addChild(ImmutableNodes.mapNodeBuilder(Monitor.QNAME).build()).build();
182 wTx.merge(LogicalDatastoreType.OPERATIONAL, YangInstanceIdentifier.of(BmpMonitor.QNAME), parentNode);
185 final BmpDeployerDependencies bmpDependecies = new BmpDeployerDependencies(getDataBroker(), getDomBroker(),
186 this.ribExtension, this.mappingService.currentSerializer(), this.clusterSSProv);
187 this.bmpApp = new BmpMonitoringStationImpl(bmpDependecies, this.dispatcher, MONITOR_ID, inetAddress, null);
188 readDataOperational(getDataBroker(), BMP_II, monitor -> {
189 assertEquals(1, monitor.nonnullMonitor().size());
190 final Monitor bmpMonitor = monitor.getMonitor().values().iterator().next();
191 assertEquals(MONITOR_ID, bmpMonitor.getMonitorId());
192 assertEquals(0, bmpMonitor.nonnullRouter().size());
193 assertEquals(MONITOR_ID, bmpMonitor.getMonitorId());
194 assertEquals(0, bmpMonitor.nonnullRouter().size());
200 protected final AbstractDataBrokerTestCustomizer createDataBrokerTestCustomizer() {
201 final AbstractDataBrokerTestCustomizer customizer = super.createDataBrokerTestCustomizer();
202 this.mappingService = customizer.getAdapterContext();
207 public void tearDown() throws Exception {
208 this.ribActivator.close();
209 this.bgpActivator.close();
210 this.bmpActivator.close();
211 this.dispatcher.close();
214 checkNotPresentOperational(getDataBroker(), BMP_II);
217 @Test(timeout = 20000)
218 public void testRouterMonitoring() throws Exception {
219 // first test if a single router monitoring is working
220 final Channel channel1 = testMonitoringStation(REMOTE_ROUTER_ADDRESS_1);
221 readDataOperational(getDataBroker(), MONITOR_IID, monitor -> {
222 assertEquals(1, monitor.getRouter().size());
226 final Channel channel2 = testMonitoringStation(REMOTE_ROUTER_ADDRESS_2);
227 readDataOperational(getDataBroker(), MONITOR_IID, monitor -> {
228 assertEquals(2, monitor.getRouter().size());
232 // initiate another BMP request from router 1, create a redundant connection
233 // we expect the connection to be closed
234 final Channel channel3 = connectTestClient(REMOTE_ROUTER_ADDRESS_1, this.msgRegistry);
237 // channel 1 should still be open, while channel3 should be closed
238 CheckUtil.checkEquals(() -> assertTrue(channel1.isOpen()));
239 CheckUtil.checkEquals(() -> assertFalse(channel3.isOpen()));
241 // now if we close the channel 1 and try it again, it should succeed
242 channel1.close().sync();
244 // channel 2 is still open
245 readDataOperational(getDataBroker(), MONITOR_IID, monitor -> {
246 assertEquals(1, monitor.getRouter().size());
250 final Channel channel4 = testMonitoringStation(REMOTE_ROUTER_ADDRESS_1);
251 readDataOperational(getDataBroker(), MONITOR_IID, monitor -> {
252 assertEquals(2, monitor.getRouter().size());
256 // close all channel altogether
257 channel2.close().sync();
260 // sleep for a while to avoid intermittent InMemoryDataTree modification conflict
261 channel4.close().sync();
263 readDataOperational(getDataBroker(), MONITOR_IID, monitor -> {
264 assertNull(monitor.getRouter());
269 private static void waitWriteAndFlushSuccess(final ChannelFuture channelFuture) throws InterruptedException {
270 channelFuture.sync();
273 private Channel testMonitoringStation(final String remoteRouterIpAddr) throws InterruptedException,
275 final Channel channel = connectTestClient(remoteRouterIpAddr, this.msgRegistry);
276 final RouterId routerId = getRouterId(remoteRouterIpAddr);
278 readDataOperational(getDataBroker(), MONITOR_IID, monitor -> {
279 assertNotNull(monitor.getRouter());
280 // now find the current router instance
281 Router router = null;
282 for (final Router r : monitor.getRouter().values()) {
283 if (routerId.equals(r.getRouterId())) {
288 assertNotNull(router);
289 assertEquals(Status.Down, router.getStatus());
290 assertNull(router.getPeer());
294 waitWriteAndFlushSuccess(channel.writeAndFlush(TestUtil
295 .createInitMsg("description", "name", "some info")));
297 readDataOperational(getDataBroker(), MONITOR_IID, monitor -> {
298 assertNotNull(monitor.getRouter());
299 Router retRouter = null;
300 for (final Router r : monitor.getRouter().values()) {
301 if (routerId.equals(r.getRouterId())) {
307 assertEquals("some info;", retRouter.getInfo());
308 assertEquals("name", retRouter.getName());
309 assertEquals("description", retRouter.getDescription());
310 assertEquals(routerId, retRouter.getRouterId());
311 assertNull(retRouter.getPeer());
312 assertEquals(Status.Up, retRouter.getStatus());
316 waitWriteAndFlushSuccess(channel.writeAndFlush(TestUtil.createPeerUpNotification(PEER1, true)));
317 final KeyedInstanceIdentifier<Router, RouterKey> routerIId =
318 MONITOR_IID.child(Router.class, new RouterKey(routerId));
320 readDataOperational(getDataBroker(), routerIId, router -> {
321 final Map<PeerKey, Peer> peers = router.getPeer();
322 assertNotNull(peers);
323 assertEquals(1, peers.size());
324 final Peer peer = peers.values().iterator().next();
325 assertEquals(PeerType.Global, peer.getType());
326 assertEquals(PEER_ID, peer.getPeerId());
327 assertEquals(PEER1, peer.getBgpId());
328 assertEquals(TestUtil.IPV4_ADDRESS_10, peer.getAddress().getIpv4AddressNoZone());
329 assertEquals(TestUtil.PEER_AS, peer.getAs());
330 assertNull(peer.getPeerDistinguisher());
331 assertNull(peer.getStats());
333 assertNotNull(peer.getPrePolicyRib());
334 assertEquals(1, peer.getPrePolicyRib().nonnullTables().size());
335 final Tables prePolicyTable = peer.getPrePolicyRib().nonnullTables().values().iterator().next();
336 assertEquals(Ipv4AddressFamily.class, prePolicyTable.getAfi());
337 assertEquals(UnicastSubsequentAddressFamily.class, prePolicyTable.getSafi());
338 assertFalse(prePolicyTable.getAttributes().isUptodate());
340 assertNotNull(peer.getPostPolicyRib());
341 assertEquals(1, peer.getPostPolicyRib().nonnullTables().size());
342 final Tables postPolicyTable = peer.getPrePolicyRib().nonnullTables().values().iterator().next();
343 assertEquals(Ipv4AddressFamily.class, postPolicyTable.getAfi());
344 assertEquals(UnicastSubsequentAddressFamily.class, postPolicyTable.getSafi());
345 assertFalse(postPolicyTable.getAttributes().isUptodate());
347 assertNotNull(peer.getPeerSession());
348 final PeerSession peerSession = peer.getPeerSession();
349 assertEquals(TestUtil.IPV4_ADDRESS_10, peerSession.getLocalAddress().getIpv4AddressNoZone());
350 assertEquals(TestUtil.PEER_LOCAL_PORT, peerSession.getLocalPort());
351 assertEquals(TestUtil.PEER_REMOTE_PORT, peerSession.getRemotePort());
352 assertEquals(Status.Up, peerSession.getStatus());
353 assertNotNull(peerSession.getReceivedOpen());
354 assertNotNull(peerSession.getSentOpen());
359 final StatsReportsMessage statsMsg = TestUtil.createStatsReportMsg(PEER1);
360 waitWriteAndFlushSuccess(channel.writeAndFlush(statsMsg));
361 final KeyedInstanceIdentifier<Peer, PeerKey> peerIId = routerIId.child(Peer.class, new PeerKey(PEER_ID));
363 readDataOperational(getDataBroker(), peerIId.child(Stats.class), peerStats -> {
364 assertNotNull(peerStats.getTimestampSec());
365 final Tlvs tlvs = statsMsg.getTlvs();
366 assertEquals(tlvs.getAdjRibsInRoutesTlv().getCount(), peerStats.getAdjRibsInRoutes());
367 assertEquals(tlvs.getDuplicatePrefixAdvertisementsTlv().getCount(),
368 peerStats.getDuplicatePrefixAdvertisements());
369 assertEquals(tlvs.getDuplicateWithdrawsTlv().getCount(), peerStats.getDuplicateWithdraws());
370 assertEquals(tlvs.getInvalidatedAsConfedLoopTlv().getCount(), peerStats.getInvalidatedAsConfedLoop());
371 assertEquals(tlvs.getInvalidatedAsPathLoopTlv().getCount(), peerStats.getInvalidatedAsPathLoop());
372 assertEquals(tlvs.getInvalidatedClusterListLoopTlv().getCount(),
373 peerStats.getInvalidatedClusterListLoop());
374 assertEquals(tlvs.getInvalidatedOriginatorIdTlv().getCount(), peerStats.getInvalidatedOriginatorId());
375 assertEquals(tlvs.getLocRibRoutesTlv().getCount(), peerStats.getLocRibRoutes());
376 assertEquals(tlvs.getRejectedPrefixesTlv().getCount(), peerStats.getRejectedPrefixes());
377 assertEquals(tlvs.getPerAfiSafiAdjRibInTlv().getCount().toString(),
378 peerStats.getPerAfiSafiAdjRibInRoutes().getAfiSafi().values().iterator().next().getCount()
380 assertEquals(tlvs.getPerAfiSafiLocRibTlv().getCount().toString(),
381 peerStats.getPerAfiSafiLocRibRoutes().getAfiSafi().values().iterator().next().getCount()
386 // route mirror message test
387 final RouteMirroringMessage routeMirrorMsg = TestUtil.createRouteMirrorMsg(PEER1);
388 waitWriteAndFlushSuccess(channel.writeAndFlush(routeMirrorMsg));
390 readDataOperational(getDataBroker(), peerIId.child(Mirrors.class), routeMirrors -> {
391 assertNotNull(routeMirrors.getTimestampSec());
395 waitWriteAndFlushSuccess(channel.writeAndFlush(createRouteMonitMsg(false, PEER1,
396 AdjRibInType.PrePolicy)));
397 waitWriteAndFlushSuccess(channel.writeAndFlush(createRouteMonMsgWithEndOfRibMarker(PEER1,
398 AdjRibInType.PrePolicy)));
400 readDataOperational(getDataBroker(), peerIId.child(PrePolicyRib.class), prePolicyRib -> {
401 assertFalse(prePolicyRib.getTables().isEmpty());
402 final Tables tables = prePolicyRib.getTables().values().iterator().next();
403 assertTrue(tables.getAttributes().isUptodate());
404 assertEquals(3, ((Ipv4RoutesCase) tables.getRoutes()).getIpv4Routes().getIpv4Route().size());
408 waitWriteAndFlushSuccess(channel.writeAndFlush(createRouteMonitMsg(false, PEER1,
409 AdjRibInType.PostPolicy)));
410 waitWriteAndFlushSuccess(channel.writeAndFlush(createRouteMonMsgWithEndOfRibMarker(PEER1,
411 AdjRibInType.PostPolicy)));
413 readDataOperational(getDataBroker(), peerIId.child(PostPolicyRib.class), postPolicyRib -> {
414 assertFalse(postPolicyRib.getTables().isEmpty());
415 final Tables tables = postPolicyRib.getTables().values().iterator().next();
416 assertTrue(tables.getAttributes().isUptodate());
417 assertEquals(3, ((org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet
418 .rev180329.bmp.monitor.monitor.router.peer.post.policy.rib.tables.routes.Ipv4RoutesCase)
419 tables.getRoutes()).getIpv4Routes().getIpv4Route().size());
423 waitWriteAndFlushSuccess(channel.writeAndFlush(TestUtil.createPeerDownNotification(PEER1)));
425 readDataOperational(getDataBroker(), routerIId, router -> {
426 assertNull(router.getPeer());
434 public void deploySecondInstance() throws Exception {
435 final BmpDeployerDependencies bmpDependecies = new BmpDeployerDependencies(getDataBroker(), getDomBroker(),
436 this.ribExtension, this.mappingService.currentSerializer(), this.clusterSSProv2);
438 final BmpMonitoringStation monitoringStation2 = new BmpMonitoringStationImpl(bmpDependecies,
439 this.dispatcher, new MonitorId("monitor2"),
440 new InetSocketAddress(InetAddresses.forString(MONITOR_LOCAL_ADDRESS_2), MONITOR_LOCAL_PORT), null);
442 readDataOperational(getDataBroker(), BMP_II, monitor -> {
443 assertEquals(2, monitor.getMonitor().size());
447 monitoringStation2.close();
450 private static Channel connectTestClient(final String routerIp, final BmpMessageRegistry msgRegistry)
451 throws InterruptedException {
452 final BmpHandlerFactory hf = new BmpHandlerFactory(msgRegistry);
453 final Bootstrap b = new Bootstrap();
454 final EventLoopGroup workerGroup;
455 if (Epoll.isAvailable()) {
456 b.channel(EpollSocketChannel.class);
457 workerGroup = new EpollEventLoopGroup();
459 b.channel(NioSocketChannel.class);
460 workerGroup = new NioEventLoopGroup();
462 b.group(workerGroup);
463 b.option(ChannelOption.SO_KEEPALIVE, true);
464 b.handler(new ChannelInitializer<SocketChannel>() {
466 protected void initChannel(final SocketChannel ch) {
467 ch.pipeline().addLast(hf.getDecoders());
468 ch.pipeline().addLast(hf.getEncoders());
471 b.localAddress(new InetSocketAddress(routerIp, 0));
472 b.option(ChannelOption.SO_REUSEADDR, true);
473 final ChannelFuture future = b.connect(new InetSocketAddress(MONITOR_LOCAL_ADDRESS, MONITOR_LOCAL_PORT)).sync();
475 return future.channel();
478 private static RouterId getRouterId(final String routerIp) {
479 return new RouterId(new IpAddressNoZone(new Ipv4AddressNoZone(routerIp)));