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