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