pcep/ietf-stateful07/src/test/java/org/opendaylight/protocol/pcep/ietf/PCEPValidatorTest.java

   1 /*
   2  * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.protocol.pcep.ietf;
   9
  10 import static org.junit.Assert.assertArrayEquals;
  11 import static org.junit.Assert.assertEquals;
  12
  13 import com.google.common.collect.Lists;
  14
  15 import io.netty.buffer.ByteBuf;
  16 import io.netty.buffer.Unpooled;
  17
  18 import java.io.IOException;
  19 import java.util.Collections;
  20 import java.util.List;
  21
  22 import org.junit.Before;
  23 import org.junit.Test;
  24 import org.opendaylight.protocol.pcep.ietf.initiated00.CInitiated00PCInitiateMessageParser;
  25 import org.opendaylight.protocol.pcep.ietf.initiated00.CrabbeInitiatedActivator;
  26 import org.opendaylight.protocol.pcep.ietf.stateful07.Stateful07PCReportMessageParser;
  27 import org.opendaylight.protocol.pcep.ietf.stateful07.Stateful07PCUpdateRequestMessageParser;
  28 import org.opendaylight.protocol.pcep.ietf.stateful07.StatefulActivator;
  29 import org.opendaylight.protocol.pcep.impl.Activator;
  30 import org.opendaylight.protocol.pcep.impl.message.PCEPErrorMessageParser;
  31 import org.opendaylight.protocol.pcep.impl.message.PCEPOpenMessageParser;
  32 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
  33 import org.opendaylight.protocol.pcep.spi.pojo.SimplePCEPExtensionProviderContext;
  34 import org.opendaylight.protocol.util.ByteArray;
  35 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Address;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ieee754.rev130819.Float32;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Lsp1;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Lsp1Builder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.PcinitiateBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Srp1;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Srp1Builder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.pcinitiate.message.PcinitiateMessageBuilder;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.pcinitiate.message.pcinitiate.message.Requests;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.pcinitiate.message.pcinitiate.message.RequestsBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.OperationalStatus;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.PcrptBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.PcupdBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.PlspId;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SrpIdNumber;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Tlvs1;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Tlvs1Builder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.Lsp;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.LspBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.lsp.TlvsBuilder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.PcrptMessageBuilder;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.Reports;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.ReportsBuilder;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcupd.message.PcupdMessageBuilder;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcupd.message.pcupd.message.Updates;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcupd.message.pcupd.message.UpdatesBuilder;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcupd.message.pcupd.message.updates.PathBuilder;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.Srp;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.SrpBuilder;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.stateful.capability.tlv.Stateful;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.stateful.capability.tlv.StatefulBuilder;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.OpenBuilder;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcerrBuilder;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.ProtocolVersion;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.address.family.ipv4._case.Ipv4Builder;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.Ero;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.EroBuilder;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.Iro;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.IroBuilder;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.Subobject;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.SubobjectBuilder;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.Metrics;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.MetricsBuilder;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.Lspa;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.LspaBuilder;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.metric.object.MetricBuilder;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.message.OpenMessageBuilder;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.Open;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObject;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObjectBuilder;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.PcerrMessageBuilder;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.Errors;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.ErrorsBuilder;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.SessionCaseBuilder;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.session._case.SessionBuilder;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.Rro;
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.RroBuilder;
  93 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.AttributeFilter;
  94 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumberCase;
  95 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumberCaseBuilder;
  96 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.as.number._case.AsNumberBuilder;
  97 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.subobject.type.UnnumberedCase;
  98 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.subobject.type.UnnumberedCaseBuilder;
  99 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.subobject.type.unnumbered._case.UnnumberedBuilder;
 100
 101 public class PCEPValidatorTest {
 102
 103     private Open open;
 104     private Lspa lspa;
 105     private Metrics metrics;
 106     private Iro iro;
 107     private Ero ero;
 108     private Rro rro;
 109     private Srp srp;
 110     private Lsp lsp;
 111
 112     private AsNumberCase eroASSubobject;
 113     private UnnumberedCase rroUnnumberedSub;
 114
 115     private SimplePCEPExtensionProviderContext ctx;
 116     private Activator act;
 117
 118     @Before
 119     public void setUp() throws Exception {
 120         this.ctx = new SimplePCEPExtensionProviderContext();
 121         this.act = new Activator();
 122         this.act.start(this.ctx);
 123
 124         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder openBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder();
 125         openBuilder.setProcessingRule(false);
 126         openBuilder.setIgnore(false);
 127         openBuilder.setDeadTimer((short) 1);
 128         openBuilder.setKeepalive((short) 1);
 129         openBuilder.setSessionId((short) 0);
 130         openBuilder.setVersion(new ProtocolVersion((short) 1));
 131         openBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().build());
 132         this.open = openBuilder.build();
 133
 134         final LspaBuilder lspaBuilder = new LspaBuilder();
 135         lspaBuilder.setProcessingRule(false);
 136         lspaBuilder.setIgnore(false);
 137         lspaBuilder.setLocalProtectionDesired(false);
 138         lspaBuilder.setHoldPriority((short) 0);
 139         lspaBuilder.setSetupPriority((short) 0);
 140         lspaBuilder.setExcludeAny(new AttributeFilter(0L));
 141         lspaBuilder.setIncludeAll(new AttributeFilter(0L));
 142         lspaBuilder.setIncludeAny(new AttributeFilter(0L));
 143         lspaBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.lspa.TlvsBuilder().build());
 144         this.lspa = lspaBuilder.build();
 145
 146         final MetricBuilder mBuilder = new MetricBuilder();
 147         mBuilder.setIgnore(false);
 148         mBuilder.setProcessingRule(false);
 149         mBuilder.setComputed(false);
 150         mBuilder.setBound(false);
 151         mBuilder.setMetricType((short) 1);
 152         mBuilder.setValue(new Float32(new byte[4]));
 153         this.metrics = new MetricsBuilder().setMetric(mBuilder.build()).build();
 154
 155         this.eroASSubobject = new AsNumberCaseBuilder().setAsNumber(
 156                 new AsNumberBuilder().setAsNumber(
 157                         new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.AsNumber(0xFFFFL)).build()).build();
 158
 159         this.rroUnnumberedSub = new UnnumberedCaseBuilder().setUnnumbered(
 160                 new UnnumberedBuilder().setRouterId(0x00112233L).setInterfaceId(0x00ff00ffL).build()).build();
 161
 162         final IroBuilder iroBuilder = new IroBuilder();
 163         iroBuilder.setIgnore(false);
 164         iroBuilder.setProcessingRule(false);
 165         final List<Subobject> iroSubs = Lists.newArrayList();
 166         iroSubs.add(new SubobjectBuilder().setSubobjectType(this.eroASSubobject).build());
 167         iroBuilder.setSubobject(iroSubs);
 168         this.iro = iroBuilder.build();
 169
 170         final EroBuilder eroBuilder = new EroBuilder();
 171         eroBuilder.setIgnore(false);
 172         eroBuilder.setProcessingRule(false);
 173         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.Subobject> eroSubs = Lists.newArrayList();
 174         eroSubs.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.SubobjectBuilder().setSubobjectType(
 175                 this.eroASSubobject).setLoose(false).build());
 176         eroBuilder.setSubobject(eroSubs);
 177         this.ero = eroBuilder.build();
 178
 179         final RroBuilder rroBuilder = new RroBuilder();
 180         rroBuilder.setIgnore(false);
 181         rroBuilder.setProcessingRule(false);
 182         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.rro.Subobject> rroSubs = Lists.newArrayList();
 183         rroSubs.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.rro.SubobjectBuilder().setSubobjectType(
 184                 this.rroUnnumberedSub).setProtectionAvailable(false).setProtectionInUse(false).build());
 185         rroBuilder.setSubobject(rroSubs);
 186         this.rro = rroBuilder.build();
 187
 188         final SrpBuilder srpBuilder = new SrpBuilder();
 189         srpBuilder.setIgnore(false);
 190         srpBuilder.setProcessingRule(false);
 191         srpBuilder.setOperationId(new SrpIdNumber(1L));
 192         srpBuilder.addAugmentation(Srp1.class, new Srp1Builder().setRemove(false).build());
 193         this.srp = srpBuilder.build();
 194
 195         final LspBuilder lspBuilder = new LspBuilder();
 196         lspBuilder.setIgnore(false);
 197         lspBuilder.setProcessingRule(false);
 198         lspBuilder.setAdministrative(false);
 199         lspBuilder.setDelegate(false);
 200         lspBuilder.setPlspId(new PlspId(0L));
 201         lspBuilder.setOperational(OperationalStatus.Down);
 202         lspBuilder.setSync(false);
 203         lspBuilder.setRemove(false);
 204         lspBuilder.setTlvs(new TlvsBuilder().build());
 205         lspBuilder.addAugmentation(Lsp1.class, new Lsp1Builder().setCreate(false).build());
 206         this.lsp = lspBuilder.build();
 207
 208         final Ipv4Builder afi = new Ipv4Builder();
 209         afi.setSourceIpv4Address(new Ipv4Address("255.255.255.255"));
 210         afi.setDestinationIpv4Address(new Ipv4Address("255.255.255.255"));
 211     }
 212
 213     @Test
 214     public void testOpenMsg() throws IOException, PCEPDeserializerException {
 215         try (StatefulActivator a = new StatefulActivator()) {
 216             a.start(this.ctx);
 217             final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPOpenMessage1.bin"));
 218             final PCEPOpenMessageParser parser = new PCEPOpenMessageParser(this.ctx.getObjectHandlerRegistry());
 219             final OpenMessageBuilder builder = new OpenMessageBuilder();
 220
 221             final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder b = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder();
 222             b.setProcessingRule(false);
 223             b.setIgnore(false);
 224             b.setVersion(new ProtocolVersion((short) 1));
 225             b.setKeepalive((short) 30);
 226             b.setDeadTimer((short) 120);
 227             b.setSessionId((short) 1);
 228             final Stateful tlv1 = new StatefulBuilder().setLspUpdateCapability(Boolean.TRUE).build();
 229             b.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().addAugmentation(
 230                     Tlvs1.class, new Tlvs1Builder().setStateful(tlv1).build()).build());
 231             builder.setOpen(b.build());
 232
 233             assertEquals(new OpenBuilder().setOpenMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 234                     result.readableBytes() - 4), Collections.<Message> emptyList()));
 235             final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 236             parser.serializeMessage(new OpenBuilder().setOpenMessage(builder.build()).build(), buf);
 237             assertArrayEquals(result.array(), buf.array());
 238         }
 239     }
 240
 241     @Test
 242     public void testUpdMsg() throws IOException, PCEPDeserializerException {
 243         try (CrabbeInitiatedActivator a = new CrabbeInitiatedActivator()) {
 244             a.start(this.ctx);
 245             ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCUpd.2.bin"));
 246
 247             final Stateful07PCUpdateRequestMessageParser parser = new Stateful07PCUpdateRequestMessageParser(this.ctx.getObjectHandlerRegistry());
 248
 249             final PcupdMessageBuilder builder = new PcupdMessageBuilder();
 250
 251             final List<Updates> updates = Lists.newArrayList();
 252             final PathBuilder pBuilder = new PathBuilder();
 253             pBuilder.setEro(this.ero);
 254             pBuilder.setLspa(this.lspa);
 255             updates.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 256             builder.setUpdates(updates);
 257
 258             assertEquals(new PcupdBuilder().setPcupdMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 259                     result.readableBytes() - 4), Collections.<Message> emptyList()));
 260             ByteBuf buf = Unpooled.buffer(result.readableBytes());
 261             parser.serializeMessage(new PcupdBuilder().setPcupdMessage(builder.build()).build(), buf);
 262             assertArrayEquals(result.array(), buf.array());
 263
 264             result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCUpd.5.bin"));
 265
 266             final List<Updates> updates1 = Lists.newArrayList();
 267             final PathBuilder pBuilder1 = new PathBuilder();
 268             pBuilder1.setEro(this.ero);
 269             pBuilder1.setLspa(this.lspa);
 270             updates1.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 271             updates1.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder1.build()).build());
 272             builder.setUpdates(updates1);
 273
 274             assertEquals(new PcupdBuilder().setPcupdMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 275                     result.readableBytes() - 4), Collections.<Message> emptyList()));
 276             buf = Unpooled.buffer(result.readableBytes());
 277             parser.serializeMessage(new PcupdBuilder().setPcupdMessage(builder.build()).build(), buf);
 278             assertArrayEquals(result.array(), buf.array());
 279         }
 280     }
 281
 282     @Test
 283     public void testRptMsg() throws IOException, PCEPDeserializerException {
 284         try (CrabbeInitiatedActivator a = new CrabbeInitiatedActivator()) {
 285             a.start(this.ctx);
 286             ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRpt.1.bin"));
 287
 288             final Stateful07PCReportMessageParser parser = new Stateful07PCReportMessageParser(this.ctx.getObjectHandlerRegistry());
 289
 290             final PcrptMessageBuilder builder = new PcrptMessageBuilder();
 291
 292             final List<Reports> reports = Lists.newArrayList();
 293             reports.add(new ReportsBuilder().setLsp(this.lsp).build());
 294             builder.setReports(reports);
 295
 296             assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 297                     result.readableBytes() - 4), Collections.<Message> emptyList()));
 298             ByteBuf buf = Unpooled.buffer(result.readableBytes());
 299             parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 300             assertArrayEquals(result.array(), buf.array());
 301
 302             result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRpt.2.bin"));
 303
 304             final List<Reports> reports1 = Lists.newArrayList();
 305             reports1.add(new ReportsBuilder().setLsp(this.lsp).setPath(
 306                     new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder().setEro(
 307                             this.ero).setLspa(this.lspa).build()).build());
 308             builder.setReports(reports1);
 309
 310             assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 311                     result.readableBytes() - 4), Collections.<Message> emptyList()));
 312             buf = Unpooled.buffer(result.readableBytes());
 313             parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 314             assertArrayEquals(result.array(), buf.array());
 315
 316             result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRpt.3.bin"));
 317
 318             final List<Reports> reports2 = Lists.newArrayList();
 319             final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder pBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder();
 320             pBuilder.setEro(this.ero);
 321             pBuilder.setLspa(this.lspa);
 322             pBuilder.setMetrics(Lists.newArrayList(this.metrics, this.metrics));
 323             pBuilder.setRro(this.rro);
 324             reports2.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 325             builder.setReports(reports2);
 326
 327             assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 328                     result.readableBytes() - 4), Collections.<Message> emptyList()));
 329             buf = Unpooled.buffer(result.readableBytes());
 330             parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 331             assertArrayEquals(result.array(), buf.array());
 332
 333             result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRpt.5.bin"));
 334
 335             final List<Reports> reports3 = Lists.newArrayList();
 336             final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder pBuilder1 = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder();
 337             pBuilder1.setEro(this.ero);
 338             pBuilder1.setLspa(this.lspa);
 339             pBuilder1.setMetrics(Lists.newArrayList(this.metrics, this.metrics));
 340             pBuilder1.setRro(this.rro);
 341             reports3.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 342             reports3.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder1.build()).build());
 343             builder.setReports(reports3);
 344
 345             assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 346                     result.readableBytes() - 4), Collections.<Message> emptyList()));
 347             buf = Unpooled.buffer(result.readableBytes());
 348             parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 349             assertArrayEquals(result.array(), buf.array());
 350         }
 351     }
 352
 353     @Test
 354     public void testPcinitMsg() throws IOException, PCEPDeserializerException {
 355         try (CrabbeInitiatedActivator a = new CrabbeInitiatedActivator()) {
 356             a.start(this.ctx);
 357             final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/Pcinit.bin"));
 358
 359             final CInitiated00PCInitiateMessageParser parser = new CInitiated00PCInitiateMessageParser(this.ctx.getObjectHandlerRegistry());
 360
 361             final PcinitiateMessageBuilder builder = new PcinitiateMessageBuilder();
 362             final RequestsBuilder rBuilder = new RequestsBuilder();
 363
 364             final List<Requests> reqs = Lists.newArrayList();
 365             rBuilder.setSrp(this.srp);
 366             rBuilder.setLsp(this.lsp);
 367             rBuilder.setEro(this.ero);
 368             rBuilder.setLspa(this.lspa);
 369             rBuilder.setMetrics(Lists.newArrayList(this.metrics));
 370             rBuilder.setIro(this.iro);
 371             reqs.add(rBuilder.build());
 372             builder.setRequests(reqs);
 373
 374             assertEquals(new PcinitiateBuilder().setPcinitiateMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 375                     result.readableBytes() - 4), Collections.<Message> emptyList()));
 376             final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 377             parser.serializeMessage(new PcinitiateBuilder().setPcinitiateMessage(builder.build()).build(), buf);
 378             assertArrayEquals(result.array(), buf.array());
 379         }
 380     }
 381
 382     @Test
 383     public void testErrorMsg() throws IOException, PCEPDeserializerException {
 384         try (StatefulActivator a = new StatefulActivator()) {
 385             a.start(this.ctx);
 386             final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCErr.3.bin"));
 387
 388             final ErrorObject error1 = new ErrorObjectBuilder().setIgnore(false).setProcessingRule(false).setType((short) 3).setValue(
 389                     (short) 1).build();
 390
 391             final PCEPErrorMessageParser parser = new PCEPErrorMessageParser(this.ctx.getObjectHandlerRegistry());
 392
 393             List<Errors> innerErr = Lists.newArrayList();
 394             innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
 395
 396             final PcerrMessageBuilder builder = new PcerrMessageBuilder();
 397             builder.setErrors(innerErr);
 398             builder.setErrorType(new SessionCaseBuilder().setSession(new SessionBuilder().setOpen(this.open).build()).build());
 399
 400             assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 401                     result.readableBytes() - 4), Collections.<Message> emptyList()));
 402             final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 403             parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
 404             assertArrayEquals(result.array(), buf.array());
 405         }
 406     }
 407 }