public class BandwidthUsageObjectCodec implements ObjectParser, ObjectSerializer {
- public static final int CLASS = 5;
+ static final int CLASS = 5;
private static final int BW_LENGTH = 4;
@Override
public BandwidthUsage parseObject(final ObjectHeader header, final ByteBuf bytes) throws PCEPDeserializerException {
- Preconditions.checkArgument(bytes != null && bytes.isReadable(), "Array of bytes is mandatory. Can't be null or empty.");
+ Preconditions.checkArgument(bytes != null && bytes.isReadable(),
+ "Array of bytes is mandatory. Can't be null or empty.");
if (bytes.readableBytes() % BW_LENGTH != 0) {
- throw new PCEPDeserializerException("Wrong length of array of bytes. Passed: " + bytes.readableBytes() + "; Expected multiple of "
- + BW_LENGTH + ".");
+ throw new PCEPDeserializerException("Wrong length of array of bytes. Passed: " + bytes.readableBytes()
+ + "; Expected multiple of " + BW_LENGTH + ".");
}
final BandwidthUsageBuilder builder = new BandwidthUsageBuilder();
builder.setIgnore(header.isIgnore());
@Override
public void serializeObject(final Object object, final ByteBuf buffer) {
- Preconditions.checkArgument(object instanceof BandwidthUsage, "Wrong instance of PCEPObject. Passed %s. Needed BandwidthUsage.", object.getClass());
+ Preconditions.checkArgument(object instanceof BandwidthUsage,
+ "Wrong instance of PCEPObject. Passed %s. Needed BandwidthUsage.", object.getClass());
final List<Bandwidth> bwSample = ((BandwidthUsage) object).getBwSample();
final ByteBuf body = Unpooled.buffer(bwSample.size() * BW_LENGTH);
for (final Bandwidth bw : bwSample) {
public class PCEPBandwidthUsageObjectCodecTest {
- private static final byte[] BW_BYTES = new byte[] { 0x05, 0x50, 0x00, 0x0C, 0x00, 0x00, 0x10, 0x00, 0x00, 0x00, 0x40, 0x00};
+ private static final byte[] BW_BYTES = new byte[]{0x05, 0x50, 0x00, 0x0C, 0x00, 0x00, 0x10, 0x00,
+ 0x00, 0x00, 0x40, 0x00};
@Test
public void testCodec() throws PCEPDeserializerException {
assertEquals(5, codec.getType());
final BandwidthUsageBuilder builder = new BandwidthUsageBuilder();
- builder.setBwSample(Lists.newArrayList(new Bandwidth(new byte [] {0x00, 0x00, 0x10, 0x00}), new Bandwidth(new byte[] {0x00, 0x00, 0x40, 0x00})));
+ builder.setBwSample(Lists.newArrayList(new Bandwidth(new byte[]{0x00, 0x00, 0x10, 0x00}),
+ new Bandwidth(new byte[]{0x00, 0x00, 0x40, 0x00})));
builder.setIgnore(false);
builder.setProcessingRule(false);
- final BandwidthUsage parsedObject = codec.parseObject(new ObjectHeaderImpl(false, false), Unpooled.wrappedBuffer(BW_BYTES, 4, BW_BYTES.length - 4));
+ final BandwidthUsage parsedObject = codec.parseObject(new ObjectHeaderImpl(false, false),
+ Unpooled.wrappedBuffer(BW_BYTES, 4, BW_BYTES.length - 4));
assertEquals(builder.build(), parsedObject);
final ByteBuf buffer = Unpooled.buffer(BW_BYTES.length);
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;
+
import com.google.common.collect.Lists;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
public class PcRptMessageCodecTest {
+ private static final List<Bandwidth> BW = Collections.singletonList(new Bandwidth(new byte[]{0, 0, 0, 1}));
private SimplePCEPExtensionProviderContext ctx;
private BaseParserExtensionActivator act;
private StatefulActivator statefulAct;
this.act.start(this.ctx);
this.statefulAct = new StatefulActivator();
this.statefulAct.start(this.ctx);
- this.autoBwActivator = new org.opendaylight.protocol.pcep.auto.bandwidth.extension.Activator(5);
+ this.autoBwActivator = new org.opendaylight.protocol.pcep.auto.bandwidth.extension
+ .Activator(5);
this.autoBwActivator.start(this.ctx);
}
@Test
public void testGetValidReportsPositive() {
final PcRptMessageCodec codec = new PcRptMessageCodec(this.ctx.getObjectHandlerRegistry());
- final BandwidthUsage bw = new BandwidthUsageBuilder().setBwSample(Lists.newArrayList(new Bandwidth(new byte[] {0, 0, 0, 1}))).build();
+ final BandwidthUsage bw = new BandwidthUsageBuilder().setBwSample(BW).build();
final Ipv4Builder builder = new Ipv4Builder();
builder.setIpv4TunnelSenderAddress(new Ipv4Address("127.0.1.1"));
builder.setIpv4ExtendedTunnelId(new Ipv4ExtendedTunnelId(new Ipv4Address("127.0.1.2")));
final AddressFamily afiLsp = new Ipv4CaseBuilder().setIpv4(builder.build()).build();
final LspId lspId = new LspId(1L);
final TunnelId tunnelId = new TunnelId(1);
- final LspIdentifiers identifier = new LspIdentifiersBuilder().setAddressFamily(afiLsp).setLspId(lspId).setTunnelId(tunnelId).build();
- final Lsp lsp = new LspBuilder().setPlspId(new PlspId(1L)).setTlvs(new TlvsBuilder().setLspIdentifiers(identifier).build()).build();
+ final LspIdentifiers identifier = new LspIdentifiersBuilder().setAddressFamily(afiLsp)
+ .setLspId(lspId).setTunnelId(tunnelId).build();
+ final Lsp lsp = new LspBuilder().setPlspId(new PlspId(1L))
+ .setTlvs(new TlvsBuilder().setLspIdentifiers(identifier).build()).build();
final Ero ero = new EroBuilder().build();
final List<Object> objects = Lists.newArrayList(lsp, ero, bw);
final Reports validReports = codec.getValidReports(objects, Collections.emptyList());
@Test
public void testGetValidReportsNegative() {
final PcRptMessageCodec codec = new PcRptMessageCodec(this.ctx.getObjectHandlerRegistry());
- final BandwidthUsage bw = new BandwidthUsageBuilder().setBwSample(Lists.newArrayList(new Bandwidth(new byte[] {0, 0, 0, 1}))).build();
+ final BandwidthUsage bw = new BandwidthUsageBuilder().setBwSample(BW).build();
final Ipv4Builder builder = new Ipv4Builder();
builder.setIpv4TunnelSenderAddress(new Ipv4Address("127.0.1.1"));
builder.setIpv4ExtendedTunnelId(new Ipv4ExtendedTunnelId(new Ipv4Address("127.0.1.2")));
public void testserializeObject() {
final PcRptMessageCodec codec = new PcRptMessageCodec(this.ctx.getObjectHandlerRegistry());
final BandwidthBuilder bwBuilder = new BandwidthBuilder();
- bwBuilder.addAugmentation(Bandwidth1.class, new Bandwidth1Builder().setBwSample(
- Lists.newArrayList(new Bandwidth(new byte[] {0, 0, 0, 1}))).build());
+ bwBuilder.addAugmentation(Bandwidth1.class, new Bandwidth1Builder().setBwSample(BW).build());
final ByteBuf buffer = Unpooled.buffer();
codec.serializeObject(bwBuilder.build(), buffer);
Assert.assertTrue(buffer.readableBytes() > 0);
@Test
public void testReportMsgWithRro() throws PCEPDeserializerException {
- final byte[] parseHexBinary = DatatypeConverter.parseHexBinary("2010003c0084a019001100106e79636e7932316372735f7432313231001200100a0000d2004008490a0000d40a0000d4001f0006000005dd700000000710001401080a000706200001080a0000d420000910001400000000000000000000000005050100051000084998968005500008513a43b70810002401080a0000d42020030801010000000001080a00070620000308010100000000");
- final Pcrpt msg = (Pcrpt) this.ctx.getMessageHandlerRegistry().parseMessage(10, Unpooled.wrappedBuffer(parseHexBinary), Collections.emptyList());
- Assert.assertNotNull(msg.getPcrptMessage().getReports().get(0).getPath().getBandwidth().getAugmentation(Bandwidth1.class));
+ final byte[] parseHexBinary = DatatypeConverter
+ .parseHexBinary("2010003c0084a019001100106e79636e7932316372735f7432313231001200100a0"
+ + "000d2004008490a0000d40a0000d4001f0006000005dd700000000710001401080a000706200001080a0000d420"
+ + "000910001400000000000000000000000005050100051000084998968005500008513a43b70810002401080a000"
+ + "0d42020030801010000000001080a00070620000308010100000000");
+ final Pcrpt msg = (Pcrpt) this.ctx.getMessageHandlerRegistry().parseMessage(10,
+ Unpooled.wrappedBuffer(parseHexBinary), Collections.emptyList());
+ Assert.assertNotNull(msg.getPcrptMessage().getReports().get(0).getPath()
+ .getBandwidth().getAugmentation(Bandwidth1.class));
}
}