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