pcep/impl/src/test/java/org/opendaylight/protocol/pcep/impl/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.impl;
   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.math.BigInteger;
  17 import java.util.Collections;
  18 import java.util.List;
  19
  20 import org.junit.Before;
  21 import org.junit.Test;
  22 import org.opendaylight.protocol.pcep.PCEPDeserializerException;
  23 import org.opendaylight.protocol.pcep.PCEPDocumentedException;
  24 import org.opendaylight.protocol.pcep.impl.message.PCEPCloseMessageParser;
  25 import org.opendaylight.protocol.pcep.impl.message.PCEPErrorMessageParser;
  26 import org.opendaylight.protocol.pcep.impl.message.PCEPKeepAliveMessageParser;
  27 import org.opendaylight.protocol.pcep.impl.message.PCEPNotificationMessageParser;
  28 import org.opendaylight.protocol.pcep.impl.message.PCEPOpenMessageParser;
  29 import org.opendaylight.protocol.pcep.impl.message.PCEPReplyMessageParser;
  30 import org.opendaylight.protocol.pcep.impl.message.PCEPReportMessageParser;
  31 import org.opendaylight.protocol.pcep.impl.message.PCEPUpdateRequestMessageParser;
  32 import org.opendaylight.protocol.pcep.impl.message.PcinitiateMessageParser;
  33 import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
  34 import org.opendaylight.protocol.pcep.spi.pojo.ServiceLoaderPCEPExtensionProviderContext;
  35 import org.opendaylight.protocol.util.ByteArray;
  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.message.rev131007.CloseBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.KeepaliveBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.OpenBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcerrBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcinitiateBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcntfBuilder;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcrepBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcrptBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcupdBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.OfId;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.OperationalStatus;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.PlspId;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.ProtocolVersion;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.RequestId;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.SrpIdNumber;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.bandwidth.object.Bandwidth;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.bandwidth.object.BandwidthBuilder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.message.CCloseMessageBuilder;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.object.CCloseBuilder;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.Ero;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.EroBuilder;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.Iro;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.IroBuilder;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.Subobjects;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.SubobjectsBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.keepalive.message.KeepaliveMessageBuilder;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.Metrics;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.MetricsBuilder;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.db.version.tlv.LspDbVersion;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.db.version.tlv.LspDbVersionBuilder;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.object.Lsp;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.object.LspBuilder;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.Lspa;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.LspaBuilder;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.metric.object.MetricBuilder;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotification;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotificationBuilder;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.Of;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.OfBuilder;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.message.OpenMessageBuilder;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.Open;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObject;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObjectBuilder;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.PcerrMessageBuilder;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.Errors;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.ErrorsBuilder;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.RequestBuilder;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.SessionBuilder;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcinitiate.message.PcinitiateMessageBuilder;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcinitiate.message.pcinitiate.message.Requests;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcinitiate.message.pcinitiate.message.RequestsBuilder;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.PcntfMessageBuilder;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.Notifications;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.NotificationsBuilder;
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Rps;
  93 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.RpsBuilder;
  94 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.PcrepMessageBuilder;
  95 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.Replies;
  96 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.RepliesBuilder;
  97 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.FailureBuilder;
  98 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.SuccessBuilder;
  99 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure.NoPath;
 100 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure.NoPathBuilder;
 101 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success.Paths;
 102 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success.PathsBuilder;
 103 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrpt.message.PcrptMessageBuilder;
 104 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrpt.message.pcrpt.message.Reports;
 105 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrpt.message.pcrpt.message.ReportsBuilder;
 106 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrpt.message.pcrpt.message.reports.PathBuilder;
 107 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.PcupdMessageBuilder;
 108 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.Updates;
 109 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.UpdatesBuilder;
 110 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.Rro;
 111 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.RroBuilder;
 112 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.Rp;
 113 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.RpBuilder;
 114 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.srp.object.Srp;
 115 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.srp.object.SrpBuilder;
 116 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.stateful.capability.tlv.Stateful;
 117 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.stateful.capability.tlv.Stateful.Flags;
 118 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.stateful.capability.tlv.StatefulBuilder;
 119 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.AttributeFilter;
 120 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumber;
 121 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumberBuilder;
 122 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.subobject.type.Unnumbered;
 123 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.subobject.type.UnnumberedBuilder;
 124
 125 import com.google.common.collect.Lists;
 126
 127 public class PCEPValidatorTest {
 128
 129         private ObjectHandlerRegistry objectRegistry;
 130
 131         private Rp rp;
 132         private Open open;
 133         private NoPath noPath;
 134         private Lspa lspa;
 135         private Bandwidth bandwidth;
 136         private Metrics metrics;
 137         private Iro iro;
 138         private Ero ero;
 139         private Rro rro;
 140         private Of of;
 141         private Srp srp;
 142         private Lsp lsp;
 143
 144         private AsNumber eroASSubobject;
 145         private Unnumbered rroUnnumberedSub;
 146
 147         @Before
 148         public void setUp() throws Exception {
 149                 this.objectRegistry = ServiceLoaderPCEPExtensionProviderContext.create().getObjectHandlerRegistry();
 150                 final RpBuilder rpBuilder = new RpBuilder();
 151                 rpBuilder.setProcessingRule(false);
 152                 rpBuilder.setIgnore(false);
 153                 rpBuilder.setReoptimization(false);
 154                 rpBuilder.setBiDirectional(false);
 155                 rpBuilder.setLoose(true);
 156                 rpBuilder.setMakeBeforeBreak(false);
 157                 rpBuilder.setOrder(false);
 158                 rpBuilder.setSupplyOf(false);
 159                 rpBuilder.setFragmentation(false);
 160                 rpBuilder.setP2mp(false);
 161                 rpBuilder.setEroCompression(false);
 162                 rpBuilder.setPriority((short) 1);
 163                 rpBuilder.setRequestId(new RequestId(10L));
 164                 this.rp = rpBuilder.build();
 165
 166                 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();
 167                 openBuilder.setProcessingRule(false);
 168                 openBuilder.setIgnore(false);
 169                 openBuilder.setDeadTimer((short) 1);
 170                 openBuilder.setKeepalive((short) 1);
 171                 openBuilder.setSessionId((short) 0);
 172                 openBuilder.setVersion(new ProtocolVersion((short) 1));
 173                 openBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().build());
 174                 this.open = openBuilder.build();
 175
 176                 final NoPathBuilder npbuilder = new NoPathBuilder();
 177                 npbuilder.setProcessingRule(false);
 178                 npbuilder.setIgnore(false);
 179                 npbuilder.setNatureOfIssue((short) 0);
 180                 npbuilder.setUnsatisfiedConstraints(false);
 181                 this.noPath = npbuilder.build();
 182
 183                 final LspaBuilder lspaBuilder = new LspaBuilder();
 184                 lspaBuilder.setProcessingRule(false);
 185                 lspaBuilder.setIgnore(false);
 186                 lspaBuilder.setLocalProtectionDesired(false);
 187                 lspaBuilder.setHoldPriority((short) 0);
 188                 lspaBuilder.setSetupPriority((short) 0);
 189                 lspaBuilder.setExcludeAny(new AttributeFilter(0L));
 190                 lspaBuilder.setIncludeAll(new AttributeFilter(0L));
 191                 lspaBuilder.setIncludeAny(new AttributeFilter(0L));
 192                 this.lspa = lspaBuilder.build();
 193
 194                 final BandwidthBuilder bBuilder = new BandwidthBuilder();
 195                 bBuilder.setIgnore(false);
 196                 bBuilder.setProcessingRule(false);
 197                 bBuilder.setBandwidth(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.nps.concepts.rev130930.Bandwidth(new Float32(new byte[4])));
 198                 this.bandwidth = bBuilder.build();
 199
 200                 final MetricBuilder mBuilder = new MetricBuilder();
 201                 mBuilder.setIgnore(false);
 202                 mBuilder.setProcessingRule(false);
 203                 mBuilder.setComputed(false);
 204                 mBuilder.setBound(false);
 205                 mBuilder.setMetricType((short) 1);
 206                 mBuilder.setValue(new Float32(new byte[4]));
 207                 this.metrics = new MetricsBuilder().setMetric(mBuilder.build()).build();
 208
 209                 this.eroASSubobject = new AsNumberBuilder().setAsNumber(
 210                                 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.AsNumber(0xFFFFL)).build();
 211
 212                 this.rroUnnumberedSub = new UnnumberedBuilder().setRouterId(0x00112233L).setInterfaceId(0x00ff00ffL).build();
 213
 214                 final IroBuilder iroBuilder = new IroBuilder();
 215                 iroBuilder.setIgnore(false);
 216                 iroBuilder.setProcessingRule(false);
 217                 final List<Subobjects> iroSubs = Lists.newArrayList();
 218                 iroSubs.add(new SubobjectsBuilder().setSubobjectType(this.eroASSubobject).build());
 219                 iroBuilder.setSubobjects(iroSubs);
 220                 this.iro = iroBuilder.build();
 221
 222                 final EroBuilder eroBuilder = new EroBuilder();
 223                 eroBuilder.setIgnore(false);
 224                 eroBuilder.setProcessingRule(false);
 225                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.Subobjects> eroSubs = Lists.newArrayList();
 226                 eroSubs.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.SubobjectsBuilder().setSubobjectType(
 227                                 this.eroASSubobject).setLoose(false).build());
 228                 eroBuilder.setSubobjects(eroSubs);
 229                 this.ero = eroBuilder.build();
 230
 231                 final RroBuilder rroBuilder = new RroBuilder();
 232                 rroBuilder.setIgnore(false);
 233                 rroBuilder.setProcessingRule(false);
 234                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.rro.Subobjects> rroSubs = Lists.newArrayList();
 235                 rroSubs.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.rro.SubobjectsBuilder().setSubobjectType(
 236                                 this.rroUnnumberedSub).setProtectionAvailable(false).setProtectionInUse(false).build());
 237                 rroBuilder.setSubobjects(rroSubs);
 238                 this.rro = rroBuilder.build();
 239
 240                 final OfBuilder ofBuilder = new OfBuilder();
 241                 ofBuilder.setIgnore(false);
 242                 ofBuilder.setProcessingRule(false);
 243                 ofBuilder.setCode(new OfId(0));
 244                 this.of = ofBuilder.build();
 245
 246                 final SrpBuilder srpBuilder = new SrpBuilder();
 247                 srpBuilder.setIgnore(false);
 248                 srpBuilder.setProcessingRule(false);
 249                 srpBuilder.setOperationId(new SrpIdNumber(1L));
 250                 this.srp = srpBuilder.build();
 251
 252                 final LspBuilder lspBuilder = new LspBuilder();
 253                 lspBuilder.setIgnore(false);
 254                 lspBuilder.setProcessingRule(false);
 255                 lspBuilder.setAdministrative(false);
 256                 lspBuilder.setDelegate(false);
 257                 lspBuilder.setPlspId(new PlspId(0L));
 258                 lspBuilder.setOperational(OperationalStatus.Down);
 259                 lspBuilder.setSync(false);
 260                 lspBuilder.setRemove(false);
 261                 lspBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.object.lsp.TlvsBuilder().build());
 262                 this.lsp = lspBuilder.build();
 263         }
 264
 265         @Test
 266         public void testOpenMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
 267                 final byte[] result = ByteArray.fileToBytes("src/test/resources/PCEPOpenMessage1.bin");
 268                 final PCEPOpenMessageParser parser = new PCEPOpenMessageParser(this.objectRegistry);
 269                 final OpenMessageBuilder builder = new OpenMessageBuilder();
 270
 271                 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();
 272                 b.setProcessingRule(false);
 273                 b.setIgnore(false);
 274                 b.setVersion(new ProtocolVersion((short) 1));
 275                 b.setKeepalive((short) 30);
 276                 b.setDeadTimer((short) 120);
 277                 b.setSessionId((short) 1);
 278                 final Stateful tlv1 = new StatefulBuilder().setFlags(new Flags(true, false, true)).build();
 279                 final LspDbVersion tlv2 = new LspDbVersionBuilder().setVersion(BigInteger.valueOf(0x80L)).build();
 280                 b.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().setStateful(
 281                                 tlv1).setLspDbVersion(tlv2).build());
 282                 builder.setOpen(b.build());
 283
 284                 assertEquals(new OpenBuilder().setOpenMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 285                 final ByteBuf buf = Unpooled.buffer(result.length);
 286                 parser.serializeMessage(new OpenBuilder().setOpenMessage(builder.build()).build(), buf);
 287                 assertArrayEquals(result, buf.array());
 288         }
 289
 290         @Test
 291         public void testKeepAliveMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
 292                 final byte[] result = new byte[] { };
 293                 final PCEPKeepAliveMessageParser parser = new PCEPKeepAliveMessageParser(this.objectRegistry);
 294                 final KeepaliveBuilder builder = new KeepaliveBuilder().setKeepaliveMessage(new KeepaliveMessageBuilder().build());
 295
 296                 assertEquals(builder.build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 297                 final ByteBuf buf = Unpooled.buffer(result.length);
 298                 parser.serializeMessage(builder.build(), buf);
 299                 assertArrayEquals(result, buf.array());
 300         }
 301
 302         @Test
 303         public void testCloseMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
 304                 final byte[] result = ByteArray.fileToBytes("src/test/resources/PCEPCloseMessage1.bin");
 305
 306                 final PCEPCloseMessageParser parser = new PCEPCloseMessageParser(this.objectRegistry);
 307                 final CloseBuilder builder = new CloseBuilder().setCCloseMessage(new CCloseMessageBuilder().setCClose(
 308                                 new CCloseBuilder().setIgnore(false).setProcessingRule(false).setReason((short) 5).build()).build());
 309
 310                 assertEquals(builder.build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 311                 final ByteBuf buf = Unpooled.buffer(result.length);
 312                 parser.serializeMessage(builder.build(), buf);
 313                 assertArrayEquals(result, buf.array());
 314         }
 315
 316         // @Test
 317         // public void testRequestMessageValidationFromBin() throws IOException, PCEPDeserializerException,
 318         // PCEPDocumentedException,
 319         // DeserializerException, DocumentedException {
 320         // List<CompositeRequestObject> requests = new ArrayList<CompositeRequestObject>();
 321         // final byte[] ipAdress = { (byte) 0xFF, (byte) 0xFF, (byte) 0xFF, (byte) 0xFF };
 322         // requests.add(new CompositeRequestObject(new PCEPRequestParameterObject(true, false, false, false, false, false,
 323         // false, false, (short) 5, 0xDEADBEEFL, true, false), new PCEPEndPointsObject<IPv4Address>(new
 324         // IPv4Address(ipAdress), new IPv4Address(ipAdress))));
 325         // PCEPRequestMessage specMessage = new PCEPRequestMessage(requests);
 326         // List<Message> deserMsgs = deserMsg("src/test/resources/PCEPRequestMessage1.bin");
 327         // final List<Message> specMessages = Lists.newArrayList();
 328         // specMessages.add(specMessage);
 329         //
 330         // assertEquals(deserMsgs.toString(), specMessages.toString());
 331         //
 332         // requests = new ArrayList<CompositeRequestObject>();
 333         // final byte[] ipAdress2 = { (byte) 0x7F, (byte) 0x00, (byte) 0x00, (byte) 0x01 };
 334         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
 335         // IPv4Address(ipAdress2), new IPv4Address(ipAdress2))));
 336         // specMessage = new PCEPRequestMessage(requests);
 337         // deserMsgs = deserMsg("src/test/resources/PCReq.1.bin");
 338         // specMessages.clear();
 339         // specMessages.add(specMessage);
 340         // assertEquals(deserMsgs.toString(), specMessages.toString());
 341         //
 342         // requests = new ArrayList<CompositeRequestObject>();
 343         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
 344         // IPv4Address(ipAdress2), new IPv4Address(ipAdress2)), null, null, null, null, null, null, null, null, new
 345         // PCEPLoadBalancingObject(3, new Bandwidth(ByteArray.floatToBytes((float) 1024.75)), false)));
 346         // specMessage = new PCEPRequestMessage(requests);
 347         // deserMsgs = deserMsg("src/test/resources/PCReq.2.bin");
 348         // specMessages.clear();
 349         // specMessages.add(specMessage);
 350         // assertEquals(deserMsgs.toString(), specMessages.toString());
 351         //
 352         // requests = new ArrayList<CompositeRequestObject>();
 353         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
 354         // IPv4Address(ipAdress2), new IPv4Address(ipAdress2)), null, new PCEPLspObject(1, false, false, true, false),
 355         // PCEPValidatorTest.lspa, new PCEPRequestedPathBandwidthObject(new Bandwidth(ByteArray.floatToBytes(1000)), false,
 356         // false), new ArrayList<PCEPMetricObject>() {
 357         // private static final long serialVersionUID = 1L;
 358         //
 359         // {
 360         // this.add(new PCEPMetricObject(true, true, new IGPMetric(53L), false, false));
 361         // }
 362         // }, new PCEPReportedRouteObject(this.rroSubobjects, false), new PCEPExistingPathBandwidthObject(new
 363         // Bandwidth(ByteArray.floatToBytes(5353)), false, false), new PCEPIncludeRouteObject(this.eroSubobjects, false,
 364         // false), new PCEPLoadBalancingObject(5, new Bandwidth(ByteArray.floatToBytes(3)), false)));
 365         //
 366         // List<CompositeRequestSvecObject> svecList = new ArrayList<CompositeRequestSvecObject>();
 367         // svecList.add(new CompositeRequestSvecObject(new PCEPSvecObject(true, false, false, false, false, this.requestIds,
 368         // false)));
 369         //
 370         // specMessage = new PCEPRequestMessage(svecList, requests);
 371         // deserMsgs = deserMsg("src/test/resources/PCReq.3.bin");
 372         // specMessages.clear();
 373         // specMessages.add(specMessage);
 374         // // FIXME BUG-89
 375         // // assertEquals(deserMsgs, specMessages);
 376         //
 377         // specMessages.clear();
 378         // requests = new ArrayList<CompositeRequestObject>();
 379         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
 380         // IPv4Address(ipAdress2), new IPv4Address(ipAdress2)), null, null, null, null, null, null, null, null, null));
 381         // specMessages.add(new PCEPRequestMessage(requests));
 382         //
 383         // final byte[] ipAdress3 = { (byte) 0x7F, (byte) 0x00, (byte) 0x30, (byte) 0x01 };
 384         // requests = new ArrayList<CompositeRequestObject>();
 385         // requests.add(new CompositeRequestObject(new PCEPRequestParameterObject(false, false, false, false, false, false,
 386         // false, false, (short) 4, 1, true, false), new PCEPEndPointsObject<IPv4Address>(new IPv4Address(ipAdress3), new
 387         // IPv4Address(ipAdress2)), null, null, null, null, null, null, null, null, null));
 388         // specMessages.add(new PCEPRequestMessage(requests));
 389         //
 390         // final byte[] ipAdress4 = { (byte) 0x7F, (byte) 0x30, (byte) 0x00, (byte) 0x01 };
 391         // requests = new ArrayList<CompositeRequestObject>();
 392         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
 393         // IPv4Address(ipAdress2), new IPv4Address(ipAdress4)), null, null, null, null, null, null, null, null, null));
 394         // specMessages.add(new PCEPRequestMessage(requests));
 395         //
 396         // final byte[] ipAdress5 = { (byte) 0x7F, (byte) 0xd0, (byte) 0x00, (byte) 0x01 };
 397         // requests = new ArrayList<CompositeRequestObject>();
 398         // requests.add(new CompositeRequestObject(new PCEPRequestParameterObject(true, false, false, false, false, false,
 399         // false, false, (short) 1, 1, true, false), new PCEPEndPointsObject<IPv4Address>(new IPv4Address(ipAdress5), new
 400         // IPv4Address(ipAdress5)), null, null, null, null, null, null, null, null, null));
 401         //
 402         // specMessages.add(new PCEPRequestMessage(requests));
 403         // deserMsgs = deserMsg("src/test/resources/PCReq.4.bin");
 404         // assertEquals(deserMsgs.toString(), specMessages.toString());
 405         //
 406         // specMessages.clear();
 407         // svecList = new ArrayList<CompositeRequestSvecObject>();
 408         // svecList.add(new CompositeRequestSvecObject(new PCEPSvecObject(true, false, false, false, false, this.requestIds,
 409         // false)));
 410         // svecList.add(new CompositeRequestSvecObject(new PCEPSvecObject(false, true, true, false, false, this.requestIds,
 411         // false), new PCEPObjectiveFunctionObject(PCEPOFCodes.MCC, true, false), new PCEPGlobalConstraintsObject((short)
 412         // 0x55, (short) 1, (short) 100, (short) 0x26, true, false), new PCEPExcludeRouteObject(new
 413         // ArrayList<ExcludeRouteSubobject>() {
 414         // private static final long serialVersionUID = 1L;
 415         //
 416         // {
 417         // this.add(new XROAsNumberSubobject(new AsNumber((long) 0x12), true));
 418         // }
 419         // }, true, true, false), new ArrayList<PCEPMetricObject>() {
 420         // private static final long serialVersionUID = 1L;
 421         //
 422         // {
 423         // this.add(new PCEPMetricObject(true, true, new TEMetric(123456L), true, false));
 424         // }
 425         // }));
 426         //
 427         // requests = new ArrayList<CompositeRequestObject>();
 428         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
 429         // IPv4Address(ipAdress2), new IPv4Address(ipAdress2)), null, null, PCEPValidatorTest.lspa, new
 430         // PCEPRequestedPathBandwidthObject(new Bandwidth(ByteArray.floatToBytes(1000)), false, false), new
 431         // ArrayList<PCEPMetricObject>() {
 432         // private static final long serialVersionUID = 1L;
 433         //
 434         // {
 435         // this.add(new PCEPMetricObject(true, true, new IGPMetric(53L), false, false));
 436         // this.add(new PCEPMetricObject(true, true, new IGPMetric(5335L), false, false));
 437         // this.add(new PCEPMetricObject(true, true, new IGPMetric(128256), false, false));
 438         // }
 439         // }, new PCEPReportedRouteObject(this.rroSubobjects, false), new PCEPExistingPathBandwidthObject(new
 440         // Bandwidth(ByteArray.floatToBytes(5353)), false, false), new PCEPIncludeRouteObject(this.eroSubobjects, false,
 441         // false), new PCEPLoadBalancingObject(5, new Bandwidth(ByteArray.floatToBytes(3)), false)));
 442         //
 443         // final byte[] ipAdress6 = { (byte) 0x7F, (byte) 0xF0, (byte) 0x00, (byte) 0x01 };
 444         // specMessages.add(new PCEPRequestMessage(svecList, requests));
 445         //
 446         // requests = new ArrayList<CompositeRequestObject>();
 447         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
 448         // IPv4Address(ipAdress6), new IPv4Address(ipAdress6)), null, null, PCEPValidatorTest.lspa, new
 449         // PCEPRequestedPathBandwidthObject(new Bandwidth(ByteArray.floatToBytes(1000)), false, false), new
 450         // ArrayList<PCEPMetricObject>() {
 451         // private static final long serialVersionUID = 1L;
 452         //
 453         // {
 454         // this.add(new PCEPMetricObject(true, true, new IGPMetric(53L), false, false));
 455         // }
 456         // }, new PCEPReportedRouteObject(this.rroSubobjects, false), new PCEPExistingPathBandwidthObject(new
 457         // Bandwidth(ByteArray.floatToBytes(5353)), false, false), new PCEPIncludeRouteObject(this.eroSubobjects, false,
 458         // false), new PCEPLoadBalancingObject(5, new Bandwidth(ByteArray.floatToBytes(3f)), false)));
 459         // deserMsgs = deserMsg("src/test/resources/PCReq.5.bin");
 460         // specMessages.add(new PCEPRequestMessage(svecList, requests));
 461         // // FIXME
 462         // // assertEquals(deserMsgs, specMessages);
 463         //
 464         // // FIXME: need construct with invalid processed parameter
 465         // // assertEquals(deserMsg("src/test/resources/PCReq.6.invalid.bin"),
 466         // // asList(
 467         // // new PCEPErrorMessage(new CompositeErrorObject(new
 468         // // PCEPRequestParameterObject(true, false, false, false, false, false,
 469         // // false, false, (short) 3,
 470         // // 1L, false, false), new PCEPErrorObject(PCEPErrors.P_FLAG_NOT_SET))),
 471         // // new PCEPRequestMessage(asList(new
 472         // // CompositeRequestObject(this.requestParameter, new
 473         // // PCEPEndPointsObject<IPv4Address>(IPv4Address
 474         // // .getNetworkAddressFactory().getNetworkAddressForBytes(new byte[] {
 475         // // 127, 0, 0, 1 }), IPv4Address.getNetworkAddressFactory()
 476         // // .getNetworkAddressForBytes(new byte[] { 127, 0, 0, 1 })), null, null,
 477         // // null, null, null, null, null, null, new PCEPLoadBalancingObject(
 478         // // 3, new Bandwidth(1024.75), false))))));
 479         //
 480         // }
 481         //
 482         // @Test
 483         // public void testRequestMessageValidationFromRawMsg() throws PCEPDeserializerException {
 484         // List<PCEPObject> objs = new ArrayList<PCEPObject>();
 485         // List<Message> msgs;
 486         // PCEPRequestParameterObject tmpRP;
 487         //
 488         // // test unrecognized object in svec list
 489         // objs.add(this.svecObj);
 490         // objs.add(new UnknownObject(true, false, PCEPErrors.UNRECOGNIZED_OBJ_CLASS));
 491         // objs.add(new PCEPSvecObject(true, true, true, false, false, PCEPValidatorTest.this.requestIds, true));
 492         //
 493         // msgs = PCEPMessageValidator.getValidator(PCEPMessageType.REQUEST).validate(objs);
 494         //
 495         // assertEquals(msgs.get(0).toString(), new PCEPErrorMessage(new ArrayList<PCEPErrorObject>() {
 496         // private static final long serialVersionUID = 1L;
 497         //
 498         // {
 499         // this.add(new PCEPErrorObject(PCEPErrors.UNRECOGNIZED_OBJ_CLASS));
 500         // }
 501         // }).toString());
 502         //
 503         // // test with request p flag not set and ignoracion of more than one
 504         // // end-points objects
 505         // objs = new ArrayList<PCEPObject>();
 506         // objs.add(this.svecObj);
 507         // objs.add(this.svecObj);
 508         // tmpRP = new PCEPRequestParameterObject(true, false, false, false, false, false, false, false, (short) 3, 1,
 509         // false, false);
 510         // objs.add(tmpRP);
 511         // objs.add(this.endPoints);
 512         //
 513         // objs.add(this.requestParameter);
 514         // objs.add(this.endPoints);
 515         // objs.add(this.endPoints);
 516         // // FIXME:mv use object constructor with set processed flag
 517         // // objs.add(this.classTypeProvider);
 518         // // objs.add(this.requestParameter);
 519         // // objs.add(this.endPointsProvider);
 520         // // objs.add(new PCEPClassTypeObjectProvider((short) 7, false));
 521         //
 522         // msgs = PCEPMessageValidator.getValidator(PCEPMessageType.REQUEST).validate(objs);
 523         // // FIXME:mv use object constructor with set processed flag
 524         // // assertEquals(msgs.get(0), new PCEPErrorMessage(new
 525         // // CompositeErrorObject(tmpRP, new
 526         // // PCEPErrorObject(PCEPErrors.P_FLAG_NOT_SET))));
 527         // // assertEquals(
 528         // // msgs.get(1),
 529         // // new PCEPRequestMessage(asList(new
 530         // // CompositeRequestSvecObject(this.svecObj), new
 531         // // CompositeRequestSvecObject(this.svecObj)), Util
 532         // // .asList(new CompositeRequestObject(this.requestParameter,
 533         // // this.endPoints, this.classType, null, null, null, null, null, null,
 534         // // null,
 535         // // null))));
 536         // // assertEquals(msgs.get(2), new PCEPErrorMessage(new
 537         // // CompositeErrorObject(tmpRP, new
 538         // // PCEPErrorObject(PCEPErrors.P_FLAG_NOT_SET))));
 539         // }
 540         //
 541
 542         @Test
 543         public void testReplyMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
 544                 // only RP
 545                 byte[] result = ByteArray.fileToBytes("src/test/resources/PCRep.1.bin");
 546
 547                 final PCEPReplyMessageParser parser = new PCEPReplyMessageParser(this.objectRegistry);
 548
 549                 final PcrepMessageBuilder builder = new PcrepMessageBuilder();
 550                 RepliesBuilder rBuilder = new RepliesBuilder();
 551
 552                 final List<Replies> replies1 = Lists.newArrayList();
 553                 rBuilder.setRp(this.rp);
 554                 replies1.add(rBuilder.build());
 555                 builder.setReplies(replies1);
 556
 557                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 558                 ByteBuf buf = Unpooled.buffer(result.length);
 559                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 560                 assertArrayEquals(result, buf.array());
 561
 562                 // simple Failure
 563                 result = ByteArray.fileToBytes("src/test/resources/PCRep.2.bin");
 564                 final List<Replies> replies2 = Lists.newArrayList();
 565                 rBuilder = new RepliesBuilder();
 566                 rBuilder.setRp(this.rp);
 567                 replies2.add(rBuilder.build());
 568                 final RepliesBuilder rBuilder2 = new RepliesBuilder();
 569                 rBuilder2.setRp(this.rp);
 570                 rBuilder2.setResult(new FailureBuilder().setNoPath(this.noPath).build());
 571                 replies2.add(rBuilder2.build());
 572                 builder.setReplies(replies2);
 573
 574                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 575                 buf = Unpooled.buffer(result.length);
 576                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 577                 assertArrayEquals(result, buf.array());
 578
 579                 // Failure with attributes
 580                 result = ByteArray.fileToBytes("src/test/resources/PCRep.3.bin");
 581                 final List<Replies> replies3 = Lists.newArrayList();
 582                 rBuilder = new RepliesBuilder();
 583                 rBuilder.setRp(this.rp);
 584                 rBuilder.setResult(new FailureBuilder().setNoPath(this.noPath).setLspa(this.lspa).setMetrics(Lists.newArrayList(this.metrics)).setIro(
 585                                 this.iro).build());
 586                 replies3.add(rBuilder.build());
 587                 builder.setReplies(replies3);
 588
 589                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 590                 buf = Unpooled.buffer(result.length);
 591                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 592                 assertArrayEquals(result, buf.array());
 593
 594                 // Success
 595                 result = ByteArray.fileToBytes("src/test/resources/PCRep.5.bin");
 596                 final List<Replies> replies4 = Lists.newArrayList();
 597                 rBuilder = new RepliesBuilder();
 598                 rBuilder.setRp(this.rp);
 599                 final List<Paths> paths = Lists.newArrayList();
 600                 final PathsBuilder paBuilder = new PathsBuilder();
 601                 paBuilder.setEro(this.ero);
 602                 paBuilder.setLspa(this.lspa);
 603                 paBuilder.setMetrics(Lists.newArrayList(this.metrics));
 604                 paBuilder.setIro(this.iro);
 605                 paBuilder.setOf(this.of);
 606                 paths.add(paBuilder.build());
 607                 rBuilder.setResult(new SuccessBuilder().setPaths(paths).build()).build();
 608                 replies4.add(rBuilder.build());
 609                 builder.setReplies(replies4);
 610
 611                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 612                 buf = Unpooled.buffer(result.length);
 613                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 614                 assertArrayEquals(result, buf.array());
 615         }
 616
 617         @Test
 618         public void testUpdMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
 619                 byte[] result = ByteArray.fileToBytes("src/test/resources/PCUpd.2.bin");
 620
 621                 final PCEPUpdateRequestMessageParser parser = new PCEPUpdateRequestMessageParser(this.objectRegistry);
 622
 623                 final PcupdMessageBuilder builder = new PcupdMessageBuilder();
 624
 625                 final List<Updates> updates = Lists.newArrayList();
 626                 final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.updates.PathBuilder pBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.updates.PathBuilder();
 627                 pBuilder.setEro(this.ero);
 628                 pBuilder.setLspa(this.lspa);
 629                 updates.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 630                 builder.setUpdates(updates);
 631
 632                 assertEquals(new PcupdBuilder().setPcupdMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 633                 ByteBuf buf = Unpooled.buffer(result.length);
 634                 parser.serializeMessage(new PcupdBuilder().setPcupdMessage(builder.build()).build(), buf);
 635                 assertArrayEquals(result, buf.array());
 636
 637                 result = ByteArray.fileToBytes("src/test/resources/PCUpd.5.bin");
 638
 639                 final List<Updates> updates1 = Lists.newArrayList();
 640                 final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.updates.PathBuilder pBuilder1 = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.updates.PathBuilder();
 641                 pBuilder1.setEro(this.ero);
 642                 pBuilder1.setLspa(this.lspa);
 643                 updates1.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 644                 updates1.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder1.build()).build());
 645                 builder.setUpdates(updates1);
 646
 647                 assertEquals(new PcupdBuilder().setPcupdMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 648                 buf = Unpooled.buffer(result.length);
 649                 parser.serializeMessage(new PcupdBuilder().setPcupdMessage(builder.build()).build(), buf);
 650                 assertArrayEquals(result, buf.array());
 651         }
 652
 653         @Test
 654         public void testRptMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
 655                 byte[] result = ByteArray.fileToBytes("src/test/resources/PCRpt.1.bin");
 656
 657                 final PCEPReportMessageParser parser = new PCEPReportMessageParser(this.objectRegistry);
 658
 659                 final PcrptMessageBuilder builder = new PcrptMessageBuilder();
 660
 661                 final List<Reports> reports = Lists.newArrayList();
 662                 reports.add(new ReportsBuilder().setLsp(this.lsp).build());
 663                 builder.setReports(reports);
 664
 665                 assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 666                 ByteBuf buf = Unpooled.buffer(result.length);
 667                 parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 668                 assertArrayEquals(result, buf.array());
 669
 670                 result = ByteArray.fileToBytes("src/test/resources/PCRpt.2.bin");
 671
 672                 final List<Reports> reports1 = Lists.newArrayList();
 673                 reports1.add(new ReportsBuilder().setLsp(this.lsp).setPath(new PathBuilder().setEro(this.ero).setLspa(this.lspa).build()).build());
 674                 builder.setReports(reports1);
 675
 676                 assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 677                 buf = Unpooled.buffer(result.length);
 678                 parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 679                 assertArrayEquals(result, buf.array());
 680
 681                 result = ByteArray.fileToBytes("src/test/resources/PCRpt.3.bin");
 682
 683                 final List<Reports> reports2 = Lists.newArrayList();
 684                 final PathBuilder pBuilder = new PathBuilder();
 685                 pBuilder.setEro(this.ero);
 686                 pBuilder.setLspa(this.lspa);
 687                 pBuilder.setMetrics(Lists.newArrayList(this.metrics, this.metrics));
 688                 pBuilder.setRro(this.rro);
 689                 reports2.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 690                 builder.setReports(reports2);
 691
 692                 assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 693                 buf = Unpooled.buffer(result.length);
 694                 parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 695                 assertArrayEquals(result, buf.array());
 696
 697                 result = ByteArray.fileToBytes("src/test/resources/PCRpt.5.bin");
 698
 699                 final List<Reports> reports3 = Lists.newArrayList();
 700                 final PathBuilder pBuilder1 = new PathBuilder();
 701                 pBuilder1.setEro(this.ero);
 702                 pBuilder1.setLspa(this.lspa);
 703                 pBuilder1.setMetrics(Lists.newArrayList(this.metrics, this.metrics));
 704                 pBuilder1.setRro(this.rro);
 705                 reports3.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 706                 reports3.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder1.build()).build());
 707                 builder.setReports(reports3);
 708
 709                 assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 710                 buf = Unpooled.buffer(result.length);
 711                 parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 712                 assertArrayEquals(result, buf.array());
 713         }
 714
 715         @Test
 716         public void testPcinitMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
 717                 final byte[] result = ByteArray.fileToBytes("src/test/resources/Pcinit.bin");
 718
 719                 final PcinitiateMessageParser parser = new PcinitiateMessageParser(this.objectRegistry);
 720
 721                 final PcinitiateMessageBuilder builder = new PcinitiateMessageBuilder();
 722                 final RequestsBuilder rBuilder = new RequestsBuilder();
 723
 724                 final List<Requests> reqs = Lists.newArrayList();
 725                 rBuilder.setSrp(this.srp);
 726                 rBuilder.setLsp(this.lsp);
 727                 rBuilder.setEro(this.ero);
 728                 rBuilder.setLspa(this.lspa);
 729                 rBuilder.setMetrics(Lists.newArrayList(this.metrics));
 730                 rBuilder.setIro(this.iro);
 731                 reqs.add(rBuilder.build());
 732                 builder.setRequests(reqs);
 733
 734                 assertEquals(new PcinitiateBuilder().setPcinitiateMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 735                 final ByteBuf buf = Unpooled.buffer(result.length);
 736                 parser.serializeMessage(new PcinitiateBuilder().setPcinitiateMessage(builder.build()).build(), buf);
 737                 assertArrayEquals(result, buf.array());
 738         }
 739
 740         @Test
 741         public void testNotificationMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
 742                 final CNotification cn1 = new CNotificationBuilder().setIgnore(false).setProcessingRule(false).setType((short) 1).setValue(
 743                                 (short) 1).build();
 744
 745                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Notifications> innerNot = Lists.newArrayList();
 746                 innerNot.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 747                                 cn1).build());
 748                 final List<Rps> rps = Lists.newArrayList();
 749                 rps.add(new RpsBuilder().setRp(this.rp).build());
 750
 751                 final byte[] result = ByteArray.fileToBytes("src/test/resources/PCNtf.5.bin");
 752
 753                 final PCEPNotificationMessageParser parser = new PCEPNotificationMessageParser(this.objectRegistry);
 754                 final PcntfMessageBuilder builder = new PcntfMessageBuilder();
 755
 756                 final List<Notifications> nots = Lists.newArrayList();
 757                 final NotificationsBuilder b = new NotificationsBuilder();
 758                 b.setNotifications(innerNot);
 759                 b.setRps(rps);
 760                 nots.add(b.build());
 761
 762                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Notifications> innerNot1 = Lists.newArrayList();
 763                 innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 764                                 cn1).build());
 765                 innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 766                                 cn1).build());
 767                 final List<Rps> rps1 = Lists.newArrayList();
 768                 rps1.add(new RpsBuilder().setRp(this.rp).build());
 769                 rps1.add(new RpsBuilder().setRp(this.rp).build());
 770
 771                 b.setNotifications(innerNot1);
 772                 b.setRps(rps1);
 773                 nots.add(b.build());
 774                 builder.setNotifications(nots);
 775
 776                 assertEquals(new PcntfBuilder().setPcntfMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 777                 final ByteBuf buf = Unpooled.buffer(result.length);
 778                 parser.serializeMessage(new PcntfBuilder().setPcntfMessage(builder.build()).build(), buf);
 779                 assertArrayEquals(result, buf.array());
 780         }
 781
 782         @Test
 783         public void testErrorMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
 784                 byte[] result = ByteArray.fileToBytes("src/test/resources/PCErr.3.bin");
 785
 786                 final ErrorObject error1 = new ErrorObjectBuilder().setIgnore(false).setProcessingRule(false).setType((short) 3).setValue((short) 1).build();
 787
 788                 final PCEPErrorMessageParser parser = new PCEPErrorMessageParser(this.objectRegistry);
 789
 790                 List<Errors> innerErr = Lists.newArrayList();
 791                 innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
 792
 793                 final PcerrMessageBuilder builder = new PcerrMessageBuilder();
 794                 builder.setErrors(innerErr);
 795                 builder.setErrorType(new SessionBuilder().setOpen(this.open).build());
 796
 797                 assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 798                 ByteBuf buf = Unpooled.buffer(result.length);
 799                 parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
 800                 assertArrayEquals(result, buf.array());
 801
 802                 result = ByteArray.fileToBytes("src/test/resources/PCErr.5.bin");
 803
 804                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request.Rps> rps = Lists.newArrayList();
 805                 rps.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request.RpsBuilder().setRp(
 806                                 this.rp).build());
 807
 808                 innerErr = Lists.newArrayList();
 809                 innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
 810
 811                 builder.setErrors(innerErr);
 812                 builder.setErrorType(new RequestBuilder().setRps(rps).build());
 813
 814                 assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
 815                 buf = Unpooled.buffer(result.length);
 816                 parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
 817                 assertArrayEquals(result, buf.array());
 818         }
 819 }