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