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