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 static org.junit.Assert.fail;
  13
  14 import com.google.common.collect.Lists;
  15 import io.netty.buffer.ByteBuf;
  16 import io.netty.buffer.Unpooled;
  17 import java.io.IOException;
  18 import java.util.ArrayList;
  19 import java.util.Collections;
  20 import java.util.List;
  21 import org.junit.Before;
  22 import org.junit.Test;
  23 import org.opendaylight.protocol.pcep.impl.TestVendorInformationTlvParser.TestEnterpriseSpecificInformation;
  24 import org.opendaylight.protocol.pcep.parser.BaseParserExtensionActivator;
  25 import org.opendaylight.protocol.pcep.parser.message.PCEPCloseMessageParser;
  26 import org.opendaylight.protocol.pcep.parser.message.PCEPErrorMessageParser;
  27 import org.opendaylight.protocol.pcep.parser.message.PCEPKeepAliveMessageParser;
  28 import org.opendaylight.protocol.pcep.parser.message.PCEPMonitoringReplyMessageParser;
  29 import org.opendaylight.protocol.pcep.parser.message.PCEPMonitoringRequestMessageParser;
  30 import org.opendaylight.protocol.pcep.parser.message.PCEPNotificationMessageParser;
  31 import org.opendaylight.protocol.pcep.parser.message.PCEPOpenMessageParser;
  32 import org.opendaylight.protocol.pcep.parser.message.PCEPReplyMessageParser;
  33 import org.opendaylight.protocol.pcep.parser.message.PCEPRequestMessageParser;
  34 import org.opendaylight.protocol.pcep.parser.message.PCEPStartTLSMessageParser;
  35 import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
  36 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
  37 import org.opendaylight.protocol.pcep.spi.pojo.SimplePCEPExtensionProviderContext;
  38 import org.opendaylight.protocol.util.ByteArray;
  39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
  40 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.iana.rev130816.EnterpriseNumber;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ieee754.rev130819.Float32;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.CloseBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.KeepaliveBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.OpenBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcerrBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcmonrepBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcmonreqBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcntfBuilder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcrepBuilder;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcreqBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.StarttlsBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.OfId;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.ProtocolVersion;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.RequestId;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.message.CCloseMessageBuilder;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.object.CCloseBuilder;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.object.c.close.TlvsBuilder;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.address.family.Ipv4CaseBuilder;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.address.family.ipv4._case.Ipv4Builder;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.object.EndpointsObj;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.object.EndpointsObjBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.Ero;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.EroBuilder;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.Iro;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.IroBuilder;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.Subobject;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.SubobjectBuilder;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.keepalive.message.KeepaliveMessageBuilder;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.Metrics;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.MetricsBuilder;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.Lspa;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.LspaBuilder;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.metric.object.MetricBuilder;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.metrics.MetricPce;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.metrics.MetricPceBuilder;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.object.Monitoring;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.object.Monitoring.Flags;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.object.MonitoringBuilder;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.response.monitoring.metrics.list.GeneralMetricsListBuilder;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.response.monitoring.metrics.list.SpecificMetricsListBuilder;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.response.monitoring.metrics.list.specific.metrics.list.SpecificMetricsBuilder;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotification;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotificationBuilder;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.Of;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.OfBuilder;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.message.OpenMessageBuilder;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.Open;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.overload.object.Overload;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.overload.object.OverloadBuilder;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcc.id.req.object.PccIdReq;
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcc.id.req.object.PccIdReqBuilder;
  93 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pce.id.object.PceId;
  94 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pce.id.object.PceIdBuilder;
  95 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObject;
  96 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObjectBuilder;
  97 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.PcerrMessageBuilder;
  98 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.Errors;
  99 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.ErrorsBuilder;
 100 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.RequestCaseBuilder;
 101 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.SessionCaseBuilder;
 102 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request._case.RequestBuilder;
 103 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.session._case.SessionBuilder;
 104 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcmonrep.message.PcmonrepMessageBuilder;
 105 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.PcntfMessageBuilder;
 106 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.Notifications;
 107 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.NotificationsBuilder;
 108 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Rps;
 109 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.RpsBuilder;
 110 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.PcrepMessageBuilder;
 111 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.Replies;
 112 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.RepliesBuilder;
 113 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.FailureCaseBuilder;
 114 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.SuccessCaseBuilder;
 115 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure._case.NoPath;
 116 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure._case.NoPathBuilder;
 117 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.SuccessBuilder;
 118 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.success.Paths;
 119 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.success.PathsBuilder;
 120 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.PcreqMessageBuilder;
 121 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.MonitoringRequestBuilder;
 122 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.monitoring.request.PceIdList;
 123 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.monitoring.request.PceIdListBuilder;
 124 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.requests.SegmentComputationBuilder;
 125 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.requests.segment.computation.P2pBuilder;
 126 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.proc.time.object.ProcTime;
 127 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.proc.time.object.ProcTimeBuilder;
 128 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.Rp;
 129 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.RpBuilder;
 130 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.start.tls.message.StartTlsMessageBuilder;
 131 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.svec.object.Svec;
 132 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.svec.object.SvecBuilder;
 133 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.vendor.information.objects.VendorInformationObject;
 134 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.vendor.information.objects.VendorInformationObjectBuilder;
 135 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.AttributeFilter;
 136 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.basic.explicit.route.subobjects.subobject.type.AsNumberCase;
 137 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.basic.explicit.route.subobjects.subobject.type.AsNumberCaseBuilder;
 138 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.basic.explicit.route.subobjects.subobject.type.as.number._case.AsNumberBuilder;
 139
 140 public class PCEPValidatorTest {
 141
 142     private ObjectRegistry objectRegistry;
 143
 144     private Open open;
 145     private Rp rpTrue;
 146     private Rp rpFalse;
 147     private NoPath noPath;
 148     private Lspa lspa;
 149     private Metrics metrics;
 150     private Iro iro;
 151     private Ero ero;
 152     private Of of;
 153     private EndpointsObj endpoints;
 154     private Svec svec;
 155     private List<VendorInformationObject> viObjects;
 156     private Monitoring monitoring;
 157     private PccIdReq pccIdReq;
 158     private PceId pceId;
 159     private ProcTime procTime;
 160     private Overload overload;
 161
 162     private AsNumberCase eroASSubobject;
 163
 164     private SimplePCEPExtensionProviderContext ctx;
 165     private BaseParserExtensionActivator act;
 166     private TestVendorInformationActivator viObjAct;
 167
 168     @Before
 169     public void setUp() throws Exception {
 170         this.ctx = new SimplePCEPExtensionProviderContext();
 171         this.act = new BaseParserExtensionActivator();
 172         this.viObjAct = new TestVendorInformationActivator();
 173         this.act.start(this.ctx);
 174         this.viObjAct.start(this.ctx);
 175         this.objectRegistry = this.ctx.getObjectHandlerRegistry();
 176         final RpBuilder rpBuilder = new RpBuilder();
 177         rpBuilder.setProcessingRule(true);
 178         rpBuilder.setIgnore(false);
 179         rpBuilder.setReoptimization(false);
 180         rpBuilder.setBiDirectional(false);
 181         rpBuilder.setLoose(true);
 182         rpBuilder.setMakeBeforeBreak(false);
 183         rpBuilder.setOrder(false);
 184         rpBuilder.setPathKey(false);
 185         rpBuilder.setSupplyOf(false);
 186         rpBuilder.setFragmentation(false);
 187         rpBuilder.setP2mp(false);
 188         rpBuilder.setEroCompression(false);
 189         rpBuilder.setPriority((short) 1);
 190         rpBuilder.setRequestId(new RequestId(10L));
 191         rpBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.rp.TlvsBuilder().build());
 192         this.rpTrue = rpBuilder.build();
 193         rpBuilder.setProcessingRule(false);
 194         this.rpFalse = rpBuilder.build();
 195
 196         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();
 197         openBuilder.setProcessingRule(false);
 198         openBuilder.setIgnore(false);
 199         openBuilder.setDeadTimer((short) 1);
 200         openBuilder.setKeepalive((short) 1);
 201         openBuilder.setSessionId((short) 0);
 202         openBuilder.setVersion(new ProtocolVersion((short) 1));
 203         openBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().build());
 204         this.open = openBuilder.build();
 205
 206         final NoPathBuilder npbuilder = new NoPathBuilder();
 207         npbuilder.setProcessingRule(false);
 208         npbuilder.setIgnore(false);
 209         npbuilder.setNatureOfIssue((short) 0);
 210         npbuilder.setUnsatisfiedConstraints(false);
 211         npbuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure._case.no.path.TlvsBuilder().build());
 212         this.noPath = npbuilder.build();
 213
 214         final LspaBuilder lspaBuilder = new LspaBuilder();
 215         lspaBuilder.setProcessingRule(false);
 216         lspaBuilder.setIgnore(false);
 217         lspaBuilder.setLocalProtectionDesired(false);
 218         lspaBuilder.setHoldPriority((short) 0);
 219         lspaBuilder.setSetupPriority((short) 0);
 220         lspaBuilder.setExcludeAny(new AttributeFilter(0L));
 221         lspaBuilder.setIncludeAll(new AttributeFilter(0L));
 222         lspaBuilder.setIncludeAny(new AttributeFilter(0L));
 223         lspaBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.lspa.TlvsBuilder().build());
 224         this.lspa = lspaBuilder.build();
 225
 226         final MetricBuilder mBuilder = new MetricBuilder();
 227         mBuilder.setIgnore(false);
 228         mBuilder.setProcessingRule(false);
 229         mBuilder.setComputed(false);
 230         mBuilder.setBound(false);
 231         mBuilder.setMetricType((short) 1);
 232         mBuilder.setValue(new Float32(new byte[4]));
 233         this.metrics = new MetricsBuilder().setMetric(mBuilder.build()).build();
 234
 235         this.eroASSubobject = new AsNumberCaseBuilder().setAsNumber(
 236             new AsNumberBuilder().setAsNumber(
 237                 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber(0xFFFFL)).build()).build();
 238
 239         final IroBuilder iroBuilder = new IroBuilder();
 240         iroBuilder.setIgnore(false);
 241         iroBuilder.setProcessingRule(false);
 242         final List<Subobject> iroSubs = Lists.newArrayList();
 243         iroSubs.add(new SubobjectBuilder().setSubobjectType(this.eroASSubobject).setLoose(false).build());
 244         iroBuilder.setSubobject(iroSubs);
 245         this.iro = iroBuilder.build();
 246
 247         final EroBuilder eroBuilder = new EroBuilder();
 248         eroBuilder.setIgnore(false);
 249         eroBuilder.setProcessingRule(false);
 250         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.Subobject> eroSubs = Lists.newArrayList();
 251         eroSubs.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.SubobjectBuilder().setSubobjectType(
 252             this.eroASSubobject).setLoose(false).build());
 253         eroBuilder.setSubobject(eroSubs);
 254         this.ero = eroBuilder.build();
 255
 256         final OfBuilder ofBuilder = new OfBuilder();
 257         ofBuilder.setIgnore(false);
 258         ofBuilder.setProcessingRule(false);
 259         ofBuilder.setCode(new OfId(0));
 260         ofBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.of.TlvsBuilder().build());
 261         this.of = ofBuilder.build();
 262
 263         final Ipv4Builder afi = new Ipv4Builder();
 264         afi.setSourceIpv4Address(new Ipv4Address("255.255.255.255"));
 265         afi.setDestinationIpv4Address(new Ipv4Address("255.255.255.255"));
 266
 267         final EndpointsObjBuilder epBuilder = new EndpointsObjBuilder();
 268         epBuilder.setIgnore(false);
 269         epBuilder.setProcessingRule(true);
 270         epBuilder.setAddressFamily(new Ipv4CaseBuilder().setIpv4(afi.build()).build());
 271         this.endpoints = epBuilder.build();
 272
 273         final SvecBuilder sBuilder = new SvecBuilder();
 274         sBuilder.setIgnore(false);
 275         sBuilder.setProcessingRule(false);
 276         sBuilder.setLinkDiverse(false);
 277         sBuilder.setNodeDiverse(false);
 278         sBuilder.setSrlgDiverse(false);
 279         sBuilder.setRequestsIds(Lists.newArrayList(new RequestId(1L)));
 280         this.svec = sBuilder.build();
 281
 282         this.viObjects = Lists.newArrayList();
 283         final TestEnterpriseSpecificInformation esInfo = new TestEnterpriseSpecificInformation(5);
 284         final VendorInformationObject viObj = new VendorInformationObjectBuilder().setEnterpriseNumber(new EnterpriseNumber(0L))
 285                 .setEnterpriseSpecificInformation(esInfo).build();
 286         this.viObjects.add(viObj);
 287
 288         this.monitoring = new MonitoringBuilder()
 289                 .setMonitoringId(100L)
 290                 .setFlags(new Flags(false, false, false, false, false))
 291                 .setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.object.monitoring.TlvsBuilder().build()).build();
 292         this.pccIdReq = new PccIdReqBuilder().setIpAddress(new IpAddress(new Ipv4Address("127.0.0.1"))).build();
 293         this.pceId = new PceIdBuilder().setIpAddress(new IpAddress(new Ipv4Address("127.0.0.2"))).build();
 294
 295         final ProcTimeBuilder procTimeBuilder = new ProcTimeBuilder();
 296         procTimeBuilder.setEstimated(false);
 297         procTimeBuilder.setCurrentProcTime(1L);
 298         procTimeBuilder.setMinProcTime(2L);
 299         procTimeBuilder.setMaxProcTime(3L);
 300         procTimeBuilder.setAverageProcTime(4L);
 301         procTimeBuilder.setVarianceProcTime(5L);
 302         this.procTime = procTimeBuilder.build();
 303         this.overload = new OverloadBuilder().setDuration(120).build();
 304     }
 305
 306     @Test
 307     public void testOpenMsg() throws IOException, PCEPDeserializerException {
 308         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPOpenMessage1.bin"));
 309         final PCEPOpenMessageParser parser = new PCEPOpenMessageParser(this.ctx.getObjectHandlerRegistry());
 310         final OpenMessageBuilder builder = new OpenMessageBuilder();
 311
 312         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();
 313         b.setProcessingRule(false);
 314         b.setIgnore(false);
 315         b.setVersion(new ProtocolVersion((short) 1));
 316         b.setKeepalive((short) 30);
 317         b.setDeadTimer((short) 120);
 318         b.setSessionId((short) 1);
 319         b.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().build());
 320         builder.setOpen(b.build());
 321
 322         assertEquals(new OpenBuilder().setOpenMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 323             result.readableBytes() - 4), Collections.emptyList()));
 324         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 325         parser.serializeMessage(new OpenBuilder().setOpenMessage(builder.build()).build(), buf);
 326         assertArrayEquals(result.array(), buf.array());
 327
 328         try {
 329             parser.serializeMessage(new OpenBuilder().setOpenMessage(new OpenMessageBuilder().build()).build(), null);
 330             fail();
 331         } catch (final IllegalArgumentException e) {
 332             assertEquals("Open Object must be present in Open Message.", e.getMessage());
 333         }
 334     }
 335
 336     @Test
 337     public void testKeepAliveMsg() throws IOException, PCEPDeserializerException {
 338         final ByteBuf result = Unpooled.wrappedBuffer(new byte[] { 32, 2, 0, 4 });
 339         final PCEPKeepAliveMessageParser parser = new PCEPKeepAliveMessageParser(this.objectRegistry);
 340         final KeepaliveBuilder builder = new KeepaliveBuilder().setKeepaliveMessage(new KeepaliveMessageBuilder().build());
 341
 342         assertEquals(builder.build(), parser.parseMessage(result.slice(4, result.readableBytes() - 4), Collections.emptyList()));
 343         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 344         parser.serializeMessage(builder.build(), buf);
 345         assertArrayEquals(result.array(), buf.array());
 346     }
 347
 348     @Test
 349     public void testStartTLSMsg() throws Exception {
 350         final ByteBuf result = Unpooled.wrappedBuffer(new byte[] { 32, 20, 0, 4 });
 351         final PCEPStartTLSMessageParser parser = new PCEPStartTLSMessageParser(this.objectRegistry);
 352         final StarttlsBuilder builder = new StarttlsBuilder().setStartTlsMessage(new StartTlsMessageBuilder().build());
 353
 354         assertEquals(builder.build(), parser.parseMessage(result.slice(4, result.readableBytes() - 4), Collections.emptyList()));
 355         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 356         parser.serializeMessage(builder.build(), buf);
 357         assertArrayEquals(result.array(), buf.array());
 358     }
 359
 360     @Test
 361     public void testCloseMsg() throws IOException, PCEPDeserializerException {
 362         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPCloseMessage1.bin"));
 363
 364         final PCEPCloseMessageParser parser = new PCEPCloseMessageParser(this.objectRegistry);
 365         final CloseBuilder builder = new CloseBuilder().setCCloseMessage(new CCloseMessageBuilder().setCClose(
 366             new CCloseBuilder().setIgnore(false).setProcessingRule(false).setReason((short) 5).setTlvs(new TlvsBuilder().build()).build()).build());
 367
 368         assertEquals(builder.build(), parser.parseMessage(result.slice(4, result.readableBytes() - 4), Collections.emptyList()));
 369         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 370         parser.serializeMessage(builder.build(), buf);
 371         assertArrayEquals(result.array(), buf.array());
 372
 373         try {
 374             parser.serializeMessage(new CloseBuilder().setCCloseMessage(new CCloseMessageBuilder().build()).build(), null);
 375             fail();
 376         } catch (final IllegalArgumentException e) {
 377             assertEquals("Close Object must be present in Close Message.", e.getMessage());
 378         }
 379     }
 380
 381     @Test
 382     public void testRequestMsg() throws IOException, PCEPDeserializerException {
 383         ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPRequestMessage1.bin"));
 384
 385         final PCEPRequestMessageParser parser = new PCEPRequestMessageParser(this.objectRegistry);
 386
 387         final PcreqMessageBuilder builder = new PcreqMessageBuilder();
 388         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs1 = Lists.newArrayList();
 389         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder rBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder();
 390         rBuilder.setRp(this.rpTrue);
 391         rBuilder.setSegmentComputation(new SegmentComputationBuilder().setP2p(new P2pBuilder().setEndpointsObj(this.endpoints).build()).build());
 392         reqs1.add(rBuilder.build());
 393         builder.setRequests(reqs1);
 394
 395         assertEquals(new PcreqBuilder().setPcreqMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 396             result.readableBytes() - 4), Collections.emptyList()));
 397         ByteBuf buf = Unpooled.buffer(result.readableBytes());
 398         parser.serializeMessage(new PcreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 399
 400         assertArrayEquals(result.array(), buf.array());
 401
 402         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCReq.3.bin"));
 403
 404         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs2 = Lists.newArrayList();
 405         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder rBuilder1 = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder();
 406         rBuilder1.setRp(this.rpTrue);
 407         final P2pBuilder p2pBuilder = new P2pBuilder();
 408         p2pBuilder.setEndpointsObj(this.endpoints);
 409         p2pBuilder.setMetrics(Lists.newArrayList(this.metrics));
 410         p2pBuilder.setIro(this.iro);
 411         rBuilder1.setSegmentComputation(new SegmentComputationBuilder().setP2p(p2pBuilder.build()).build());
 412         reqs2.add(rBuilder1.build());
 413         builder.setRequests(reqs2);
 414         builder.setSvec(Lists.newArrayList(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.SvecBuilder().setSvec(
 415             this.svec).build()));
 416
 417         assertEquals(new PcreqBuilder().setPcreqMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 418             result.readableBytes() - 4), Collections.emptyList()));
 419         buf = Unpooled.buffer(result.readableBytes());
 420         parser.serializeMessage(new PcreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 421         assertArrayEquals(result.array(), buf.array());
 422
 423         try {
 424             parser.serializeMessage(new PcreqBuilder().setPcreqMessage(new PcreqMessageBuilder().build()).build(), null);
 425             fail();
 426         } catch (final IllegalArgumentException e) {
 427             assertEquals("Requests cannot be null or empty.", e.getMessage());
 428         }
 429         try {
 430             parser.serializeMessage(new PcreqBuilder().setPcreqMessage(new PcreqMessageBuilder().setRequests(Collections.emptyList()).build()).build(), null);
 431             fail();
 432         } catch (final IllegalArgumentException e) {
 433             assertEquals("Requests cannot be null or empty.", e.getMessage());
 434         }
 435     }
 436
 437     @Test
 438     public void testReplyMsg() throws IOException, PCEPDeserializerException {
 439         // only RP
 440         ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.1.bin"));
 441
 442         final PCEPReplyMessageParser parser = new PCEPReplyMessageParser(this.objectRegistry);
 443
 444         final PcrepMessageBuilder builder = new PcrepMessageBuilder();
 445         RepliesBuilder rBuilder = new RepliesBuilder();
 446
 447         final List<Replies> replies1 = Lists.newArrayList();
 448         rBuilder.setRp(this.rpTrue);
 449         replies1.add(rBuilder.build());
 450         builder.setReplies(replies1);
 451
 452         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 453             result.readableBytes() - 4), Collections.emptyList()));
 454         ByteBuf buf = Unpooled.buffer(result.readableBytes());
 455         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 456         assertArrayEquals(result.array(), buf.array());
 457
 458         // simple Failure
 459         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.2.bin"));
 460         final List<Replies> replies2 = Lists.newArrayList();
 461         rBuilder = new RepliesBuilder();
 462         rBuilder.setRp(this.rpTrue);
 463         replies2.add(rBuilder.build());
 464         final RepliesBuilder rBuilder2 = new RepliesBuilder();
 465         rBuilder2.setRp(this.rpTrue);
 466         rBuilder2.setResult(new FailureCaseBuilder().setNoPath(this.noPath).build());
 467         replies2.add(rBuilder2.build());
 468         builder.setReplies(replies2);
 469
 470         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 471             result.readableBytes() - 4), Collections.emptyList()));
 472         buf = Unpooled.buffer(result.readableBytes());
 473         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 474         assertArrayEquals(result.array(), buf.array());
 475
 476         // Failure with attributes
 477         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.3.bin"));
 478         final List<Replies> replies3 = Lists.newArrayList();
 479         rBuilder = new RepliesBuilder();
 480         rBuilder.setRp(this.rpTrue);
 481         rBuilder.setResult(new FailureCaseBuilder().setNoPath(this.noPath).setLspa(this.lspa).setMetrics(Lists.newArrayList(this.metrics)).setIro(
 482             this.iro).build());
 483         replies3.add(rBuilder.build());
 484         builder.setReplies(replies3);
 485
 486         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 487             result.readableBytes() - 4), Collections.emptyList()));
 488         buf = Unpooled.buffer(result.readableBytes());
 489         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 490         assertArrayEquals(result.array(), buf.array());
 491
 492         // Success
 493         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.5.bin"));
 494         final List<Replies> replies4 = Lists.newArrayList();
 495         rBuilder = new RepliesBuilder();
 496         rBuilder.setRp(this.rpTrue);
 497         final List<Paths> paths = Lists.newArrayList();
 498         final PathsBuilder paBuilder = new PathsBuilder();
 499         paBuilder.setEro(this.ero);
 500         paBuilder.setLspa(this.lspa);
 501         paBuilder.setMetrics(Lists.newArrayList(this.metrics));
 502         paBuilder.setIro(this.iro);
 503         paBuilder.setOf(this.of);
 504         paths.add(paBuilder.build());
 505         rBuilder.setResult(new SuccessCaseBuilder().setSuccess(new SuccessBuilder().setPaths(paths).build()).build()).build();
 506         replies4.add(rBuilder.build());
 507         builder.setReplies(replies4);
 508
 509         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 510             result.readableBytes() - 4), Collections.emptyList()));
 511         buf = Unpooled.buffer(result.readableBytes());
 512         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 513         assertArrayEquals(result.array(), buf.array());
 514
 515         try {
 516             parser.serializeMessage(new PcrepBuilder().setPcrepMessage(new PcrepMessageBuilder().build()).build(), null);
 517             fail();
 518         } catch (final IllegalArgumentException e) {
 519             assertEquals("Replies cannot be null or empty.", e.getMessage());
 520         }
 521         try {
 522             parser.serializeMessage(new PcrepBuilder().setPcrepMessage(new PcrepMessageBuilder().setReplies(Collections.emptyList()).build()).build(), null);
 523             fail();
 524         } catch (final IllegalArgumentException e) {
 525             assertEquals("Replies cannot be null or empty.", e.getMessage());
 526         }
 527     }
 528
 529     @Test
 530     public void testNotificationMsg() throws IOException, PCEPDeserializerException {
 531         final CNotification cn1 = new CNotificationBuilder().setIgnore(false).setProcessingRule(false).setType((short) 1).setValue(
 532             (short) 1).build();
 533
 534         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();
 535         innerNot.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 536             cn1).build());
 537         final List<Rps> rps = Lists.newArrayList();
 538         rps.add(new RpsBuilder().setRp(this.rpFalse).build());
 539
 540         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCNtf.5.bin"));
 541
 542         final PCEPNotificationMessageParser parser = new PCEPNotificationMessageParser(this.objectRegistry);
 543         final PcntfMessageBuilder builder = new PcntfMessageBuilder();
 544
 545         final List<Notifications> nots = Lists.newArrayList();
 546         final NotificationsBuilder b = new NotificationsBuilder();
 547         b.setNotifications(innerNot);
 548         b.setRps(rps);
 549         nots.add(b.build());
 550
 551         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();
 552         innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 553             cn1).build());
 554         innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 555             cn1).build());
 556         final List<Rps> rps1 = Lists.newArrayList();
 557         rps1.add(new RpsBuilder().setRp(this.rpFalse).build());
 558         rps1.add(new RpsBuilder().setRp(this.rpFalse).build());
 559
 560         b.setNotifications(innerNot1);
 561         b.setRps(rps1);
 562         nots.add(b.build());
 563         builder.setNotifications(nots);
 564
 565         assertEquals(new PcntfBuilder().setPcntfMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 566             result.readableBytes() - 4), Collections.emptyList()));
 567         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 568         parser.serializeMessage(new PcntfBuilder().setPcntfMessage(builder.build()).build(), buf);
 569         assertArrayEquals(result.array(), buf.array());
 570     }
 571
 572     @Test
 573     public void testErrorMsg() throws IOException, PCEPDeserializerException {
 574         ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCErr.5.bin"));
 575
 576         ErrorObject error1 = new ErrorObjectBuilder().setIgnore(false).setProcessingRule(false).setType((short) 3).setValue((short) 1).build();
 577
 578         final PCEPErrorMessageParser parser = new PCEPErrorMessageParser(this.ctx.getObjectHandlerRegistry());
 579
 580         List<Errors> innerErr = new ArrayList<>();
 581
 582         final PcerrMessageBuilder builder = new PcerrMessageBuilder();
 583
 584         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();
 585         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(
 586             this.rpFalse).build());
 587
 588         innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
 589
 590         builder.setErrors(innerErr);
 591         builder.setErrorType(new RequestCaseBuilder().setRequest(new RequestBuilder().setRps(rps).build()).build());
 592
 593         assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 594             result.readableBytes() - 4), Collections.emptyList()));
 595         ByteBuf buf = Unpooled.buffer(result.readableBytes());
 596         parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
 597         assertArrayEquals(result.array(), buf.array());
 598
 599         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCErr.3.bin"));
 600
 601         error1 = new ErrorObjectBuilder().setIgnore(false).setProcessingRule(false).setType((short) 3).setValue((short) 1).build();
 602
 603         innerErr = new ArrayList<>();
 604         innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
 605
 606         builder.setErrors(innerErr);
 607         builder.setErrorType(new SessionCaseBuilder().setSession(new SessionBuilder().setOpen(this.open).build()).build());
 608
 609         assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 610             result.readableBytes() - 4), Collections.emptyList()));
 611         buf = Unpooled.buffer(result.readableBytes());
 612         parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
 613         assertArrayEquals(result.array(), buf.array());
 614
 615         try {
 616             parser.serializeMessage(new PcerrBuilder().setPcerrMessage(new PcerrMessageBuilder().build()).build(), null);
 617             fail();
 618         } catch (final IllegalArgumentException e) {
 619             assertEquals("Errors should not be empty.", e.getMessage());
 620         }
 621         try {
 622             parser.serializeMessage(new PcerrBuilder().setPcerrMessage(new PcerrMessageBuilder().setErrors(Collections.emptyList()).build()).build(), null);
 623             fail();
 624         } catch (final IllegalArgumentException e) {
 625             assertEquals("Errors should not be empty.", e.getMessage());
 626         }
 627     }
 628
 629     @Test
 630     public void testReqMsgWithVendorInfoObjects() throws IOException, PCEPDeserializerException {
 631         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCReq.7.bin"));
 632         final PCEPRequestMessageParser parser = new PCEPRequestMessageParser(this.objectRegistry);
 633
 634         final PcreqMessageBuilder builder = new PcreqMessageBuilder();
 635         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs1 = Lists.newArrayList();
 636         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder rBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder();
 637         rBuilder.setRp(this.rpTrue);
 638         rBuilder.setVendorInformationObject(this.viObjects);
 639         final SegmentComputationBuilder sBuilder = new SegmentComputationBuilder();
 640         sBuilder.setP2p(new P2pBuilder().setEndpointsObj(this.endpoints).setVendorInformationObject(this.viObjects).build());
 641         rBuilder.setSegmentComputation(sBuilder.build());
 642         reqs1.add(rBuilder.build());
 643         builder.setSvec(Lists.newArrayList(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.SvecBuilder().setSvec(
 644                 this.svec).setVendorInformationObject(this.viObjects).build()));
 645         builder.setRequests(reqs1);
 646
 647         assertEquals(new PcreqBuilder().setPcreqMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 648             result.readableBytes() - 4), Collections.emptyList()));
 649         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 650         parser.serializeMessage(new PcreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 651
 652         assertArrayEquals(result.array(), buf.array());
 653     }
 654
 655     @Test
 656     public void testRepMsgWithVendorInforObjects() throws IOException, PCEPDeserializerException {
 657         final PCEPReplyMessageParser parser = new PCEPReplyMessageParser(this.objectRegistry);
 658
 659         final PcrepMessageBuilder builder = new PcrepMessageBuilder();
 660         RepliesBuilder rBuilder = new RepliesBuilder();
 661         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.6.bin"));
 662         final List<Replies> replies = Lists.newArrayList();
 663         rBuilder = new RepliesBuilder();
 664         rBuilder.setRp(this.rpTrue);
 665         rBuilder.setVendorInformationObject(this.viObjects);
 666         final List<Paths> paths = Lists.newArrayList();
 667         final PathsBuilder paBuilder = new PathsBuilder();
 668         paBuilder.setEro(this.ero);
 669         paths.add(paBuilder.build());
 670         rBuilder.setResult(new SuccessCaseBuilder().setSuccess(new SuccessBuilder().setPaths(paths).setVendorInformationObject(this.viObjects).build()).build()).build();
 671         replies.add(rBuilder.build());
 672         builder.setReplies(replies);
 673
 674         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 675             result.readableBytes() - 4), Collections.emptyList()));
 676         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 677         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 678         assertArrayEquals(result.array(), buf.array());
 679     }
 680
 681     @Test
 682     public void testMonRepMsg() throws PCEPDeserializerException, IOException {
 683         final PCEPMonitoringReplyMessageParser parser = new PCEPMonitoringReplyMessageParser(this.objectRegistry);
 684         final PcmonrepMessageBuilder builder = new PcmonrepMessageBuilder();
 685         builder.setMonitoring(this.monitoring);
 686         builder.setMonitoringMetricsList(new GeneralMetricsListBuilder().setMetricPce(Lists.newArrayList(new MetricPceBuilder().setPceId(this.pceId).build())).build());
 687
 688         final byte[] msgBytes = {
 689             0x20, 0x09, 0x00, 0x18,
 690             /* monitoring object */
 691             0x13, 0x10, 0x00, 0x0C, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x64,
 692             /* pce-id object */
 693             0x19, 0x10, 0x00, 0x08, 0x7f, 0x00, 0x00, 0x02
 694         };
 695
 696         ByteBuf result = Unpooled.wrappedBuffer(msgBytes);
 697         assertEquals(new PcmonrepBuilder().setPcmonrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 698                 result.readableBytes() - 4), Collections.emptyList()));
 699         ByteBuf buf = Unpooled.buffer(result.readableBytes());
 700         parser.serializeMessage(new PcmonrepBuilder().setPcmonrepMessage(builder.build()).build(), buf);
 701         assertArrayEquals(result.array(), buf.array());
 702
 703         builder.setMonitoring(this.monitoring);
 704         builder.setPccIdReq(this.pccIdReq);
 705         final SpecificMetricsBuilder smBuilder = new SpecificMetricsBuilder();
 706         smBuilder.setRp(this.rpTrue);
 707         final List<MetricPce> metricPces = Lists.newArrayList();
 708         metricPces.add(new MetricPceBuilder().setOverload(this.overload).setPceId(this.pceId).setProcTime(this.procTime).build());
 709         metricPces.add(new MetricPceBuilder().setPceId(this.pceId).setProcTime(this.procTime).build());
 710         smBuilder.setMetricPce(metricPces);
 711         final SpecificMetricsBuilder smBuilder2 = new SpecificMetricsBuilder();
 712         final List<MetricPce> metricPces2 = Lists.newArrayList();
 713         smBuilder2.setRp(this.rpTrue);
 714         metricPces2.add(new MetricPceBuilder().setOverload(this.overload).setPceId(this.pceId).build());
 715         smBuilder2.setMetricPce(metricPces2);
 716         builder.setMonitoringMetricsList(new SpecificMetricsListBuilder().setSpecificMetrics(Lists.newArrayList(smBuilder.build(), smBuilder2.build())).build());
 717
 718         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCMonRep.bin"));
 719         assertEquals(new PcmonrepBuilder().setPcmonrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 720                 result.readableBytes() - 4), Collections.emptyList()));
 721         buf = Unpooled.buffer(result.readableBytes());
 722         parser.serializeMessage(new PcmonrepBuilder().setPcmonrepMessage(builder.build()).build(), buf);
 723         assertArrayEquals(result.array(), buf.array());
 724     }
 725
 726     @Test
 727     public void testRepWithMonitoring() throws IOException, PCEPDeserializerException {
 728         final PCEPReplyMessageParser parser = new PCEPReplyMessageParser(this.objectRegistry);
 729
 730         final PcrepMessageBuilder builder = new PcrepMessageBuilder();
 731         RepliesBuilder rBuilder = new RepliesBuilder();
 732
 733         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRepMon.5.bin"));
 734         final List<Replies> replies4 = Lists.newArrayList();
 735         rBuilder = new RepliesBuilder();
 736         rBuilder.setRp(this.rpTrue);
 737         rBuilder.setMonitoring(this.monitoring);
 738         rBuilder.setPccIdReq(this.pccIdReq);
 739         rBuilder.setMetricPce(Lists.newArrayList(new MetricPceBuilder().setPceId(this.pceId).build()));
 740         final List<Paths> paths = Lists.newArrayList();
 741         final PathsBuilder paBuilder = new PathsBuilder();
 742         paBuilder.setEro(this.ero);
 743         paBuilder.setLspa(this.lspa);
 744         paBuilder.setMetrics(Lists.newArrayList(this.metrics));
 745         paBuilder.setIro(this.iro);
 746         paBuilder.setOf(this.of);
 747         paths.add(paBuilder.build());
 748         rBuilder.setResult(new SuccessCaseBuilder().setSuccess(new SuccessBuilder().setPaths(paths).build()).build()).build();
 749         replies4.add(rBuilder.build());
 750         builder.setReplies(replies4);
 751
 752         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 753             result.readableBytes() - 4), Collections.emptyList()));
 754         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 755         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 756         assertArrayEquals(result.array(), buf.array());
 757     }
 758
 759     @Test
 760     public void testReqWithMonitoring() throws IOException, PCEPDeserializerException {
 761         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCReq.8.bin"));
 762
 763         final PCEPRequestMessageParser parser = new PCEPRequestMessageParser(this.objectRegistry);
 764
 765         final PcreqMessageBuilder builder = new PcreqMessageBuilder();
 766         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs1 = Lists.newArrayList();
 767         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder rBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder();
 768         rBuilder.setRp(this.rpTrue);
 769         rBuilder.setSegmentComputation(new SegmentComputationBuilder().setP2p(new P2pBuilder().setEndpointsObj(this.endpoints).build()).build());
 770         reqs1.add(rBuilder.build());
 771         final MonitoringRequestBuilder monReqBuilder = new MonitoringRequestBuilder();
 772         monReqBuilder.setMonitoring(this.monitoring);
 773         monReqBuilder.setPccIdReq(this.pccIdReq);
 774         monReqBuilder.setPceIdList(Lists.newArrayList(new PceIdListBuilder().setPceId(this.pceId).build()));
 775         builder.setMonitoringRequest(monReqBuilder.build());
 776         builder.setRequests(reqs1);
 777
 778         assertEquals(new PcreqBuilder().setPcreqMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 779                 result.readableBytes() - 4), Collections.emptyList()));
 780         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 781         parser.serializeMessage(new PcreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 782
 783         assertArrayEquals(result.array(), buf.array());
 784     }
 785
 786     @Test
 787     public void testMonReqMsg() throws PCEPDeserializerException, IOException {
 788         final PCEPMonitoringRequestMessageParser parser = new PCEPMonitoringRequestMessageParser(this.objectRegistry);
 789
 790         final PcreqMessageBuilder builder = new PcreqMessageBuilder();
 791         final MonitoringRequestBuilder monReqBuilder = new MonitoringRequestBuilder();
 792         monReqBuilder.setMonitoring(this.monitoring);
 793         monReqBuilder.setPceIdList(Lists.newArrayList(new PceIdListBuilder().setPceId(this.pceId).build()));
 794         builder.setMonitoringRequest(monReqBuilder.build());
 795         final byte[] msgBytes = {
 796             0x20, 0x08, 0x00, 0x18,
 797             /* monitoring object */
 798             0x13, 0x10, 0x00, 0x0C, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x64,
 799             /* pce-id object */
 800             0x19, 0x10, 0x00, 0x08, 0x7f, 0x00, 0x00, 0x02
 801         };
 802         ByteBuf result = Unpooled.wrappedBuffer(msgBytes);
 803         assertEquals(new PcmonreqBuilder().setPcreqMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 804                 result.readableBytes() - 4), Collections.emptyList()));
 805         ByteBuf buf = Unpooled.buffer(result.readableBytes());
 806         parser.serializeMessage(new PcmonreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 807         assertArrayEquals(result.array(), buf.array());
 808
 809         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCMonReq.bin"));
 810         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs2 = Lists.newArrayList();
 811         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder rBuilder1 = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder();
 812         rBuilder1.setRp(this.rpTrue);
 813         final P2pBuilder p2pBuilder = new P2pBuilder();
 814         p2pBuilder.setEndpointsObj(this.endpoints);
 815         p2pBuilder.setMetrics(Lists.newArrayList(this.metrics));
 816         p2pBuilder.setIro(this.iro);
 817         rBuilder1.setSegmentComputation(new SegmentComputationBuilder().setP2p(p2pBuilder.build()).build());
 818         reqs2.add(rBuilder1.build());
 819         builder.setRequests(reqs2);
 820         builder.setSvec(Lists.newArrayList(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.SvecBuilder().setSvec(
 821             this.svec).build()));
 822         monReqBuilder.setMonitoring(this.monitoring);
 823         monReqBuilder.setPccIdReq(this.pccIdReq);
 824         final PceIdList pceIdList = new PceIdListBuilder().setPceId(this.pceId).build();
 825         monReqBuilder.setPceIdList(Lists.newArrayList(pceIdList, pceIdList));
 826         builder.setMonitoringRequest(monReqBuilder.build());
 827
 828         assertEquals(new PcmonreqBuilder().setPcreqMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 829             result.readableBytes() - 4), Collections.emptyList()));
 830         buf = Unpooled.buffer(result.readableBytes());
 831         parser.serializeMessage(new PcmonreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 832         assertArrayEquals(result.array(), buf.array());
 833     }
 834 }