2 * Copyright (c) 2014 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
9 package org.opendaylight.bgpcep.bgp.topology.provider;
11 import static org.junit.Assert.assertEquals;
12 import static org.junit.Assert.assertNotEquals;
13 import static org.junit.Assert.assertNotNull;
14 import static org.junit.Assert.assertNull;
15 import static org.junit.Assert.assertTrue;
16 import static org.junit.Assert.fail;
17 import static org.mockito.Matchers.any;
18 import static org.mockito.Mockito.RETURNS_SMART_NULLS;
19 import static org.mockito.Mockito.doThrow;
20 import static org.mockito.Mockito.mock;
21 import static org.mockito.Mockito.never;
22 import static org.mockito.Mockito.spy;
23 import static org.mockito.Mockito.timeout;
24 import static org.mockito.Mockito.times;
25 import static org.mockito.Mockito.verify;
26 import static org.opendaylight.protocol.util.CheckUtil.checkNotPresentOperational;
27 import static org.opendaylight.protocol.util.CheckUtil.readDataOperational;
29 import com.google.common.collect.Lists;
30 import io.netty.buffer.Unpooled;
31 import java.math.BigInteger;
32 import java.nio.charset.StandardCharsets;
33 import java.util.ArrayList;
34 import java.util.Collections;
35 import java.util.List;
36 import org.junit.After;
37 import org.junit.Before;
38 import org.junit.Test;
39 import org.opendaylight.controller.md.sal.binding.api.DataTreeModification;
40 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
41 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
42 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
43 import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
44 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber;
45 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
46 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
47 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
48 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Prefix;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.AdministrativeGroup;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.Identifier;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.Ipv4RouterIdentifier;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.IsisAreaIdentifier;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.LinkstateAddressFamily;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.LinkstateSubsequentAddressFamily;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.ProtocolId;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.TopologyIdentifier;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.attribute.UnreservedBandwidthBuilder;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.attribute.UnreservedBandwidthKey;
59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.object.type.link._case.LinkDescriptorsBuilder;
60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.object.type.link._case.LocalNodeDescriptorsBuilder;
61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.object.type.link._case.RemoteNodeDescriptorsBuilder;
62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.object.type.node._case.NodeDescriptorsBuilder;
63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.object.type.prefix._case.AdvertisingNodeDescriptorsBuilder;
64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.object.type.prefix._case.PrefixDescriptorsBuilder;
65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.path.attribute.link.state.attribute.LinkAttributesCaseBuilder;
66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.path.attribute.link.state.attribute.NodeAttributesCaseBuilder;
67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.path.attribute.link.state.attribute.PrefixAttributesCaseBuilder;
68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.path.attribute.link.state.attribute.link.attributes._case.LinkAttributesBuilder;
69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.path.attribute.link.state.attribute.node.attributes._case.NodeAttributesBuilder;
70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.path.attribute.link.state.attribute.prefix.attributes._case.PrefixAttributesBuilder;
71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.routes.LinkstateRoutes;
72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.routes.linkstate.routes.LinkstateRoute;
73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.routes.linkstate.routes.LinkstateRouteBuilder;
74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.routes.linkstate.routes.LinkstateRouteKey;
75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.routes.linkstate.routes.linkstate.route.Attributes1;
76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.routes.linkstate.routes.linkstate.route.Attributes1Builder;
77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.node.identifier.c.router.identifier.IsisNodeCaseBuilder;
78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.node.identifier.c.router.identifier.isis.node._case.IsisNodeBuilder;
79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev171207.path.attributes.AttributesBuilder;
80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev171207.path.attributes.attributes.OriginBuilder;
81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev171207.bgp.rib.rib.LocRib;
82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev171207.rib.Tables;
83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev171207.rib.TablesKey;
84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.BgpOrigin;
85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.network.concepts.rev131125.Bandwidth;
86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.network.concepts.rev131125.IgpMetric;
87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.network.concepts.rev131125.IsoSystemIdentifier;
88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.network.concepts.rev131125.TeMetric;
89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.SrlgId;
90 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021.IgpLinkAttributes1;
91 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021.IgpNodeAttributes1;
92 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Link;
93 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
94 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.nt.l3.unicast.igp.topology.rev131021.Link1;
95 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.nt.l3.unicast.igp.topology.rev131021.Node1;
96 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.nt.l3.unicast.igp.topology.rev131021.igp.link.attributes.IgpLinkAttributes;
97 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.nt.l3.unicast.igp.topology.rev131021.igp.node.attributes.IgpNodeAttributes;
98 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.nt.l3.unicast.igp.topology.rev131021.igp.node.attributes.igp.node.attributes.Prefix;
99 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
101 public class LinkstateTopologyBuilderTest extends AbstractTopologyBuilderTest {
103 private static final byte[] LINKSTATE_ROUTE_KEY = Unpooled.wrappedBuffer(
104 StandardCharsets.UTF_8.encode("linkstate-route")).array();
105 private static final String ROUTER_1_ID = "127.0.0.1";
106 private static final String ROUTER_2_ID = "127.0.0.2";
107 private static final String NODE_1_PREFIX = "127.0.1.1/32";
108 private static final AsNumber NODE_1_AS = new AsNumber(1L);
109 private static final AsNumber NODE_2_AS = new AsNumber(2L);
110 private static final String NODE_1_ISIS_ID = "bgpls://IsisLevel2:1/type=node&as=1&router=0000.0102.0304";
111 private static final String NODE_2_ISIS_ID = "bgpls://IsisLevel2:1/type=node&as=2";
112 private static final String NODE_1_OSPF_ID = "bgpls://Ospf:1/type=node&as=1&router=0000.0102.0304";
113 private static final String NODE_2_OSPF_ID = "bgpls://Ospf:1/type=node&as=2";
114 private static final Identifier IDENTIFIER = new Identifier(new BigInteger("1"));
115 private static final long LISTENER_RESTART_TIME = 20000;
116 private static final int LISTENER_ENFORCE_COUNTER = 2;
118 private LinkstateTopologyBuilder linkstateTopoBuilder;
119 private InstanceIdentifier<LinkstateRoute> linkstateRouteIID;
123 public void setUp() {
125 this.linkstateTopoBuilder = new LinkstateTopologyBuilder(getDataBroker(), LOC_RIB_REF, TEST_TOPOLOGY_ID,
126 LISTENER_RESTART_TIME, LISTENER_ENFORCE_COUNTER);
127 this.linkstateTopoBuilder.start();
128 final InstanceIdentifier<Tables> path = LOC_RIB_REF.getInstanceIdentifier().builder().child(LocRib.class)
129 .child(Tables.class, new TablesKey(LinkstateAddressFamily.class, LinkstateSubsequentAddressFamily.class))
131 this.linkstateRouteIID = path.builder().child((Class) LinkstateRoutes.class)
132 .child(LinkstateRoute.class, new LinkstateRouteKey(LINKSTATE_ROUTE_KEY)).build();
137 public void tearDown() throws Exception {
138 this.linkstateTopoBuilder.close();
139 checkNotPresentOperational(getDataBroker(), this.linkstateTopoBuilder.getInstanceIdentifier());
143 public void testLinkstateTopologyBuilderTopologyTypes() throws ReadFailedException {
144 readDataOperational(getDataBroker(), this.linkstateTopoBuilder.getInstanceIdentifier(), topology -> {
145 assertNotNull(topology.getTopologyTypes().getAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.odl.bgp.topology.types.rev160524.TopologyTypes1.class));
146 assertNotNull(topology.getTopologyTypes().getAugmentation(org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.odl.bgp.topology.types.rev160524.TopologyTypes1.class).getBgpLinkstateTopology());
152 public void testIsisLinkstateTopologyBuilder() throws TransactionCommitFailedException, ReadFailedException {
154 updateLinkstateRoute(createLinkstateNodeRoute(ProtocolId.IsisLevel2, "node1", NODE_1_AS, ROUTER_1_ID));
155 readDataOperational(getDataBroker(), this.linkstateTopoBuilder.getInstanceIdentifier(), topology -> {
156 assertEquals(1, topology.getNode().size());
157 final Node node1 = topology.getNode().get(0);
158 assertEquals(NODE_1_ISIS_ID, node1.getNodeId().getValue());
159 final IgpNodeAttributes igpNode1 = node1.getAugmentation(Node1.class).getIgpNodeAttributes();
160 assertEquals(ROUTER_1_ID, igpNode1.getRouterId().get(0).getIpv4Address().getValue());
161 assertEquals("node1", igpNode1.getName().getValue());
162 final IgpNodeAttributes1 igpNodeAttributes1 = igpNode1.getAugmentation(IgpNodeAttributes1.class);
163 assertEquals("0000.0102.0304", igpNodeAttributes1.getIsisNodeAttributes().getIso().getIsoSystemId().getValue());
164 assertEquals(ROUTER_1_ID, igpNodeAttributes1.getIsisNodeAttributes().getTed().getTeRouterIdIpv4().getValue());
165 assertEquals("47.0000.0000.0000.0000.0102.0304", igpNodeAttributes1.getIsisNodeAttributes().getNet().get(0).getValue());
166 assertNull(igpNode1.getAugmentation(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.IgpNodeAttributes1.class));
172 updateLinkstateRoute(createLinkstateLinkRoute(ProtocolId.IsisLevel2, NODE_1_AS, NODE_2_AS, "link1"));
173 readDataOperational(getDataBroker(), this.linkstateTopoBuilder.getInstanceIdentifier(), topology -> {
174 assertEquals(1, topology.getLink().size());
175 final Link link1 = topology.getLink().get(0);
176 assertEquals(2, topology.getNode().size());
177 assertEquals(1, topology.getNode().get(0).getTerminationPoint().size());
178 assertEquals(1, topology.getNode().get(1).getTerminationPoint().size());
179 assertEquals("bgpls://IsisLevel2:1/type=link&local-as=1&local-router=0000.0102.0304&remote-as=2&mt=1", link1.getLinkId().getValue());
180 assertEquals(NODE_1_ISIS_ID, link1.getSource().getSourceNode().getValue());
181 assertEquals(NODE_2_ISIS_ID, link1.getDestination().getDestNode().getValue());
182 final IgpLinkAttributes igpLink1 = link1.getAugmentation(Link1.class).getIgpLinkAttributes();
183 assertEquals("link1", igpLink1.getName());
184 assertEquals((short) 1, igpLink1.getAugmentation(IgpLinkAttributes1.class).getIsisLinkAttributes().getMultiTopologyId().shortValue());
185 assertNull(igpLink1.getAugmentation(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.IgpLinkAttributes1.class));
191 updateLinkstateRoute(createLinkstateNodeRoute(ProtocolId.IsisLevel2, "updated-node", NODE_1_AS, ROUTER_2_ID));
192 readDataOperational(getDataBroker(), this.linkstateTopoBuilder.getInstanceIdentifier(), topology -> {
193 assertEquals(1, topology.getNode().size());
194 final IgpNodeAttributes igpNode2 = topology.getNode().get(0).getAugmentation(Node1.class).getIgpNodeAttributes();
195 assertEquals(ROUTER_2_ID, igpNode2.getRouterId().get(0).getIpv4Address().getValue());
196 assertEquals("updated-node", igpNode2.getName().getValue());
201 final WriteTransaction wTx = getDataBroker().newWriteOnlyTransaction();
202 wTx.delete(LogicalDatastoreType.OPERATIONAL, this.linkstateRouteIID);
204 readDataOperational(getDataBroker(), this.linkstateTopoBuilder.getInstanceIdentifier(), topology -> {
205 assertEquals(0, topology.getNode().size());
206 assertEquals(0, topology.getLink().size());
212 public void testOspfLinkstateTopologyBuilder() throws TransactionCommitFailedException, ReadFailedException {
214 updateLinkstateRoute(createLinkstateNodeRoute(ProtocolId.Ospf, "node1", NODE_1_AS, ROUTER_1_ID));
215 readDataOperational(getDataBroker(), this.linkstateTopoBuilder.getInstanceIdentifier(), topology -> {
216 assertEquals(1, topology.getNode().size());
217 final Node node1 = topology.getNode().get(0);
218 assertEquals(NODE_1_OSPF_ID, node1.getNodeId().getValue());
219 final IgpNodeAttributes igpNode1 = node1.getAugmentation(Node1.class).getIgpNodeAttributes();
220 assertEquals(ROUTER_1_ID, igpNode1.getRouterId().get(0).getIpv4Address().getValue());
221 assertEquals("node1", igpNode1.getName().getValue());
222 assertNull(igpNode1.getAugmentation(IgpNodeAttributes1.class));
223 assertEquals(ROUTER_1_ID, igpNode1.getAugmentation(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.IgpNodeAttributes1.class).getOspfNodeAttributes().getTed().getTeRouterIdIpv4().getValue());
227 // update node with prefix
228 updateLinkstateRoute(createLinkstatePrefixRoute(ProtocolId.Ospf, NODE_1_AS, NODE_1_PREFIX, 500L, ROUTER_1_ID));
229 readDataOperational(getDataBroker(), this.linkstateTopoBuilder.getInstanceIdentifier(), topology -> {
230 final IgpNodeAttributes igpNode2 = topology.getNode().get(0).getAugmentation(Node1.class).getIgpNodeAttributes();
231 assertEquals(1, igpNode2.getPrefix().size());
232 final Prefix prefix = igpNode2.getPrefix().get(0);
233 assertEquals(NODE_1_PREFIX, prefix.getPrefix().getIpv4Prefix().getValue());
234 assertEquals(500L, prefix.getMetric().longValue());
240 updateLinkstateRoute(createLinkstateLinkRoute(ProtocolId.Ospf, NODE_1_AS, NODE_2_AS, "link1"));
241 readDataOperational(getDataBroker(), this.linkstateTopoBuilder.getInstanceIdentifier(), topology -> {
242 assertEquals(1, topology.getLink().size());
243 final Link link1 = topology.getLink().get(0);
244 assertEquals(2, topology.getNode().size());
245 assertEquals(1, topology.getNode().get(0).getTerminationPoint().size());
246 assertEquals(1, topology.getNode().get(1).getTerminationPoint().size());
247 assertEquals("bgpls://Ospf:1/type=link&local-as=1&local-router=0000.0102.0304&remote-as=2&mt=1", link1.getLinkId().getValue());
248 assertEquals(NODE_1_OSPF_ID, link1.getSource().getSourceNode().getValue());
249 assertEquals(NODE_2_OSPF_ID, link1.getDestination().getDestNode().getValue());
250 final IgpLinkAttributes igpLink1 = link1.getAugmentation(Link1.class).getIgpLinkAttributes();
251 assertEquals("link1", igpLink1.getName());
252 assertNull(igpLink1.getAugmentation(IgpLinkAttributes1.class));
253 assertEquals((short) 1, igpLink1.getAugmentation(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.IgpLinkAttributes1.class).getOspfLinkAttributes().getMultiTopologyId().shortValue());
254 assertEquals(2, igpLink1.getAugmentation(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.IgpLinkAttributes1.class).getOspfLinkAttributes().getTed().getSrlg().getSrlgValues().size());
262 * This test is to verify if the AbstractTopologyBuilder/LinkstateTopologyBuilder is handling exception correctly
267 public void testRouteChangedError() throws Exception {
268 final LinkstateTopologyBuilder spiedLinkstateTopologyBuilder = spy(this.linkstateTopoBuilder);
269 doThrow(RuntimeException.class).when(spiedLinkstateTopologyBuilder).routeChanged(any(), any());
271 spiedLinkstateTopologyBuilder.routeChanged(null, null);
272 fail("Mockito failed to spy routeChanged() method");
273 } catch (final Exception e) {
274 assertTrue(e instanceof RuntimeException);
276 assertEquals(0L, spiedLinkstateTopologyBuilder.listenerScheduledRestartTime);
277 assertEquals(0L, spiedLinkstateTopologyBuilder.listenerScheduledRestartEnforceCounter);
278 // first we examine if the chain is being reset when no exception is thrown
279 spiedLinkstateTopologyBuilder.onDataTreeChanged(new ArrayList<>());
280 verify(spiedLinkstateTopologyBuilder, times(1)).restartTransactionChainOnDemand();
281 verify(spiedLinkstateTopologyBuilder, never()).scheduleListenerRestart();
282 verify(spiedLinkstateTopologyBuilder, never()).resetTransactionChain();
283 assertEquals(0L, spiedLinkstateTopologyBuilder.listenerScheduledRestartTime);
284 assertEquals(0L, spiedLinkstateTopologyBuilder.listenerScheduledRestartEnforceCounter);
285 // now pass some invalid data to cause onDataTreeChanged fail
286 final DataTreeModification<LinkstateRoute> modification = mock(DataTreeModification.class, RETURNS_SMART_NULLS);
287 final List<DataTreeModification<LinkstateRoute>> changes = new ArrayList<>();
288 changes.add(modification);
289 spiedLinkstateTopologyBuilder.onDataTreeChanged(changes);
290 // one restart transaction chain check in onDataTreeChanged()
291 // we are introducing some timeout here as transaction may be executed in a delay manner
292 verify(spiedLinkstateTopologyBuilder, timeout(5000).times(1)).scheduleListenerRestart();
293 verify(spiedLinkstateTopologyBuilder, times(2)).restartTransactionChainOnDemand();
294 assertNotEquals(0L, spiedLinkstateTopologyBuilder.listenerScheduledRestartTime);
295 assertEquals(0, spiedLinkstateTopologyBuilder.listenerScheduledRestartEnforceCounter);
296 final long listenerScheduledRestartTime = spiedLinkstateTopologyBuilder.listenerScheduledRestartTime;
297 // call again with empty change to invoke restartTransactionChainOnDemand()
298 spiedLinkstateTopologyBuilder.onDataTreeChanged(new ArrayList<>());
299 verify(spiedLinkstateTopologyBuilder, times(3)).restartTransactionChainOnDemand();
300 // transaction chain should be reset while listener should not
301 verify(spiedLinkstateTopologyBuilder, times(1)).resetTransactionChain();
302 verify(spiedLinkstateTopologyBuilder, never()).resetListener();
303 // now apply a change with bad modification again
304 spiedLinkstateTopologyBuilder.onDataTreeChanged(changes);
305 verify(spiedLinkstateTopologyBuilder, times(4)).restartTransactionChainOnDemand();
306 // listener scheduled again
307 verify(spiedLinkstateTopologyBuilder, timeout(5000).times(2)).scheduleListenerRestart();
308 // listener timer shouldn't have changed
309 assertEquals(listenerScheduledRestartTime, spiedLinkstateTopologyBuilder.listenerScheduledRestartTime);
310 assertEquals(0, spiedLinkstateTopologyBuilder.listenerScheduledRestartEnforceCounter);
311 verify(spiedLinkstateTopologyBuilder, times(2)).resetTransactionChain();
312 verify(spiedLinkstateTopologyBuilder, never()).resetListener();
313 Thread.sleep(LISTENER_RESTART_TIME);
314 // manually invoke onTransactionChainFailed() to have the listener restart scheduled again
315 spiedLinkstateTopologyBuilder.onTransactionChainFailed(null, null, null);
316 assertTrue(spiedLinkstateTopologyBuilder.listenerScheduledRestartTime == listenerScheduledRestartTime + LISTENER_RESTART_TIME);
317 verify(spiedLinkstateTopologyBuilder, times(5)).restartTransactionChainOnDemand();
318 verify(spiedLinkstateTopologyBuilder, times(3)).scheduleListenerRestart();
319 // enforce counter get increased
320 assertEquals(1, spiedLinkstateTopologyBuilder.listenerScheduledRestartEnforceCounter);
321 verify(spiedLinkstateTopologyBuilder, times(3)).resetTransactionChain();
322 verify(spiedLinkstateTopologyBuilder, never()).resetListener();
323 // sleep to let the listener restart timer times out
324 Thread.sleep(LISTENER_RESTART_TIME);
325 // apply a good modification (empty change)
326 spiedLinkstateTopologyBuilder.onDataTreeChanged(new ArrayList<>());
327 assertEquals(0, spiedLinkstateTopologyBuilder.listenerScheduledRestartTime);
328 assertEquals(0, spiedLinkstateTopologyBuilder.listenerScheduledRestartEnforceCounter);
329 verify(spiedLinkstateTopologyBuilder, times(6)).restartTransactionChainOnDemand();
330 // listener restarted didn't get rescheduled again
331 verify(spiedLinkstateTopologyBuilder, times(3)).scheduleListenerRestart();
332 verify(spiedLinkstateTopologyBuilder, times(4)).resetTransactionChain();
333 verify(spiedLinkstateTopologyBuilder, times(1)).resetListener();
336 private void updateLinkstateRoute(final LinkstateRoute data) {
337 final WriteTransaction wTx = getDataBroker().newWriteOnlyTransaction();
338 wTx.put(LogicalDatastoreType.OPERATIONAL, this.linkstateRouteIID, data, true);
342 private static LinkstateRoute createLinkstateNodeRoute(final ProtocolId protocolId, final String nodeName,
343 final AsNumber asNumber, final String ipv4RouterId) {
344 return createBaseBuilder(protocolId)
345 .setObjectType(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.object.type.NodeCaseBuilder().setNodeDescriptors(new NodeDescriptorsBuilder().setCRouterIdentifier(new IsisNodeCaseBuilder().setIsisNode(new IsisNodeBuilder().setIsoSystemId(new IsoSystemIdentifier(new byte[]{0, 0, 1, 2, 3, 4})).build()).build()).setAsNumber(asNumber).build()).build())
346 .setAttributes(new AttributesBuilder()
347 .setOrigin(new OriginBuilder().setValue(BgpOrigin.Igp).build())
348 .addAugmentation(Attributes1.class, new Attributes1Builder().setLinkStateAttribute(new NodeAttributesCaseBuilder().setNodeAttributes(new NodeAttributesBuilder()
349 .setDynamicHostname(nodeName)
350 .setIpv4RouterId(new Ipv4RouterIdentifier(ipv4RouterId))
351 .setIsisAreaId(Collections.singletonList(new IsisAreaIdentifier(new byte[]{0x47}))).build()).build()).build()).build()).build();
354 private static LinkstateRoute createLinkstatePrefixRoute(final ProtocolId protocolId, final AsNumber asNumber,
355 final String ipv4Prefix, final long igpMetric, final String ospfFwdAddress) {
356 return createBaseBuilder(protocolId)
357 .setObjectType(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.object.type.PrefixCaseBuilder()
358 .setAdvertisingNodeDescriptors(new AdvertisingNodeDescriptorsBuilder().setAsNumber(asNumber).build())
359 .setPrefixDescriptors(new PrefixDescriptorsBuilder().setIpReachabilityInformation(new IpPrefix(new Ipv4Prefix(ipv4Prefix))).build())
361 .setAttributes(new AttributesBuilder()
362 .setOrigin(new OriginBuilder().setValue(BgpOrigin.Igp).build())
363 .addAugmentation(Attributes1.class, new Attributes1Builder().setLinkStateAttribute(new PrefixAttributesCaseBuilder().setPrefixAttributes(new PrefixAttributesBuilder().setOspfForwardingAddress(new IpAddress(new Ipv4Address(ospfFwdAddress))).setPrefixMetric(new IgpMetric(igpMetric)).build()).build()).build()).build())
367 private static LinkstateRoute createLinkstateLinkRoute(final ProtocolId protocolId, final AsNumber localAs,
368 final AsNumber remoteAs, final String linkName) {
369 return createBaseBuilder(protocolId)
370 .setObjectType(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev171207.linkstate.object.type.LinkCaseBuilder()
371 .setLocalNodeDescriptors(new LocalNodeDescriptorsBuilder().setAsNumber(localAs).setCRouterIdentifier(new IsisNodeCaseBuilder().setIsisNode(new IsisNodeBuilder().setIsoSystemId(new IsoSystemIdentifier(new byte[]{0, 0, 1, 2, 3, 4})).build()).build()).build())
372 .setRemoteNodeDescriptors(new RemoteNodeDescriptorsBuilder().setAsNumber(remoteAs).build())
373 .setLinkDescriptors(new LinkDescriptorsBuilder().setMultiTopologyId(new TopologyIdentifier(1)).build())
375 .setAttributes(new AttributesBuilder()
376 .setOrigin(new OriginBuilder().setValue(BgpOrigin.Igp).build())
377 .addAugmentation(Attributes1.class, new Attributes1Builder().setLinkStateAttribute(new LinkAttributesCaseBuilder().setLinkAttributes(
378 new LinkAttributesBuilder().setSharedRiskLinkGroups(Lists.newArrayList(new SrlgId(5L), new SrlgId(15L))).setAdminGroup(new AdministrativeGroup(0L))
379 .setMaxLinkBandwidth(new Bandwidth(new byte[]{0x00, 0x00, (byte) 0xff, (byte) 0xff}))
380 .setMaxReservableBandwidth(new Bandwidth(new byte[]{0x00, 0x00, (byte) 0xff, (byte) 0x1f}))
381 .setUnreservedBandwidth(Lists.newArrayList(new UnreservedBandwidthBuilder().setKey(new UnreservedBandwidthKey((short) 1)).setBandwidth(new Bandwidth(new byte[]{0x00, 0x00, 0x00, (byte) 0xff})).build()))
382 .setTeMetric(new TeMetric(100L)).setLinkName(linkName).build()).build()).build())
387 private static LinkstateRouteBuilder createBaseBuilder(final ProtocolId protocolId) {
388 return new LinkstateRouteBuilder()
389 .setIdentifier(IDENTIFIER)
390 .setKey(new LinkstateRouteKey(LINKSTATE_ROUTE_KEY))
391 .setRouteKey(LINKSTATE_ROUTE_KEY)
392 .setProtocolId(protocolId);