Eliminate some leftovers from codegen change.
Change-Id: I9a6ab0a13e406c194c7267fd99ed77616a5c7815
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
public ContainerNode serializeAttributes(final Attributes pathAttr) {
Preconditions.checkState(this.attributesCodec != null, "Attributes codec not available");
final AttributesBuilder a = new AttributesBuilder(pathAttr);
- a.addAugmentation(Attributes1.class, null);
- a.addAugmentation(Attributes2.class, null);
+ a.removeAugmentation(Attributes1.class);
+ a.removeAugmentation(Attributes2.class);
return (ContainerNode) this.attributesCodec.serialize(a.build());
}
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.CParametersBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.c.parameters.As4BytesCapabilityBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.BgpTableType;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1Builder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.AddPathCapabilityBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.MultiprotocolCapabilityBuilder;
tableTypeRegistry);
if (!addPathCapability.isEmpty()) {
caps.add(new OptionalCapabilitiesBuilder()
- .setCParameters(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setAddPathCapability(
- new AddPathCapabilityBuilder()
- .setAddressFamilies(addPathCapability).build()).build()).build()).build());
+ .setCParameters(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setAddPathCapability(new AddPathCapabilityBuilder()
+ .setAddressFamilies(addPathCapability)
+ .build())
+ .build())
+ .build())
+ .build());
}
final List<BgpTableType> tableTypes = OpenConfigMappingUtil.toTableTypes(afiSafi, tableTypeRegistry);
tableType);
}
- caps.add(new OptionalCapabilitiesBuilder().setCParameters(
- new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setMultiprotocolCapability(
- new MultiprotocolCapabilityBuilder(tableType).build()).build()).build()).build());
+ caps.add(new OptionalCapabilitiesBuilder()
+ .setCParameters(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setMultiprotocolCapability(new MultiprotocolCapabilityBuilder(tableType).build())
+ .build())
+ .build())
+ .build());
}
return caps;
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.OriginatorIdBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.as.path.SegmentsBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.update.message.WithdrawnRoutesBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes1;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes1Builder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.BgpTableType;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.update.attributes.MpReachNlriBuilder;
private static void addAttributeAugmentation(final AttributesBuilder attBuilder, final Ipv4Prefix prefix,
final PathId pathId) {
- attBuilder.setUnrecognizedAttributes(Collections.emptyList());
- attBuilder.addAugmentation(Attributes1.class,
- new Attributes1Builder().setMpReachNlri(
- new MpReachNlriBuilder()
- .setCNextHop(new Ipv4NextHopCaseBuilder().setIpv4NextHop(new Ipv4NextHopBuilder().setGlobal(NH1)
- .build()).build())
- .setAfi(Ipv4AddressFamily.class)
- .setSafi(UnicastSubsequentAddressFamily.class)
- .setAdvertizedRoutes(new AdvertizedRoutesBuilder().setDestinationType(
- new DestinationIpv4CaseBuilder().setDestinationIpv4(
- new DestinationIpv4Builder().setIpv4Prefixes(Collections.singletonList(
- new Ipv4PrefixesBuilder().setPathId(pathId).setPrefix(new Ipv4Prefix(prefix)).build()))
- .build())
- .build()).build())
- .build()).build());
+ attBuilder.setUnrecognizedAttributes(Collections.emptyMap());
+ attBuilder.addAugmentation(new Attributes1Builder()
+ .setMpReachNlri(new MpReachNlriBuilder()
+ .setCNextHop(new Ipv4NextHopCaseBuilder()
+ .setIpv4NextHop(new Ipv4NextHopBuilder().setGlobal(NH1).build())
+ .build())
+ .setAfi(Ipv4AddressFamily.class)
+ .setSafi(UnicastSubsequentAddressFamily.class)
+ .setAdvertizedRoutes(new AdvertizedRoutesBuilder()
+ .setDestinationType(new DestinationIpv4CaseBuilder()
+ .setDestinationIpv4(new DestinationIpv4Builder()
+ .setIpv4Prefixes(Collections.singletonList(new Ipv4PrefixesBuilder()
+ .setPathId(pathId)
+ .setPrefix(new Ipv4Prefix(prefix))
+ .build()))
+ .build())
+ .build())
+ .build())
+ .build())
+ .build());
}
private static Update createSimpleWithdrawalUpdate(final Ipv4Prefix prefix, final long localPreference) {
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.CParametersBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.c.parameters.As4BytesCapabilityBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.BgpTableType;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1Builder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.MultiprotocolCapabilityBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.BgpId;
final List<OptionalCapabilities> capas = new ArrayList<>();
capas.add(new OptionalCapabilitiesBuilder()
.setCParameters(new CParametersBuilder()
- .addAugmentation(CParameters1.class, new CParameters1Builder()
+ .addAugmentation(new CParameters1Builder()
.setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
.setAfi(IPV_4_TT.getAfi())
.setSafi(IPV_4_TT.getSafi())
capas.add(new OptionalCapabilitiesBuilder()
.setCParameters(BgpExtendedMessageUtil.EXTENDED_MESSAGE_CAPABILITY).build());
tlvs.add(new BgpParametersBuilder().setOptionalCapabilities(capas).build());
- final BgpId bgpId = new BgpId(IetfInetUtil.INSTANCE.ipv4AddressNoZoneFor(socketAddress.getAddress()));
+ final BgpId bgpId = new BgpId(IetfInetUtil.INSTANCE.ipv4AddressFor(socketAddress.getAddress()));
return new BGPSessionPreferences(AS_NUMBER, HOLD_TIMER, bgpId, AS_NUMBER, tlvs);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.CParametersBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.c.parameters.As4BytesCapabilityBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.BgpTableType;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1Builder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.GracefulRestartCapabilityBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.MultiprotocolCapabilityBuilder;
final List<OptionalCapabilities> capas = new ArrayList<>();
capas.add(new OptionalCapabilitiesBuilder()
- .setCParameters(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
- .setAfi(this.ipv4tt.getAfi()).setSafi(this.ipv4tt.getSafi()).build()).build())
- .build()).build());
- capas.add(new OptionalCapabilitiesBuilder().setCParameters(new CParametersBuilder()
- .addAugmentation(CParameters1.class,
- new CParameters1Builder().setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
- .setAfi(this.linkstatett.getAfi()).setSafi(this.linkstatett.getSafi())
- .build()).build()).build()).build());
+ .setCParameters(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
+ .setAfi(this.ipv4tt.getAfi())
+ .setSafi(this.ipv4tt.getSafi())
+ .build())
+ .build())
+ .build())
+ .build());
+ capas.add(new OptionalCapabilitiesBuilder()
+ .setCParameters(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
+ .setAfi(this.linkstatett.getAfi())
+ .setSafi(this.linkstatett.getSafi())
+ .build())
+ .build())
+ .build())
+ .build());
capas.add(new OptionalCapabilitiesBuilder()
.setCParameters(new CParametersBuilder()
.setAs4BytesCapability(new As4BytesCapabilityBuilder()
capas.add(new OptionalCapabilitiesBuilder()
.setCParameters(BgpExtendedMessageUtil.EXTENDED_MESSAGE_CAPABILITY).build());
capas.add(new OptionalCapabilitiesBuilder()
- .setCParameters(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setGracefulRestartCapability(new GracefulRestartCapabilityBuilder()
- .build()).build()).build()).build());
+ .setCParameters(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setGracefulRestartCapability(new GracefulRestartCapabilityBuilder().build())
+ .build())
+ .build())
+ .build());
tlvs.add(new BgpParametersBuilder().setOptionalCapabilities(capas).build());
final List<BgpParameters> tlvs = new ArrayList<>();
final List<OptionalCapabilities> capas = new ArrayList<>();
- capas.add(new OptionalCapabilitiesBuilder().setCParameters(new CParametersBuilder()
- .addAugmentation(CParameters1.class,
- new CParameters1Builder().setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
- .setAfi(this.ipv4tt.getAfi()).setSafi(this.ipv4tt.getSafi())
- .build()).build()).build()).build());
+ capas.add(new OptionalCapabilitiesBuilder()
+ .setCParameters(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
+ .setAfi(this.ipv4tt.getAfi())
+ .setSafi(this.ipv4tt.getSafi())
+ .build())
+ .build())
+ .build())
+ .build());
capas.add(new OptionalCapabilitiesBuilder()
.setCParameters(BgpExtendedMessageUtil.EXTENDED_MESSAGE_CAPABILITY).build());
tlvs.add(new BgpParametersBuilder().setOptionalCapabilities(capas).build());
final List<OptionalCapabilities> capas = new ArrayList<>();
capas.add(new OptionalCapabilitiesBuilder()
.setCParameters(new CParametersBuilder()
- .addAugmentation(CParameters1.class, new CParameters1Builder()
+ .addAugmentation(new CParameters1Builder()
.setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
.setAfi(this.ipv4tt.getAfi())
.setSafi(this.ipv4tt.getSafi())
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.update.message.NlriBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.update.message.WithdrawnRoutes;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.update.message.WithdrawnRoutesBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes2;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes2Builder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1Builder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.RouteRefreshBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.MultiprotocolCapabilityBuilder;
this.classic.onMessage(this.session, ub.build());
assertEquals(2, this.routes.size());
this.classic.onMessage(this.session, new KeepaliveBuilder().build());
- this.classic.onMessage(this.session, new UpdateBuilder().setAttributes(
- new AttributesBuilder().addAugmentation(
- Attributes2.class,
- new Attributes2Builder().setMpUnreachNlri(
- new MpUnreachNlriBuilder()
- .setAfi(IPV4_AFI)
- .setSafi(SAFI)
- .build()).build()).build()).build());
+ this.classic.onMessage(this.session, new UpdateBuilder()
+ .setAttributes(new AttributesBuilder()
+ .addAugmentation(new Attributes2Builder()
+ .setMpUnreachNlri(new MpUnreachNlriBuilder().setAfi(IPV4_AFI).setSafi(SAFI).build())
+ .build())
+ .build())
+ .build());
this.classic.onMessage(this.session, new RouteRefreshBuilder().setAfi(IPV4_AFI).setSafi(SAFI).build());
this.classic.onMessage(this.session, new RouteRefreshBuilder()
.setAfi(Ipv6AddressFamily.class)
doReturn(new DefaultChannelPromise(channel)).when(channel).writeAndFlush(any(Notification.class));
doReturn(new InetSocketAddress("localhost", 12345)).when(channel).remoteAddress();
doReturn(new InetSocketAddress("localhost", 12345)).when(channel).localAddress();
- final List<BgpParameters> params = Lists.newArrayList(new BgpParametersBuilder().setOptionalCapabilities(
- Lists.newArrayList(new OptionalCapabilitiesBuilder().setCParameters(
- new CParametersBuilder().addAugmentation(
- CParameters1.class, new CParameters1Builder().setMultiprotocolCapability(
- new MultiprotocolCapabilityBuilder()
- .setAfi(Ipv4AddressFamily.class)
- .setSafi(UnicastSubsequentAddressFamily.class)
- .build()).build()).build()).build())).build());
+ final List<BgpParameters> params = Lists.newArrayList(new BgpParametersBuilder()
+ .setOptionalCapabilities(Lists.newArrayList(new OptionalCapabilitiesBuilder()
+ .setCParameters(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
+ .setAfi(Ipv4AddressFamily.class)
+ .setSafi(UnicastSubsequentAddressFamily.class)
+ .build())
+ .build())
+ .build())
+ .build()))
+ .build());
final Open openObj = new OpenBuilder()
.setBgpIdentifier(new Ipv4AddressNoZone("1.1.1.1"))
.setHoldTimer(Uint16.valueOf(50))
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.Origin;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.OriginBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.as.path.Segments;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes1;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes1Builder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes2;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes2Builder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1Builder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.SendReceive;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.destination.DestinationType;
.setOrigin(origin).setAsPath(asPath).setLocalPref(localPref);
if (mpReach != null) {
- attributeBuilder.addAugmentation(Attributes1.class, new Attributes1Builder()
- .setMpReachNlri(mpReach)
- .build());
+ attributeBuilder.addAugmentation(new Attributes1Builder().setMpReachNlri(mpReach).build());
}
if (mpUnreach != null) {
- attributeBuilder.addAugmentation(Attributes2.class, new Attributes2Builder()
- .setMpUnreachNlri(mpUnreach)
- .build());
+ attributeBuilder.addAugmentation(new Attributes2Builder().setMpUnreachNlri(mpUnreach).build());
}
return new UpdateBuilder()
.setOrigin(origin)
.setAsPath(asPath)
.setLocalPref(localPref)
- .addAugmentation(Attributes1.class, new Attributes1Builder()
- .setMpReachNlri(mpReach)
- .build())
+ .addAugmentation(new Attributes1Builder().setMpReachNlri(mpReach).build())
.build()).build();
}
}
private static OptionalCapabilities createMultiprotocolCapability(final TablesKey key) {
- return new OptionalCapabilitiesBuilder().setCParameters(
- new CParametersBuilder().addAugmentation(
- CParameters1.class, new CParameters1Builder().setMultiprotocolCapability(
- new MultiprotocolCapabilityBuilder()
- .setAfi(key.getAfi())
- .setSafi(key.getSafi())
- .build()).build()).build()).build();
+ return new OptionalCapabilitiesBuilder()
+ .setCParameters(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
+ .setAfi(key.getAfi())
+ .setSafi(key.getSafi())
+ .build())
+ .build())
+ .build())
+ .build();
}
private static OptionalCapabilities createGracefulRestartCapability(final Map<TablesKey, Boolean> gracefulTables,
final int restartTime) {
- return new OptionalCapabilitiesBuilder().setCParameters(
- new CParametersBuilder().addAugmentation(
- CParameters1.class, new CParameters1Builder()
- .setGracefulRestartCapability(new GracefulRestartCapabilityBuilder()
- .setRestartFlags(new GracefulRestartCapability.RestartFlags(false))
- .setRestartTime(restartTime)
- .setTables(gracefulTables.keySet().stream()
- .map(key -> new TablesBuilder()
- .setAfi(key.getAfi())
- .setSafi(key.getSafi())
- .setAfiFlags(new Tables.AfiFlags(gracefulTables.get(key)))
+ return new OptionalCapabilitiesBuilder()
+ .setCParameters(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setGracefulRestartCapability(new GracefulRestartCapabilityBuilder()
+ .setRestartFlags(new GracefulRestartCapability.RestartFlags(false))
+ .setRestartTime(restartTime)
+ .setTables(gracefulTables.keySet().stream()
+ .map(key -> new TablesBuilder()
+ .setAfi(key.getAfi())
+ .setSafi(key.getSafi())
+ .setAfiFlags(new Tables.AfiFlags(gracefulTables.get(key)))
+ .build())
+ .collect(Collectors.toList()))
.build())
- .collect(Collectors.toList()))
- .build()).build()).build()).build();
+ .build())
+ .build())
+ .build();
}
private static OptionalCapabilities createAddPathCapability(final List<TablesKey> keys) {
- return new OptionalCapabilitiesBuilder().setCParameters(
- new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setAddPathCapability(
- new AddPathCapabilityBuilder().setAddressFamilies(keys.stream()
- .map(key -> new AddressFamiliesBuilder()
- .setAfi(key.getAfi())
- .setSafi(key.getSafi())
- .setSendReceive(SendReceive.Both)
- .build())
- .collect(Collectors.toList()))
- .build()).build()).build()).build();
+ return new OptionalCapabilitiesBuilder()
+ .setCParameters(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setAddPathCapability(new AddPathCapabilityBuilder()
+ .setAddressFamilies(keys.stream()
+ .map(key -> new AddressFamiliesBuilder()
+ .setAfi(key.getAfi())
+ .setSafi(key.getSafi())
+ .setSendReceive(SendReceive.Both)
+ .build())
+ .collect(Collectors.toList()))
+ .build())
+ .build())
+ .build())
+ .build();
}
}
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertSame;
import static org.junit.Assert.fail;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.doNothing;
+import static org.mockito.Mockito.doReturn;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.verifyNoMoreInteractions;
import com.google.common.collect.Lists;
import com.google.common.util.concurrent.Futures;
import java.util.List;
import org.junit.Before;
import org.junit.Test;
-import org.mockito.Mockito;
import org.opendaylight.protocol.bgp.parser.BGPDocumentedException;
import org.opendaylight.protocol.bgp.parser.BGPError;
import org.opendaylight.protocol.bgp.rib.impl.spi.BGPSessionPreferences;
}
private static BGPSessionListener getMockSession() {
- final BGPSessionListener mock = Mockito.mock(BGPSessionListener.class);
- Mockito.doReturn(Futures.immediateFuture(null)).when(mock).releaseConnection();
+ final BGPSessionListener mock = mock(BGPSessionListener.class);
+ doReturn(Futures.immediateFuture(null)).when(mock).releaseConnection();
return mock;
}
private static PeerRegistrySessionListener getMockSessionListener() {
- final PeerRegistrySessionListener mock = Mockito.mock(PeerRegistrySessionListener.class);
- Mockito.doNothing().when(mock).onSessionCreated(Mockito.any(IpAddressNoZone.class));
- Mockito.doNothing().when(mock).onSessionRemoved(Mockito.any(IpAddressNoZone.class));
+ final PeerRegistrySessionListener mock = mock(PeerRegistrySessionListener.class);
+ doNothing().when(mock).onSessionCreated(any(IpAddressNoZone.class));
+ doNothing().when(mock).onSessionRemoved(any(IpAddressNoZone.class));
return mock;
}
final BGPSessionListener returnedSession2 = this.peerRegistry.getPeer(remoteIp2, FROM, to2, this.classicOpen);
assertSame(session2, returnedSession2);
- Mockito.verifyZeroInteractions(this.peer1);
- Mockito.verifyZeroInteractions(session2);
+ verifyNoMoreInteractions(this.peer1);
+ verifyNoMoreInteractions(session2);
}
@Test
this.peerRegistry.getPeer(remoteIp, lower, higher, createOpen(higher, LOCAL_AS));
this.peerRegistry.getPeer(remoteIp, higher, lower, createOpen(lower, LOCAL_AS));
- Mockito.verify(this.peer1).releaseConnection();
+ verify(this.peer1).releaseConnection();
}
@Test
this.peerRegistry.getPeer(REMOTE_IP, FROM, TO, this.classicOpen);
this.peerRegistry.getPeer(REMOTE_IP, FROM, TO, createOpen(TO, REMOTE_AS));
- Mockito.verify(this.peer1).releaseConnection();
+ verify(this.peer1).releaseConnection();
}
@Test
this.peerRegistry.addPeer(REMOTE_IP, this.peer1, this.mockPreferences);
this.peerRegistry.getPeer(REMOTE_IP, FROM, TO, this.classicOpen);
- Mockito.verify(sessionListener1, Mockito.times(1)).onSessionCreated(REMOTE_IP);
- Mockito.verify(sessionListener2, Mockito.times(1)).onSessionCreated(REMOTE_IP);
+ verify(sessionListener1, times(1)).onSessionCreated(REMOTE_IP);
+ verify(sessionListener2, times(1)).onSessionCreated(REMOTE_IP);
this.peerRegistry.removePeerSession(REMOTE_IP);
- Mockito.verify(sessionListener1, Mockito.times(1)).onSessionRemoved(REMOTE_IP);
- Mockito.verify(sessionListener2, Mockito.times(1)).onSessionRemoved(REMOTE_IP);
+ verify(sessionListener1, times(1)).onSessionRemoved(REMOTE_IP);
+ verify(sessionListener2, times(1)).onSessionRemoved(REMOTE_IP);
}
@Test
this.peerRegistry.getPeer(REMOTE_IP, FROM, TO, this.classicOpen);
this.peerRegistry.removePeerSession(REMOTE_IP);
- Mockito.verify(sessionListener1, Mockito.times(1)).onSessionCreated(REMOTE_IP);
- Mockito.verify(sessionListener2, Mockito.times(2)).onSessionCreated(REMOTE_IP);
- Mockito.verify(sessionListener1, Mockito.times(1)).onSessionRemoved(REMOTE_IP);
- Mockito.verify(sessionListener2, Mockito.times(2)).onSessionRemoved(REMOTE_IP);
+ verify(sessionListener1, times(1)).onSessionCreated(REMOTE_IP);
+ verify(sessionListener2, times(2)).onSessionCreated(REMOTE_IP);
+ verify(sessionListener1, times(1)).onSessionRemoved(REMOTE_IP);
+ verify(sessionListener2, times(2)).onSessionRemoved(REMOTE_IP);
}
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.UpdateBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.AttributesBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.update.message.NlriBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes1;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes1Builder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.update.attributes.MpReachNlriBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.rib.TablesKey;
mpBuilder.setAfi(Ipv6AddressFamily.class);
mpBuilder.setSafi(UnicastSubsequentAddressFamily.class);
- AttributesBuilder paBuilder = new AttributesBuilder().addAugmentation(Attributes1.class,
- new Attributes1Builder().setMpReachNlri(mpBuilder.build()).build());
+ AttributesBuilder paBuilder = new AttributesBuilder()
+ .addAugmentation(new Attributes1Builder().setMpReachNlri(mpBuilder.build()).build());
this.ipv6m = new UpdateBuilder().setAttributes(paBuilder.build()).build();
mpBuilder.setAfi(LinkstateAddressFamily.class);
mpBuilder.setSafi(LinkstateSubsequentAddressFamily.class);
- paBuilder = new AttributesBuilder().addAugmentation(Attributes1.class,
- new Attributes1Builder().setMpReachNlri(mpBuilder.build()).build());
+ paBuilder = new AttributesBuilder()
+ .addAugmentation(new Attributes1Builder().setMpReachNlri(mpBuilder.build()).build());
this.lsm = new UpdateBuilder().setAttributes(paBuilder.build()).build();
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package org.opendaylight.protocol.bgp.rib.impl.config;
import static org.junit.Assert.assertFalse;
import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbors.NeighborBuilder;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborPeerGroupConfig;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborPeerGroupConfigBuilder;
public class AppPeerTest extends AbstractConfig {
private static final AppPeer APP_PEER = new AppPeer();
private final Neighbor neighbor = new NeighborBuilder()
- .setConfig(new ConfigBuilder().addAugmentation(NeighborPeerGroupConfig.class,
- new NeighborPeerGroupConfigBuilder().setPeerGroup(OpenConfigMappingUtil.APPLICATION_PEER_GROUP_NAME)
- .build()).build())
+ .setConfig(new ConfigBuilder()
+ .addAugmentation(new NeighborPeerGroupConfigBuilder()
+ .setPeerGroup(OpenConfigMappingUtil.APPLICATION_PEER_GROUP_NAME)
+ .build())
+ .build())
.setNeighborAddress(new IpAddress(new Ipv4Address("127.0.0.1"))).build();
@Override
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.PortNumber;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborAddPathsConfig;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborAddPathsConfigBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborTransportConfig;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborTransportConfigBuilder;
import org.opendaylight.yangtools.yang.common.Uint16;
import org.opendaylight.yangtools.yang.common.Uint8;
static final String MD5_PASSWORD = "123";
static final PortNumber PORT = new PortNumber(Uint16.valueOf(179));
static final AfiSafi AFI_SAFI_IPV4 = new AfiSafiBuilder().setAfiSafiName(IPV4UNICAST.class)
- .addAugmentation(NeighborAddPathsConfig.class, new NeighborAddPathsConfigBuilder()
- .setReceive(true).setSendMax(Uint8.ZERO).build()).build();
+ .addAugmentation(new NeighborAddPathsConfigBuilder().setReceive(true).setSendMax(Uint8.ZERO).build())
+ .build();
static final Map<AfiSafiKey, AfiSafi> AFI_SAFI = Collections.singletonMap(AFI_SAFI_IPV4.key(), AFI_SAFI_IPV4);
private static final BigDecimal DEFAULT_TIMERS = BigDecimal.valueOf(30);
private BgpPeer bgpPeer;
static Transport createTransport() {
return new TransportBuilder().setConfig(new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp
- .rev151009.bgp.neighbor.group.transport.ConfigBuilder().setMtuDiscovery(false)
- .setPassiveMode(false).addAugmentation(NeighborTransportConfig.class,
- new NeighborTransportConfigBuilder().setRemotePort(PORT).build()).build()).build();
+ .rev151009.bgp.neighbor.group.transport.ConfigBuilder()
+ .setMtuDiscovery(false)
+ .setPassiveMode(false)
+ .addAugmentation(new NeighborTransportConfigBuilder().setRemotePort(PORT).build())
+ .build())
+ .build();
}
static Timers createTimers() {
import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.types.rev151009.IPV4LABELLEDUNICAST;
import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.types.rev151009.IPV4UNICAST;
import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.types.rev151009.IPV6UNICAST;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.ll.graceful.restart.rev181112.Config1;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.ll.graceful.restart.rev181112.Config1Builder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.ll.graceful.restart.rev181112.afi.safi.ll.graceful.restart.LlGracefulRestartBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.BgpParameters;
.setAfiSafiName(IPV4UNICAST.class)
.setGracefulRestart(new GracefulRestartBuilder()
.setConfig(new ConfigBuilder()
- .addAugmentation(Config1.class, new Config1Builder()
+ .addAugmentation(new Config1Builder()
.setLlGracefulRestart(new LlGracefulRestartBuilder()
.setConfig(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.ll
.graceful.restart.rev181112.afi.safi.ll.graceful.restart.ll.graceful.restart
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.add.path.capability.AddressFamilies;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.add.path.capability.AddressFamiliesBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.GlobalAddPathsConfigBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.GlobalConfigAugmentation;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.GlobalConfigAugmentationBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborAddPathsConfig;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborAddPathsConfigBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborPeerGroupConfig;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborPeerGroupConfigBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborTransportConfig;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborTransportConfigBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NetworkInstanceProtocol;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.PeerGroupTransportConfig;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.PeerGroupTransportConfigBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.PeerRole;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.Ipv4AddressFamily;
.group.transport.ConfigBuilder().build()).build()).build(), null));
final PortNumber newPort = new PortNumber(Uint16.valueOf(111));
final Config portConfig = new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor
- .group.transport.ConfigBuilder().addAugmentation(NeighborTransportConfig.class,
- new NeighborTransportConfigBuilder().setRemotePort(newPort).build()).build();
+ .group.transport.ConfigBuilder()
+ .addAugmentation(new NeighborTransportConfigBuilder().setRemotePort(newPort).build()).build();
assertEquals(newPort, OpenConfigMappingUtil.getPort(new NeighborBuilder().setTransport(
transport.setConfig(portConfig).build()).build(), null));
.setTransport(transport.setConfig(portConfig).build()).build(), new PeerGroupBuilder().build()));
final Config portConfigGroup = new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp
- .neighbor.group.transport.ConfigBuilder().addAugmentation(PeerGroupTransportConfig.class,
- new PeerGroupTransportConfigBuilder().setRemotePort(newPort).build()).build();
+ .neighbor.group.transport.ConfigBuilder()
+ .addAugmentation(new PeerGroupTransportConfigBuilder().setRemotePort(newPort).build()).build();
assertEquals(newPort, OpenConfigMappingUtil.getPort(new NeighborBuilder().build(), new PeerGroupBuilder()
.setTransport(transport.setConfig(portConfigGroup).build()).build()));
}
assertEquals(defaultValue, OpenConfigMappingUtil.getAfiSafiWithDefault(afiSafi, true));
final AfiSafi afiSafiIpv6 = new AfiSafiBuilder().setAfiSafiName(IPV6UNICAST.class)
- .addAugmentation(NeighborAddPathsConfig.class,
- new NeighborAddPathsConfigBuilder().setReceive(true).setSendMax(SHORT).build()).build();
+ .addAugmentation(new NeighborAddPathsConfigBuilder().setReceive(true).setSendMax(SHORT).build())
+ .build();
final List<AfiSafi> afiSafiIpv6List = new ArrayList<>();
afiSafiIpv6List.add(afiSafiIpv6);
assertEquals(ROUTER_ID.getValue(),
OpenConfigMappingUtil.getGlobalClusterIdentifier(configBuilder.build()).getValue());
- configBuilder.addAugmentation(GlobalConfigAugmentation.class, new GlobalConfigAugmentationBuilder()
+ configBuilder.addAugmentation(new GlobalConfigAugmentationBuilder()
.setRouteReflectorClusterId(new RrClusterIdType(CLUSTER_ID)).build()).build();
assertEquals(CLUSTER_ID.getValue(),
OpenConfigMappingUtil.getGlobalClusterIdentifier(configBuilder.build()).getValue());
assertFalse(OpenConfigMappingUtil.isApplicationPeer(new NeighborBuilder()
.setConfig(new ConfigBuilder().build()).build()));
final Neighbor neighbor = new NeighborBuilder().setConfig(new ConfigBuilder()
- .addAugmentation(NeighborPeerGroupConfig.class, new NeighborPeerGroupConfigBuilder()
+ .addAugmentation(new NeighborPeerGroupConfigBuilder()
.setPeerGroup(OpenConfigMappingUtil.APPLICATION_PEER_GROUP_NAME).build()).build()).build();
assertTrue(OpenConfigMappingUtil.isApplicationPeer(neighbor));
}
public void toAddPathCapability() {
final List<AfiSafi> families = new ArrayList<>();
families.add(new AfiSafiBuilder().setAfiSafiName(IPV4UNICAST.class)
- .addAugmentation(NeighborAddPathsConfig.class,
- new NeighborAddPathsConfigBuilder()
- .setReceive(Boolean.TRUE).setSendMax(ALL_PATHS).build()).build());
+ .addAugmentation(new NeighborAddPathsConfigBuilder()
+ .setReceive(Boolean.TRUE).setSendMax(ALL_PATHS).build()).build());
families.add(new AfiSafiBuilder().setAfiSafiName(IPV6UNICAST.class)
- .addAugmentation(NeighborAddPathsConfig.class,
- new NeighborAddPathsConfigBuilder()
- .setReceive(Boolean.FALSE).setSendMax(N_PATHS).build()).build());
+ .addAugmentation(new NeighborAddPathsConfigBuilder()
+ .setReceive(Boolean.FALSE).setSendMax(N_PATHS).build()).build());
families.add(new AfiSafiBuilder().setAfiSafiName(IPV6LABELLEDUNICAST.class)
- .addAugmentation(NeighborAddPathsConfig.class,
- new NeighborAddPathsConfigBuilder().setReceive(Boolean.FALSE).build()).build());
+ .addAugmentation(new NeighborAddPathsConfigBuilder().setReceive(Boolean.FALSE).build()).build());
final List<AddressFamilies> result = OpenConfigMappingUtil
.toAddPathCapability(families, this.tableTypeRegistry);
assertEquals(FAMILIES, result);
import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.types.rev151009.IPV4UNICAST;
import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.types.rev151009.IPV6UNICAST;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4AddressNoZone;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.GlobalAddPathsConfig;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.GlobalAddPathsConfigBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.BgpId;
import org.opendaylight.yangtools.yang.common.Uint8;
static {
AFISAFIS_IPV4.add(new AfiSafiBuilder().setAfiSafiName(IPV4UNICAST.class)
- .addAugmentation(GlobalAddPathsConfig.class, new GlobalAddPathsConfigBuilder().setReceive(true)
- .setSendMax(Uint8.ZERO).build()).build());
+ .addAugmentation(new GlobalAddPathsConfigBuilder().setReceive(true).setSendMax(Uint8.ZERO).build())
+ .build());
}
static {
AFISAFIS_IPV6.add(new AfiSafiBuilder().setAfiSafiName(IPV6UNICAST.class)
- .addAugmentation(GlobalAddPathsConfig.class, new GlobalAddPathsConfigBuilder().setReceive(true)
- .setSendMax(Uint8.ZERO).build()).build());
+ .addAugmentation(new GlobalAddPathsConfigBuilder().setReceive(true).setSendMax(Uint8.ZERO).build())
+ .build());
}
private RIBTestsUtil() {