Eliminate some leftovers from codegen change.
Change-Id: I83b17bfd00475ea40bb5eab4bfa1d25f70d88cd2
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
final MpReachNlri mpReachNlri = getMpReach(parsed);
if (mpReachNlri == null) {
// No MP_REACH attribute, just reuse MP_UNREACH if it is present.
- builder.addAugmentation(Attributes2.class, parsed.augmentation(Attributes2.class));
+ final Attributes2 attrs2 = parsed.augmentation(Attributes2.class);
+ if (attrs2 != null) {
+ builder.addAugmentation(attrs2);
+ }
return builder.build();
}
return new BGPDocumentedException(withdrawCause);
});
- builder.addAugmentation(Attributes2.class, new Attributes2Builder().setMpUnreachNlri(converted).build());
+ builder.addAugmentation(new Attributes2Builder().setMpUnreachNlri(converted).build());
return builder.build();
}
.build());
}
}
- return new CParametersBuilder().addAugmentation(CParameters1.class,new CParameters1Builder()
+ return new CParametersBuilder().addAugmentation(new CParameters1Builder()
.setAddPathCapability(new AddPathCapabilityBuilder().setAddressFamilies(families).build()).build()).build();
}
.setAfiFlags(new AfiFlags((flags & AFI_FLAG_FORWARDING_STATE) != 0)).build());
}
cb.setTables(tables);
- return new CParametersBuilder().addAugmentation(CParameters1.class, new CParameters1Builder()
- .setGracefulRestartCapability(cb.build()).build()).build();
+ return new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(cb.build()).build())
+ .build();
}
}
tables.add(table);
}
return new CParametersBuilder()
- .addAugmentation(CParameters1.class, new CParameters1Builder()
- .setLlGracefulRestartCapability(new LlGracefulRestartCapabilityBuilder()
- .setTables(tables)
- .build())
- .build())
+ .addAugmentation(new CParameters1Builder()
+ .setLlGracefulRestartCapability(new LlGracefulRestartCapabilityBuilder().setTables(tables).build())
+ .build())
.build();
}
final Optional<BgpTableType> parsedAfiSafiOptional = MultiprotocolCapabilitiesUtil
.parseMPAfiSafi(buffer, this.afiReg, this.safiReg);
return parsedAfiSafiOptional.map(bgpTableType -> new CParametersBuilder()
- .addAugmentation(CParameters1.class, new CParameters1Builder().setMultiprotocolCapability(
- new MultiprotocolCapabilityBuilder(bgpTableType).build()).build()).build()).orElse(null);
+ .addAugmentation(new CParameters1Builder()
+ .setMultiprotocolCapability(new MultiprotocolCapabilityBuilder(bgpTableType).build())
+ .build())
+ .build()).orElse(null);
}
@Override
final RevisedErrorHandling errorHandling, final PeerSpecificParserConstraint constraint)
throws BGPDocumentedException {
try {
- builder.addAugmentation(Attributes1.class, new Attributes1Builder()
+ builder.addAugmentation(new Attributes1Builder()
.setMpReachNlri(reg.parseMpReach(buffer, constraint))
.build());
} catch (final BGPParsingException e) {
final RevisedErrorHandling errorHandling, final PeerSpecificParserConstraint constraint)
throws BGPDocumentedException {
try {
- builder.addAugmentation(Attributes2.class, new Attributes2Builder()
+ builder.addAugmentation(new Attributes2Builder()
.setMpUnreachNlri(reg.parseMpUnreach(buffer, constraint))
.build());
} catch (final BGPParsingException e) {
family.add(new AddressFamiliesBuilder().setAfi(AddPathCapabilityHandlerTest.AFI)
.setSafi(AddPathCapabilityHandlerTest.SAFI).setSendReceive(SendReceive.forValue(1)).build());
- final CParameters capabilityToSerialize = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setAddPathCapability(
- new AddPathCapabilityBuilder().setAddressFamilies(family).build()).build()).build();
+ final CParameters capabilityToSerialize = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setAddPathCapability(new AddPathCapabilityBuilder().setAddressFamilies(family).build())
+ .build())
+ .build();
final ByteBuf bytes = Unpooled.buffer(6);
final AddPathCapabilityHandler handler = new AddPathCapabilityHandler(this.afiRegistry, this.safiRegistry);
@Test
public void testSendReceiveIgnored() throws BGPDocumentedException, BGPParsingException {
- final CParameters capabilityToSerialize = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setAddPathCapability(
- new AddPathCapabilityBuilder().setAddressFamilies(new ArrayList<>()).build()).build()).build();
+ final CParameters capabilityToSerialize = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setAddPathCapability(new AddPathCapabilityBuilder().setAddressFamilies(new ArrayList<>()).build())
+ .build())
+ .build();
final ByteBuf bytes = this.parseWrongBytes.copy();
final AddPathCapabilityHandler handler = new AddPathCapabilityHandler(this.afiRegistry, this.safiRegistry);
family.add(new AddressFamiliesBuilder().setAfi(AddPathCapabilityHandlerTest.AFI)
.setSafi(AddPathCapabilityHandlerTest.SAFI).setSendReceive(SendReceive.forValue(2)).build());
- final CParameters capabilityToSerialize = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setAddPathCapability(
- new AddPathCapabilityBuilder().setAddressFamilies(family).build()).build()).build();
+ final CParameters capabilityToSerialize = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setAddPathCapability(new AddPathCapabilityBuilder().setAddressFamilies(family).build())
+ .build())
+ .build();
final ByteBuf bytes = Unpooled.buffer();
final AddPathCapabilityHandler handler = new AddPathCapabilityHandler(this.afirExpection, this.safiRegistry);
family.add(new AddressFamiliesBuilder().setAfi(AddPathCapabilityHandlerTest.AFI)
.setSafi(AddPathCapabilityHandlerTest.SAFI).setSendReceive(SendReceive.forValue(3)).build());
- final CParameters capabilityToSerialize = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setAddPathCapability(
- new AddPathCapabilityBuilder().setAddressFamilies(family).build()).build()).build();
+ final CParameters capabilityToSerialize = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setAddPathCapability(new AddPathCapabilityBuilder().setAddressFamilies(family).build())
+ .build())
+ .build();
final ByteBuf bytes = Unpooled.buffer();
final AddPathCapabilityHandler handler = new AddPathCapabilityHandler(this.afiRegistry, this.safirException);
family.add(new AddressFamiliesBuilder().setAfi(AddPathCapabilityHandlerTest.AFI)
.setSafi(AddPathCapabilityHandlerTest.SAFI).setSendReceive(SendReceive.forValue(4)).build());
- final CParameters capabilityToSerialize = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setAddPathCapability(
- new AddPathCapabilityBuilder().setAddressFamilies(family).build()).build()).build();
+ final CParameters capabilityToSerialize = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setAddPathCapability(new AddPathCapabilityBuilder().setAddressFamilies(family).build())
+ .build())
+ .build();
final ByteBuf bytes = Unpooled.buffer();
final AddPathCapabilityHandler handler = new AddPathCapabilityHandler(this.afiRegistry, this.safiRegistry);
@Test
public void noSerializationTest() {
- final CParameters capabilityNoAugmentation = new CParametersBuilder().addAugmentation(CParameters1.class, null)
+ final CParameters capabilityNoAugmentation = new CParametersBuilder().removeAugmentation(CParameters1.class)
+ .build();
+ final CParameters capabilityNoMP = new CParametersBuilder().addAugmentation(new CParameters1Builder().build())
.build();
- final CParameters capabilityNoMP = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().build()).build();
final ByteBuf bytes = Unpooled.buffer();
final AddPathCapabilityHandler handler = new AddPathCapabilityHandler(this.afiRegistry, this.safirException);
paBuilder.setCommunities(comms);
assertEquals(paBuilder.getCommunities(), attrs.getCommunities());
- paBuilder.setUnrecognizedAttributes(Collections.emptyList());
+ paBuilder.setUnrecognizedAttributes(Collections.emptyMap());
builder.setAttributes(paBuilder.build());
paBuilder.setAggregator(aggregator);
assertEquals(paBuilder.getAggregator(), attrs.getAggregator());
- paBuilder.setUnrecognizedAttributes(Collections.emptyList());
+ paBuilder.setUnrecognizedAttributes(Collections.emptyMap());
builder.setAttributes(paBuilder.build());
assertEquals(builder.build(), message);
paBuilder.setExtendedCommunities(comms);
assertEquals(paBuilder.getExtendedCommunities(), attrs.getExtendedCommunities());
- paBuilder.setUnrecognizedAttributes(Collections.emptyList());
+ paBuilder.setUnrecognizedAttributes(Collections.emptyMap());
// check API message
builder.setAttributes(paBuilder.build());
assertEquals(builder.build(), message);
paBuilder.setCommunities(comms);
assertEquals(paBuilder.getCommunities(), attrs.getCommunities());
- paBuilder.setUnrecognizedAttributes(Collections.emptyList());
+ paBuilder.setUnrecognizedAttributes(Collections.emptyMap());
builder.setAttributes(paBuilder.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.message.rev200120.path.attributes.attributes.AggregatorBuilder;
-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.GracefulRestartCapability;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.GracefulRestartCapability.RestartFlags;
final MultiprotocolCapability cap = new MultiprotocolCapabilityBuilder().setAfi(Ipv6AddressFamily.class)
.setSafi(UnicastSubsequentAddressFamily.class).build();
- final CParameters tlv1 = new CParametersBuilder().addAugmentation(CParameters1.class, new CParameters1Builder()
+ final CParameters tlv1 = new CParametersBuilder().addAugmentation(new CParameters1Builder()
.setMultiprotocolCapability(cap).build()).build();
final MultiprotocolCapability cap1 = new MultiprotocolCapabilityBuilder().setAfi(Ipv4AddressFamily.class)
.setSafi(UnicastSubsequentAddressFamily.class).build();
- final CParameters tlv2 = new CParametersBuilder().addAugmentation(CParameters1.class, new CParameters1Builder()
+ final CParameters tlv2 = new CParametersBuilder().addAugmentation(new CParameters1Builder()
.setMultiprotocolCapability(cap1).build()).build();
final List<Tables> tt = new ArrayList<>();
* 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.parser.impl;
+import static org.junit.Assert.assertArrayEquals;
+import static org.junit.Assert.assertEquals;
+
import com.google.common.collect.Lists;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import java.util.Collections;
-import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.opendaylight.protocol.bgp.parser.BGPDocumentedException;
import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionProviderContext;
import org.opendaylight.protocol.bgp.parser.spi.pojo.ServiceLoaderBGPExtensionProviderContext;
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.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.GracefulRestartCapability.RestartFlags;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.GracefulRestartCapabilityBuilder;
capaBuilder.setTables(Lists.newArrayList(tablesBuilder.build()));
final ByteBuf buffer = Unpooled.buffer(capaBytes.length);
- handler.serializeCapability(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build()).build(), buffer);
- Assert.assertArrayEquals(capaBytes, buffer.array());
+ handler.serializeCapability(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build())
+ .build(), buffer);
+ assertArrayEquals(capaBytes, buffer.array());
- Assert.assertEquals(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build()).build(),
- handler.parseCapability(Unpooled.wrappedBuffer(capaBytes).slice(2, capaBytes.length - 2)));
+ assertEquals(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build())
+ .build(), handler.parseCapability(Unpooled.wrappedBuffer(capaBytes).slice(2, capaBytes.length - 2)));
final byte[] capaBytes2 = {
(byte) 0x40, (byte) 0x06, (byte) 0x00, (byte) 0x00,
tablesBuilder.setAfiFlags(new AfiFlags(false));
capaBuilder.setTables(Lists.newArrayList(tablesBuilder.build()));
buffer.clear();
- handler.serializeCapability(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build()).build(), buffer);
- Assert.assertArrayEquals(capaBytes2, buffer.array());
- Assert.assertEquals(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build()).build(),
- handler.parseCapability(Unpooled.wrappedBuffer(capaBytes2).slice(2, capaBytes2.length - 2)));
+ handler.serializeCapability(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build())
+ .build(), buffer);
+ assertArrayEquals(capaBytes2, buffer.array());
+ assertEquals(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build())
+ .build(), handler.parseCapability(Unpooled.wrappedBuffer(capaBytes2).slice(2, capaBytes2.length - 2)));
capaBuilder.setRestartFlags(null);
tablesBuilder.setAfiFlags(null);
capaBuilder.setRestartTime((Uint16) null);
capaBuilder.setTables(Lists.newArrayList(tablesBuilder.build()));
buffer.clear();
- handler.serializeCapability(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build()).build(), buffer);
- Assert.assertArrayEquals(capaBytes2, buffer.array());
+ handler.serializeCapability(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build())
+ .build(), buffer);
+ assertArrayEquals(capaBytes2, buffer.array());
final byte[] capaBytes3 = {
(byte) 0x40, (byte) 0x06, (byte) 0x00, (byte) 0x00,
capaBuilder.setRestartFlags(new RestartFlags(false));
capaBuilder.setRestartTime(Uint16.ZERO);
capaBuilder.setTables(Collections.emptyList());
- Assert.assertEquals(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build()).build(),
- handler.parseCapability(Unpooled.wrappedBuffer(capaBytes3).slice(2, capaBytes3.length - 2)));
+ assertEquals(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build())
+ .build(), handler.parseCapability(Unpooled.wrappedBuffer(capaBytes3).slice(2, capaBytes3.length - 2)));
final byte[] capaBytes4 = {
(byte) 0x40, (byte) 0x06, (byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x01, (byte) 0x00, (byte) 0x00
};
- Assert.assertEquals(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build()).build(),
- handler.parseCapability(Unpooled.wrappedBuffer(capaBytes4).slice(2, capaBytes4.length - 2)));
+ assertEquals(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build())
+ .build(), handler.parseCapability(Unpooled.wrappedBuffer(capaBytes4).slice(2, capaBytes4.length - 2)));
final byte[] capaBytes5 = {
(byte) 0x40, (byte) 0x02, (byte) 0x00, (byte) 0x00
};
final ByteBuf b = Unpooled.buffer(capaBytes5.length);
- handler.serializeCapability(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setGracefulRestartCapability(new GracefulRestartCapabilityBuilder().build())
- .build()).build(), b);
- Assert.assertArrayEquals(capaBytes5, b.array());
- Assert.assertEquals(new CParametersBuilder().addAugmentation(CParameters1.class, new CParameters1Builder()
- .setGracefulRestartCapability(new GracefulRestartCapabilityBuilder()
- .setRestartFlags(new RestartFlags(Boolean.FALSE))
- .setRestartTime(Uint16.ZERO).setTables(Collections.emptyList()).build()).build()).build(),
- handler.parseCapability(Unpooled.wrappedBuffer(capaBytes5).slice(2, capaBytes5.length - 2)));
+ handler.serializeCapability(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setGracefulRestartCapability(new GracefulRestartCapabilityBuilder().build())
+ .build())
+ .build(), b);
+ assertArrayEquals(capaBytes5, b.array());
+ assertEquals(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setGracefulRestartCapability(new GracefulRestartCapabilityBuilder()
+ .setRestartFlags(new RestartFlags(Boolean.FALSE))
+ .setRestartTime(Uint16.ZERO)
+ .build())
+ .build())
+ .build(), handler.parseCapability(Unpooled.wrappedBuffer(capaBytes5).slice(2, capaBytes5.length - 2)));
}
@Test(expected = IllegalArgumentException.class)
capaBuilder.setTables(Lists.newArrayList(tablesBuilder.build()));
final ByteBuf buffer = Unpooled.buffer();
- handler.serializeCapability(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build()).build(), buffer);
+ handler.serializeCapability(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build())
+ .build(), buffer);
}
@Test(expected = IllegalArgumentException.class)
capaBuilder.setTables(Lists.newArrayList(tablesBuilder.build()));
final ByteBuf buffer = Unpooled.buffer();
- handler.serializeCapability(new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build()).build(), buffer);
+ handler.serializeCapability(new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build())
+ .build(), buffer);
}
@Test(expected = IllegalArgumentException.class)
final ByteBuf buffer = Unpooled.buffer();
handler.serializeCapability(new CParametersBuilder()
- .addAugmentation(CParameters1.class, new CParameters1Builder()
- .setGracefulRestartCapability(capaBuilder.build()).build()).build(), buffer);
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build())
+ .build(), buffer);
}
@Test(expected = IllegalArgumentException.class)
final ByteBuf buffer = Unpooled.buffer();
handler.serializeCapability(new CParametersBuilder()
- .addAugmentation(CParameters1.class, new CParameters1Builder()
- .setGracefulRestartCapability(capaBuilder.build()).build()).build(), buffer);
+ .addAugmentation(new CParameters1Builder().setGracefulRestartCapability(capaBuilder.build()).build())
+ .build(), buffer);
}
}
import org.opendaylight.protocol.bgp.parser.spi.pojo.ServiceLoaderBGPExtensionProviderContext;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.CParameters;
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.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.LlGracefulRestartCapability;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.LlGracefulRestartCapabilityBuilder;
.build())
).build();
- final CParameters cParameters = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setLlGracefulRestartCapability(capability).build()).build();
+ final CParameters cParameters = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setLlGracefulRestartCapability(capability).build())
+ .build();
final ByteBuf buffer = Unpooled.buffer(capaBytes.length);
this.handler.serializeCapability(cParameters, buffer);
.setLongLivedStaleTime(TEN)
.build())).build();
- final CParameters cParameters = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setLlGracefulRestartCapability(capability).build()).build();
+ final CParameters cParameters = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setLlGracefulRestartCapability(capability).build())
+ .build();
final ByteBuf buffer = Unpooled.buffer();
this.handler.serializeCapability(cParameters, buffer);
}
.setLongLivedStaleTime(new Uint24(Uint32.valueOf(160)))
.build())).build();
- final CParameters cParameters = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setLlGracefulRestartCapability(capability).build()).build();
+ final CParameters cParameters = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setLlGracefulRestartCapability(capability).build())
+ .build();
LlGracefulCapabilityHandler handler1 = new LlGracefulCapabilityHandler(
afir, safir);
Assert.assertEquals(cParameters, handler1.parseCapability(Unpooled.wrappedBuffer(capaBytes)
.setLongLivedStaleTime(TEN)
.build())).build();
- final CParameters cParameters = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setLlGracefulRestartCapability(capability).build()).build();
+ final CParameters cParameters = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setLlGracefulRestartCapability(capability).build())
+ .build();
final ByteBuf buffer = Unpooled.buffer();
this.handler.serializeCapability(cParameters, buffer);
}
.setLongLivedStaleTime(new Uint24(Uint32.valueOf(160)))
.build())).build();
- final CParameters cParameters = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setLlGracefulRestartCapability(capability).build()).build();
+ final CParameters cParameters = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setLlGracefulRestartCapability(capability).build())
+ .build();
LlGracefulCapabilityHandler handler1 = new LlGracefulCapabilityHandler(
afir, safir);
Assert.assertEquals(cParameters, handler1.parseCapability(Unpooled.wrappedBuffer(capaBytes)
@Test
public void testCapabilityHandler() throws BGPDocumentedException, BGPParsingException {
- final CParameters capabilityToSerialize = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setMultiprotocolCapability(
- new MultiprotocolCapabilityBuilder().setAfi(MultiProtocolCapabilityHandlerTest.AFI)
- .setSafi(MultiProtocolCapabilityHandlerTest.SAFI).build()).build()).build();
+ final CParameters capabilityToSerialize = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
+ .setAfi(MultiProtocolCapabilityHandlerTest.AFI)
+ .setSafi(MultiProtocolCapabilityHandlerTest.SAFI)
+ .build())
+ .build())
+ .build();
final ByteBuf bytes = Unpooled.buffer();
final MultiProtocolCapabilityHandler handler = new MultiProtocolCapabilityHandler(this.afir, this.safir);
@Test(expected = IllegalArgumentException.class)
public void testUnhandledAfi() {
- final CParameters capabilityToSerialize = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setMultiprotocolCapability(
- new MultiprotocolCapabilityBuilder().setAfi(MultiProtocolCapabilityHandlerTest.AFI)
- .setSafi(MultiProtocolCapabilityHandlerTest.SAFI).build()).build()).build();
+ final CParameters capabilityToSerialize = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
+ .setAfi(MultiProtocolCapabilityHandlerTest.AFI)
+ .setSafi(MultiProtocolCapabilityHandlerTest.SAFI).build())
+ .build())
+ .build();
final ByteBuf bytes = Unpooled.buffer();
final MultiProtocolCapabilityHandler handler = new MultiProtocolCapabilityHandler(this.afirExpection,
@Test(expected = IllegalArgumentException.class)
public void testUnhandledSafi() {
- final CParameters capabilityToSerialize = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setMultiprotocolCapability(
- new MultiprotocolCapabilityBuilder().setAfi(MultiProtocolCapabilityHandlerTest.AFI)
- .setSafi(MultiProtocolCapabilityHandlerTest.SAFI).build()).build()).build();
+ final CParameters capabilityToSerialize = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setMultiprotocolCapability(new MultiprotocolCapabilityBuilder()
+ .setAfi(MultiProtocolCapabilityHandlerTest.AFI)
+ .setSafi(MultiProtocolCapabilityHandlerTest.SAFI)
+ .build())
+ .build())
+ .build();
final ByteBuf bytes = Unpooled.buffer();
final MultiProtocolCapabilityHandler handler = new MultiProtocolCapabilityHandler(this.afir,
@Test
public void noSerializationTest() {
- final CParameters capabilityNoAugmentation = new CParametersBuilder().addAugmentation(CParameters1.class, null)
+ final CParameters capabilityNoAugmentation = new CParametersBuilder().removeAugmentation(CParameters1.class)
+ .build();
+ final CParameters capabilityNoMP = new CParametersBuilder().addAugmentation(new CParameters1Builder().build())
.build();
- final CParameters capabilityNoMP = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().build()).build();
final ByteBuf bytes = Unpooled.buffer();
final MultiProtocolCapabilityHandler handler = new MultiProtocolCapabilityHandler(this.afir,
.setCParameters(new CParametersBuilder()
.setAs4BytesCapability(new As4BytesCapabilityBuilder()
.setAsNumber(new AsNumber(Uint32.valueOf(1000))).build())
- .addAugmentation(CParameters1.class, new CParameters1Builder()
+ .addAugmentation(new CParameters1Builder()
.setGracefulRestartCapability(new GracefulRestartCapabilityBuilder()
.setRestartFlags(new GracefulRestartCapability.RestartFlags(false))
.setRestartTime(Uint16.ZERO)
import org.opendaylight.protocol.bgp.parser.impl.message.open.RouteRefreshCapabilityHandler;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.CParameters;
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.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.RouteRefreshCapabilityBuilder;
@Test
public void testRRCapHandler() throws BGPDocumentedException, BGPParsingException {
- final CParameters expectedParams = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setRouteRefreshCapability(
- new RouteRefreshCapabilityBuilder().build()).build()).build();
+ final CParameters expectedParams = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder()
+ .setRouteRefreshCapability(new RouteRefreshCapabilityBuilder().build())
+ .build())
+ .build();
assertEquals(expectedParams, HANDLER.parseCapability(Unpooled.copiedBuffer(OK_BYTES)));
assertEquals(expectedParams, HANDLER.parseCapability(Unpooled.copiedBuffer(WRONG_BYTES)));
HANDLER.serializeCapability(expectedParams, byteAggregator);
assertEquals(Unpooled.copiedBuffer(CAP_BYTES), byteAggregator);
- final CParameters missingCap = new CParametersBuilder().addAugmentation(CParameters1.class,
- new CParameters1Builder().setRouteRefreshCapability(
- null).build()).build();
+ final CParameters missingCap = new CParametersBuilder()
+ .addAugmentation(new CParameters1Builder().setRouteRefreshCapability(null).build())
+ .build();
final ByteBuf byteAggregator2 = Unpooled.buffer(0);
HANDLER.serializeCapability(missingCap, byteAggregator2);
assertEquals(Unpooled.copiedBuffer(new byte[]{}), byteAggregator2);
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
-import java.util.ArrayList;
-import java.util.List;
+import java.util.Map;
import org.junit.Test;
import org.opendaylight.protocol.bgp.parser.spi.pojo.ServiceLoaderBGPExtensionProviderContext;
import org.opendaylight.protocol.util.ByteArray;
(byte)0xd3, 0x5d, 0x35, (byte)0xe0, 0x66, 0x0c, (byte)0xd3, 0x5d, 0x35, (byte)0xd3, 0x5d, 0x35,
(byte)0xd7, 0x5d, 0x75, (byte)0xd7, 0x5d, 0x75
};
- final List<UnrecognizedAttributes> unrecognizedAttrs = new ArrayList<>();
final UnrecognizedAttributes unrecognizedAttribute1 = new UnrecognizedAttributesBuilder().setPartial(true)
.setTransitive(true).setType(Uint8.valueOf(101)).setValue(unrecognizedValue1).build();
- unrecognizedAttrs.add(unrecognizedAttribute1);
final UnrecognizedAttributes unrecognizedAttribute2 = new UnrecognizedAttributesBuilder().setPartial(true)
.setTransitive(true).setType(Uint8.valueOf(102)).setValue(unrecognizedValue2).build();
- unrecognizedAttrs.add(unrecognizedAttribute2);
- final Attributes attrs = new AttributesBuilder().setUnrecognizedAttributes(unrecognizedAttrs).build();
+ final Attributes attrs = new AttributesBuilder()
+ .setUnrecognizedAttributes(Map.of(unrecognizedAttribute1.key(), unrecognizedAttribute1,
+ unrecognizedAttribute2.key(), unrecognizedAttribute2)).build();
final ByteBuf buffer = Unpooled.buffer();
ServiceLoaderBGPExtensionProviderContext.getSingletonInstance().getAttributeRegistry().serializeAttribute(attrs,