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