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