Rework parser infrastructure to support partial message processing
[bgpcep.git] / 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 io.netty.buffer.ByteBuf;
13 import io.netty.buffer.Unpooled;
14
15 import java.io.IOException;
16 import java.math.BigInteger;
17 import java.util.Collections;
18 import java.util.List;
19
20 import org.junit.Before;
21 import org.junit.Test;
22 import org.opendaylight.protocol.pcep.PCEPDeserializerException;
23 import org.opendaylight.protocol.pcep.PCEPDocumentedException;
24 import org.opendaylight.protocol.pcep.impl.message.PCEPCloseMessageParser;
25 import org.opendaylight.protocol.pcep.impl.message.PCEPErrorMessageParser;
26 import org.opendaylight.protocol.pcep.impl.message.PCEPKeepAliveMessageParser;
27 import org.opendaylight.protocol.pcep.impl.message.PCEPNotificationMessageParser;
28 import org.opendaylight.protocol.pcep.impl.message.PCEPOpenMessageParser;
29 import org.opendaylight.protocol.pcep.impl.message.PCEPReplyMessageParser;
30 import org.opendaylight.protocol.pcep.impl.message.PCEPReportMessageParser;
31 import org.opendaylight.protocol.pcep.impl.message.PCEPUpdateRequestMessageParser;
32 import org.opendaylight.protocol.pcep.impl.message.PcinitiateMessageParser;
33 import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
34 import org.opendaylight.protocol.pcep.spi.pojo.ServiceLoaderPCEPExtensionProviderContext;
35 import org.opendaylight.protocol.util.ByteArray;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ieee754.rev130819.Float32;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.CloseBuilder;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.KeepaliveBuilder;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.OpenBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcerrBuilder;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcinitiateBuilder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcntfBuilder;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcrepBuilder;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcrptBuilder;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcupdBuilder;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.OfId;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.OperationalStatus;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.PlspId;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.ProtocolVersion;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.RequestId;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.SrpIdNumber;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.bandwidth.object.Bandwidth;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.bandwidth.object.BandwidthBuilder;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.message.CCloseMessageBuilder;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.object.CCloseBuilder;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.Ero;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.EroBuilder;
59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.Iro;
60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.IroBuilder;
61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.Subobjects;
62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.SubobjectsBuilder;
63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.keepalive.message.KeepaliveMessageBuilder;
64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.Metrics;
65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.MetricsBuilder;
66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.db.version.tlv.LspDbVersion;
67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.db.version.tlv.LspDbVersionBuilder;
68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.object.Lsp;
69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.object.LspBuilder;
70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.Lspa;
71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.LspaBuilder;
72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.metric.object.MetricBuilder;
73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotification;
74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotificationBuilder;
75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.Of;
76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.OfBuilder;
77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.message.OpenMessageBuilder;
78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.Open;
79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObject;
80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObjectBuilder;
81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.PcerrMessageBuilder;
82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.Errors;
83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.ErrorsBuilder;
84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.RequestBuilder;
85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.SessionBuilder;
86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcinitiate.message.PcinitiateMessageBuilder;
87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcinitiate.message.pcinitiate.message.Requests;
88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcinitiate.message.pcinitiate.message.RequestsBuilder;
89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.PcntfMessageBuilder;
90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.Notifications;
91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.NotificationsBuilder;
92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Rps;
93 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.RpsBuilder;
94 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.PcrepMessageBuilder;
95 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.Replies;
96 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.RepliesBuilder;
97 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.FailureBuilder;
98 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.SuccessBuilder;
99 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure.NoPath;
100 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure.NoPathBuilder;
101 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success.Paths;
102 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success.PathsBuilder;
103 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrpt.message.PcrptMessageBuilder;
104 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrpt.message.pcrpt.message.Reports;
105 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrpt.message.pcrpt.message.ReportsBuilder;
106 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrpt.message.pcrpt.message.reports.PathBuilder;
107 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.PcupdMessageBuilder;
108 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.Updates;
109 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.UpdatesBuilder;
110 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.Rro;
111 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.RroBuilder;
112 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.Rp;
113 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.RpBuilder;
114 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.srp.object.Srp;
115 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.srp.object.SrpBuilder;
116 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.stateful.capability.tlv.Stateful;
117 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.stateful.capability.tlv.Stateful.Flags;
118 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.stateful.capability.tlv.StatefulBuilder;
119 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.AttributeFilter;
120 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumber;
121 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumberBuilder;
122 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.subobject.type.Unnumbered;
123 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.subobject.type.UnnumberedBuilder;
124
125 import com.google.common.collect.Lists;
126
127 public class PCEPValidatorTest {
128
129         private ObjectHandlerRegistry objectRegistry;
130
131         private Rp rp;
132         private Open open;
133         private NoPath noPath;
134         private Lspa lspa;
135         private Bandwidth bandwidth;
136         private Metrics metrics;
137         private Iro iro;
138         private Ero ero;
139         private Rro rro;
140         private Of of;
141         private Srp srp;
142         private Lsp lsp;
143
144         private AsNumber eroASSubobject;
145         private Unnumbered rroUnnumberedSub;
146
147         @Before
148         public void setUp() throws Exception {
149                 this.objectRegistry = ServiceLoaderPCEPExtensionProviderContext.create().getObjectHandlerRegistry();
150                 final RpBuilder rpBuilder = new RpBuilder();
151                 rpBuilder.setProcessingRule(false);
152                 rpBuilder.setIgnore(false);
153                 rpBuilder.setReoptimization(false);
154                 rpBuilder.setBiDirectional(false);
155                 rpBuilder.setLoose(true);
156                 rpBuilder.setMakeBeforeBreak(false);
157                 rpBuilder.setOrder(false);
158                 rpBuilder.setSupplyOf(false);
159                 rpBuilder.setFragmentation(false);
160                 rpBuilder.setP2mp(false);
161                 rpBuilder.setEroCompression(false);
162                 rpBuilder.setPriority((short) 1);
163                 rpBuilder.setRequestId(new RequestId(10L));
164                 this.rp = rpBuilder.build();
165
166                 final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder openBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder();
167                 openBuilder.setProcessingRule(false);
168                 openBuilder.setIgnore(false);
169                 openBuilder.setDeadTimer((short) 1);
170                 openBuilder.setKeepalive((short) 1);
171                 openBuilder.setSessionId((short) 0);
172                 openBuilder.setVersion(new ProtocolVersion((short) 1));
173                 openBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().build());
174                 this.open = openBuilder.build();
175
176                 final NoPathBuilder npbuilder = new NoPathBuilder();
177                 npbuilder.setProcessingRule(false);
178                 npbuilder.setIgnore(false);
179                 npbuilder.setNatureOfIssue((short) 0);
180                 npbuilder.setUnsatisfiedConstraints(false);
181                 this.noPath = npbuilder.build();
182
183                 final LspaBuilder lspaBuilder = new LspaBuilder();
184                 lspaBuilder.setProcessingRule(false);
185                 lspaBuilder.setIgnore(false);
186                 lspaBuilder.setLocalProtectionDesired(false);
187                 lspaBuilder.setHoldPriority((short) 0);
188                 lspaBuilder.setSetupPriority((short) 0);
189                 lspaBuilder.setExcludeAny(new AttributeFilter(0L));
190                 lspaBuilder.setIncludeAll(new AttributeFilter(0L));
191                 lspaBuilder.setIncludeAny(new AttributeFilter(0L));
192                 this.lspa = lspaBuilder.build();
193
194                 final BandwidthBuilder bBuilder = new BandwidthBuilder();
195                 bBuilder.setIgnore(false);
196                 bBuilder.setProcessingRule(false);
197                 bBuilder.setBandwidth(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.nps.concepts.rev130930.Bandwidth(new Float32(new byte[4])));
198                 this.bandwidth = bBuilder.build();
199
200                 final MetricBuilder mBuilder = new MetricBuilder();
201                 mBuilder.setIgnore(false);
202                 mBuilder.setProcessingRule(false);
203                 mBuilder.setComputed(false);
204                 mBuilder.setBound(false);
205                 mBuilder.setMetricType((short) 1);
206                 mBuilder.setValue(new Float32(new byte[4]));
207                 this.metrics = new MetricsBuilder().setMetric(mBuilder.build()).build();
208
209                 this.eroASSubobject = new AsNumberBuilder().setAsNumber(
210                                 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.AsNumber(0xFFFFL)).build();
211
212                 this.rroUnnumberedSub = new UnnumberedBuilder().setRouterId(0x00112233L).setInterfaceId(0x00ff00ffL).build();
213
214                 final IroBuilder iroBuilder = new IroBuilder();
215                 iroBuilder.setIgnore(false);
216                 iroBuilder.setProcessingRule(false);
217                 final List<Subobjects> iroSubs = Lists.newArrayList();
218                 iroSubs.add(new SubobjectsBuilder().setSubobjectType(this.eroASSubobject).build());
219                 iroBuilder.setSubobjects(iroSubs);
220                 this.iro = iroBuilder.build();
221
222                 final EroBuilder eroBuilder = new EroBuilder();
223                 eroBuilder.setIgnore(false);
224                 eroBuilder.setProcessingRule(false);
225                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.Subobjects> eroSubs = Lists.newArrayList();
226                 eroSubs.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.SubobjectsBuilder().setSubobjectType(
227                                 this.eroASSubobject).setLoose(false).build());
228                 eroBuilder.setSubobjects(eroSubs);
229                 this.ero = eroBuilder.build();
230
231                 final RroBuilder rroBuilder = new RroBuilder();
232                 rroBuilder.setIgnore(false);
233                 rroBuilder.setProcessingRule(false);
234                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.rro.Subobjects> rroSubs = Lists.newArrayList();
235                 rroSubs.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.rro.SubobjectsBuilder().setSubobjectType(
236                                 this.rroUnnumberedSub).setProtectionAvailable(false).setProtectionInUse(false).build());
237                 rroBuilder.setSubobjects(rroSubs);
238                 this.rro = rroBuilder.build();
239
240                 final OfBuilder ofBuilder = new OfBuilder();
241                 ofBuilder.setIgnore(false);
242                 ofBuilder.setProcessingRule(false);
243                 ofBuilder.setCode(new OfId(0));
244                 this.of = ofBuilder.build();
245
246                 final SrpBuilder srpBuilder = new SrpBuilder();
247                 srpBuilder.setIgnore(false);
248                 srpBuilder.setProcessingRule(false);
249                 srpBuilder.setOperationId(new SrpIdNumber(1L));
250                 this.srp = srpBuilder.build();
251
252                 final LspBuilder lspBuilder = new LspBuilder();
253                 lspBuilder.setIgnore(false);
254                 lspBuilder.setProcessingRule(false);
255                 lspBuilder.setAdministrative(false);
256                 lspBuilder.setDelegate(false);
257                 lspBuilder.setPlspId(new PlspId(0L));
258                 lspBuilder.setOperational(OperationalStatus.Down);
259                 lspBuilder.setSync(false);
260                 lspBuilder.setRemove(false);
261                 lspBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.object.lsp.TlvsBuilder().build());
262                 this.lsp = lspBuilder.build();
263         }
264
265         @Test
266         public void testOpenMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
267                 final byte[] result = ByteArray.fileToBytes("src/test/resources/PCEPOpenMessage1.bin");
268                 final PCEPOpenMessageParser parser = new PCEPOpenMessageParser(this.objectRegistry);
269                 final OpenMessageBuilder builder = new OpenMessageBuilder();
270
271                 final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder b = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder();
272                 b.setProcessingRule(false);
273                 b.setIgnore(false);
274                 b.setVersion(new ProtocolVersion((short) 1));
275                 b.setKeepalive((short) 30);
276                 b.setDeadTimer((short) 120);
277                 b.setSessionId((short) 1);
278                 final Stateful tlv1 = new StatefulBuilder().setFlags(new Flags(true, false, true)).build();
279                 final LspDbVersion tlv2 = new LspDbVersionBuilder().setVersion(BigInteger.valueOf(0x80L)).build();
280                 b.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().setStateful(
281                                 tlv1).setLspDbVersion(tlv2).build());
282                 builder.setOpen(b.build());
283
284                 assertEquals(new OpenBuilder().setOpenMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
285                 final ByteBuf buf = Unpooled.buffer(result.length);
286                 parser.serializeMessage(new OpenBuilder().setOpenMessage(builder.build()).build(), buf);
287                 assertArrayEquals(result, buf.array());
288         }
289
290         @Test
291         public void testKeepAliveMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
292                 final byte[] result = new byte[] { };
293                 final PCEPKeepAliveMessageParser parser = new PCEPKeepAliveMessageParser(this.objectRegistry);
294                 final KeepaliveBuilder builder = new KeepaliveBuilder().setKeepaliveMessage(new KeepaliveMessageBuilder().build());
295
296                 assertEquals(builder.build(), parser.parseMessage(result, Collections.<Message>emptyList()));
297                 final ByteBuf buf = Unpooled.buffer(result.length);
298                 parser.serializeMessage(builder.build(), buf);
299                 assertArrayEquals(result, buf.array());
300         }
301
302         @Test
303         public void testCloseMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
304                 final byte[] result = ByteArray.fileToBytes("src/test/resources/PCEPCloseMessage1.bin");
305
306                 final PCEPCloseMessageParser parser = new PCEPCloseMessageParser(this.objectRegistry);
307                 final CloseBuilder builder = new CloseBuilder().setCCloseMessage(new CCloseMessageBuilder().setCClose(
308                                 new CCloseBuilder().setIgnore(false).setProcessingRule(false).setReason((short) 5).build()).build());
309
310                 assertEquals(builder.build(), parser.parseMessage(result, Collections.<Message>emptyList()));
311                 final ByteBuf buf = Unpooled.buffer(result.length);
312                 parser.serializeMessage(builder.build(), buf);
313                 assertArrayEquals(result, buf.array());
314         }
315
316         // @Test
317         // public void testRequestMessageValidationFromBin() throws IOException, PCEPDeserializerException,
318         // PCEPDocumentedException,
319         // DeserializerException, DocumentedException {
320         // List<CompositeRequestObject> requests = new ArrayList<CompositeRequestObject>();
321         // final byte[] ipAdress = { (byte) 0xFF, (byte) 0xFF, (byte) 0xFF, (byte) 0xFF };
322         // requests.add(new CompositeRequestObject(new PCEPRequestParameterObject(true, false, false, false, false, false,
323         // false, false, (short) 5, 0xDEADBEEFL, true, false), new PCEPEndPointsObject<IPv4Address>(new
324         // IPv4Address(ipAdress), new IPv4Address(ipAdress))));
325         // PCEPRequestMessage specMessage = new PCEPRequestMessage(requests);
326         // List<Message> deserMsgs = deserMsg("src/test/resources/PCEPRequestMessage1.bin");
327         // final List<Message> specMessages = Lists.newArrayList();
328         // specMessages.add(specMessage);
329         //
330         // assertEquals(deserMsgs.toString(), specMessages.toString());
331         //
332         // requests = new ArrayList<CompositeRequestObject>();
333         // final byte[] ipAdress2 = { (byte) 0x7F, (byte) 0x00, (byte) 0x00, (byte) 0x01 };
334         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
335         // IPv4Address(ipAdress2), new IPv4Address(ipAdress2))));
336         // specMessage = new PCEPRequestMessage(requests);
337         // deserMsgs = deserMsg("src/test/resources/PCReq.1.bin");
338         // specMessages.clear();
339         // specMessages.add(specMessage);
340         // assertEquals(deserMsgs.toString(), specMessages.toString());
341         //
342         // requests = new ArrayList<CompositeRequestObject>();
343         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
344         // IPv4Address(ipAdress2), new IPv4Address(ipAdress2)), null, null, null, null, null, null, null, null, new
345         // PCEPLoadBalancingObject(3, new Bandwidth(ByteArray.floatToBytes((float) 1024.75)), false)));
346         // specMessage = new PCEPRequestMessage(requests);
347         // deserMsgs = deserMsg("src/test/resources/PCReq.2.bin");
348         // specMessages.clear();
349         // specMessages.add(specMessage);
350         // assertEquals(deserMsgs.toString(), specMessages.toString());
351         //
352         // requests = new ArrayList<CompositeRequestObject>();
353         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
354         // IPv4Address(ipAdress2), new IPv4Address(ipAdress2)), null, new PCEPLspObject(1, false, false, true, false),
355         // PCEPValidatorTest.lspa, new PCEPRequestedPathBandwidthObject(new Bandwidth(ByteArray.floatToBytes(1000)), false,
356         // false), new ArrayList<PCEPMetricObject>() {
357         // private static final long serialVersionUID = 1L;
358         //
359         // {
360         // this.add(new PCEPMetricObject(true, true, new IGPMetric(53L), false, false));
361         // }
362         // }, new PCEPReportedRouteObject(this.rroSubobjects, false), new PCEPExistingPathBandwidthObject(new
363         // Bandwidth(ByteArray.floatToBytes(5353)), false, false), new PCEPIncludeRouteObject(this.eroSubobjects, false,
364         // false), new PCEPLoadBalancingObject(5, new Bandwidth(ByteArray.floatToBytes(3)), false)));
365         //
366         // List<CompositeRequestSvecObject> svecList = new ArrayList<CompositeRequestSvecObject>();
367         // svecList.add(new CompositeRequestSvecObject(new PCEPSvecObject(true, false, false, false, false, this.requestIds,
368         // false)));
369         //
370         // specMessage = new PCEPRequestMessage(svecList, requests);
371         // deserMsgs = deserMsg("src/test/resources/PCReq.3.bin");
372         // specMessages.clear();
373         // specMessages.add(specMessage);
374         // // FIXME BUG-89
375         // // assertEquals(deserMsgs, specMessages);
376         //
377         // specMessages.clear();
378         // requests = new ArrayList<CompositeRequestObject>();
379         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
380         // IPv4Address(ipAdress2), new IPv4Address(ipAdress2)), null, null, null, null, null, null, null, null, null));
381         // specMessages.add(new PCEPRequestMessage(requests));
382         //
383         // final byte[] ipAdress3 = { (byte) 0x7F, (byte) 0x00, (byte) 0x30, (byte) 0x01 };
384         // requests = new ArrayList<CompositeRequestObject>();
385         // requests.add(new CompositeRequestObject(new PCEPRequestParameterObject(false, false, false, false, false, false,
386         // false, false, (short) 4, 1, true, false), new PCEPEndPointsObject<IPv4Address>(new IPv4Address(ipAdress3), new
387         // IPv4Address(ipAdress2)), null, null, null, null, null, null, null, null, null));
388         // specMessages.add(new PCEPRequestMessage(requests));
389         //
390         // final byte[] ipAdress4 = { (byte) 0x7F, (byte) 0x30, (byte) 0x00, (byte) 0x01 };
391         // requests = new ArrayList<CompositeRequestObject>();
392         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
393         // IPv4Address(ipAdress2), new IPv4Address(ipAdress4)), null, null, null, null, null, null, null, null, null));
394         // specMessages.add(new PCEPRequestMessage(requests));
395         //
396         // final byte[] ipAdress5 = { (byte) 0x7F, (byte) 0xd0, (byte) 0x00, (byte) 0x01 };
397         // requests = new ArrayList<CompositeRequestObject>();
398         // requests.add(new CompositeRequestObject(new PCEPRequestParameterObject(true, false, false, false, false, false,
399         // false, false, (short) 1, 1, true, false), new PCEPEndPointsObject<IPv4Address>(new IPv4Address(ipAdress5), new
400         // IPv4Address(ipAdress5)), null, null, null, null, null, null, null, null, null));
401         //
402         // specMessages.add(new PCEPRequestMessage(requests));
403         // deserMsgs = deserMsg("src/test/resources/PCReq.4.bin");
404         // assertEquals(deserMsgs.toString(), specMessages.toString());
405         //
406         // specMessages.clear();
407         // svecList = new ArrayList<CompositeRequestSvecObject>();
408         // svecList.add(new CompositeRequestSvecObject(new PCEPSvecObject(true, false, false, false, false, this.requestIds,
409         // false)));
410         // svecList.add(new CompositeRequestSvecObject(new PCEPSvecObject(false, true, true, false, false, this.requestIds,
411         // false), new PCEPObjectiveFunctionObject(PCEPOFCodes.MCC, true, false), new PCEPGlobalConstraintsObject((short)
412         // 0x55, (short) 1, (short) 100, (short) 0x26, true, false), new PCEPExcludeRouteObject(new
413         // ArrayList<ExcludeRouteSubobject>() {
414         // private static final long serialVersionUID = 1L;
415         //
416         // {
417         // this.add(new XROAsNumberSubobject(new AsNumber((long) 0x12), true));
418         // }
419         // }, true, true, false), new ArrayList<PCEPMetricObject>() {
420         // private static final long serialVersionUID = 1L;
421         //
422         // {
423         // this.add(new PCEPMetricObject(true, true, new TEMetric(123456L), true, false));
424         // }
425         // }));
426         //
427         // requests = new ArrayList<CompositeRequestObject>();
428         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
429         // IPv4Address(ipAdress2), new IPv4Address(ipAdress2)), null, null, PCEPValidatorTest.lspa, new
430         // PCEPRequestedPathBandwidthObject(new Bandwidth(ByteArray.floatToBytes(1000)), false, false), new
431         // ArrayList<PCEPMetricObject>() {
432         // private static final long serialVersionUID = 1L;
433         //
434         // {
435         // this.add(new PCEPMetricObject(true, true, new IGPMetric(53L), false, false));
436         // this.add(new PCEPMetricObject(true, true, new IGPMetric(5335L), false, false));
437         // this.add(new PCEPMetricObject(true, true, new IGPMetric(128256), false, false));
438         // }
439         // }, new PCEPReportedRouteObject(this.rroSubobjects, false), new PCEPExistingPathBandwidthObject(new
440         // Bandwidth(ByteArray.floatToBytes(5353)), false, false), new PCEPIncludeRouteObject(this.eroSubobjects, false,
441         // false), new PCEPLoadBalancingObject(5, new Bandwidth(ByteArray.floatToBytes(3)), false)));
442         //
443         // final byte[] ipAdress6 = { (byte) 0x7F, (byte) 0xF0, (byte) 0x00, (byte) 0x01 };
444         // specMessages.add(new PCEPRequestMessage(svecList, requests));
445         //
446         // requests = new ArrayList<CompositeRequestObject>();
447         // requests.add(new CompositeRequestObject(this.requestParameter, new PCEPEndPointsObject<IPv4Address>(new
448         // IPv4Address(ipAdress6), new IPv4Address(ipAdress6)), null, null, PCEPValidatorTest.lspa, new
449         // PCEPRequestedPathBandwidthObject(new Bandwidth(ByteArray.floatToBytes(1000)), false, false), new
450         // ArrayList<PCEPMetricObject>() {
451         // private static final long serialVersionUID = 1L;
452         //
453         // {
454         // this.add(new PCEPMetricObject(true, true, new IGPMetric(53L), false, false));
455         // }
456         // }, new PCEPReportedRouteObject(this.rroSubobjects, false), new PCEPExistingPathBandwidthObject(new
457         // Bandwidth(ByteArray.floatToBytes(5353)), false, false), new PCEPIncludeRouteObject(this.eroSubobjects, false,
458         // false), new PCEPLoadBalancingObject(5, new Bandwidth(ByteArray.floatToBytes(3f)), false)));
459         // deserMsgs = deserMsg("src/test/resources/PCReq.5.bin");
460         // specMessages.add(new PCEPRequestMessage(svecList, requests));
461         // // FIXME
462         // // assertEquals(deserMsgs, specMessages);
463         //
464         // // FIXME: need construct with invalid processed parameter
465         // // assertEquals(deserMsg("src/test/resources/PCReq.6.invalid.bin"),
466         // // asList(
467         // // new PCEPErrorMessage(new CompositeErrorObject(new
468         // // PCEPRequestParameterObject(true, false, false, false, false, false,
469         // // false, false, (short) 3,
470         // // 1L, false, false), new PCEPErrorObject(PCEPErrors.P_FLAG_NOT_SET))),
471         // // new PCEPRequestMessage(asList(new
472         // // CompositeRequestObject(this.requestParameter, new
473         // // PCEPEndPointsObject<IPv4Address>(IPv4Address
474         // // .getNetworkAddressFactory().getNetworkAddressForBytes(new byte[] {
475         // // 127, 0, 0, 1 }), IPv4Address.getNetworkAddressFactory()
476         // // .getNetworkAddressForBytes(new byte[] { 127, 0, 0, 1 })), null, null,
477         // // null, null, null, null, null, null, new PCEPLoadBalancingObject(
478         // // 3, new Bandwidth(1024.75), false))))));
479         //
480         // }
481         //
482         // @Test
483         // public void testRequestMessageValidationFromRawMsg() throws PCEPDeserializerException {
484         // List<PCEPObject> objs = new ArrayList<PCEPObject>();
485         // List<Message> msgs;
486         // PCEPRequestParameterObject tmpRP;
487         //
488         // // test unrecognized object in svec list
489         // objs.add(this.svecObj);
490         // objs.add(new UnknownObject(true, false, PCEPErrors.UNRECOGNIZED_OBJ_CLASS));
491         // objs.add(new PCEPSvecObject(true, true, true, false, false, PCEPValidatorTest.this.requestIds, true));
492         //
493         // msgs = PCEPMessageValidator.getValidator(PCEPMessageType.REQUEST).validate(objs);
494         //
495         // assertEquals(msgs.get(0).toString(), new PCEPErrorMessage(new ArrayList<PCEPErrorObject>() {
496         // private static final long serialVersionUID = 1L;
497         //
498         // {
499         // this.add(new PCEPErrorObject(PCEPErrors.UNRECOGNIZED_OBJ_CLASS));
500         // }
501         // }).toString());
502         //
503         // // test with request p flag not set and ignoracion of more than one
504         // // end-points objects
505         // objs = new ArrayList<PCEPObject>();
506         // objs.add(this.svecObj);
507         // objs.add(this.svecObj);
508         // tmpRP = new PCEPRequestParameterObject(true, false, false, false, false, false, false, false, (short) 3, 1,
509         // false, false);
510         // objs.add(tmpRP);
511         // objs.add(this.endPoints);
512         //
513         // objs.add(this.requestParameter);
514         // objs.add(this.endPoints);
515         // objs.add(this.endPoints);
516         // // FIXME:mv use object constructor with set processed flag
517         // // objs.add(this.classTypeProvider);
518         // // objs.add(this.requestParameter);
519         // // objs.add(this.endPointsProvider);
520         // // objs.add(new PCEPClassTypeObjectProvider((short) 7, false));
521         //
522         // msgs = PCEPMessageValidator.getValidator(PCEPMessageType.REQUEST).validate(objs);
523         // // FIXME:mv use object constructor with set processed flag
524         // // assertEquals(msgs.get(0), new PCEPErrorMessage(new
525         // // CompositeErrorObject(tmpRP, new
526         // // PCEPErrorObject(PCEPErrors.P_FLAG_NOT_SET))));
527         // // assertEquals(
528         // // msgs.get(1),
529         // // new PCEPRequestMessage(asList(new
530         // // CompositeRequestSvecObject(this.svecObj), new
531         // // CompositeRequestSvecObject(this.svecObj)), Util
532         // // .asList(new CompositeRequestObject(this.requestParameter,
533         // // this.endPoints, this.classType, null, null, null, null, null, null,
534         // // null,
535         // // null))));
536         // // assertEquals(msgs.get(2), new PCEPErrorMessage(new
537         // // CompositeErrorObject(tmpRP, new
538         // // PCEPErrorObject(PCEPErrors.P_FLAG_NOT_SET))));
539         // }
540         //
541
542         @Test
543         public void testReplyMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
544                 // only RP
545                 byte[] result = ByteArray.fileToBytes("src/test/resources/PCRep.1.bin");
546
547                 final PCEPReplyMessageParser parser = new PCEPReplyMessageParser(this.objectRegistry);
548
549                 final PcrepMessageBuilder builder = new PcrepMessageBuilder();
550                 RepliesBuilder rBuilder = new RepliesBuilder();
551
552                 final List<Replies> replies1 = Lists.newArrayList();
553                 rBuilder.setRp(this.rp);
554                 replies1.add(rBuilder.build());
555                 builder.setReplies(replies1);
556
557                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
558                 ByteBuf buf = Unpooled.buffer(result.length);
559                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
560                 assertArrayEquals(result, buf.array());
561
562                 // simple Failure
563                 result = ByteArray.fileToBytes("src/test/resources/PCRep.2.bin");
564                 final List<Replies> replies2 = Lists.newArrayList();
565                 rBuilder = new RepliesBuilder();
566                 rBuilder.setRp(this.rp);
567                 replies2.add(rBuilder.build());
568                 final RepliesBuilder rBuilder2 = new RepliesBuilder();
569                 rBuilder2.setRp(this.rp);
570                 rBuilder2.setResult(new FailureBuilder().setNoPath(this.noPath).build());
571                 replies2.add(rBuilder2.build());
572                 builder.setReplies(replies2);
573
574                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
575                 buf = Unpooled.buffer(result.length);
576                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
577                 assertArrayEquals(result, buf.array());
578
579                 // Failure with attributes
580                 result = ByteArray.fileToBytes("src/test/resources/PCRep.3.bin");
581                 final List<Replies> replies3 = Lists.newArrayList();
582                 rBuilder = new RepliesBuilder();
583                 rBuilder.setRp(this.rp);
584                 rBuilder.setResult(new FailureBuilder().setNoPath(this.noPath).setLspa(this.lspa).setMetrics(Lists.newArrayList(this.metrics)).setIro(
585                                 this.iro).build());
586                 replies3.add(rBuilder.build());
587                 builder.setReplies(replies3);
588
589                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
590                 buf = Unpooled.buffer(result.length);
591                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
592                 assertArrayEquals(result, buf.array());
593
594                 // Success
595                 result = ByteArray.fileToBytes("src/test/resources/PCRep.5.bin");
596                 final List<Replies> replies4 = Lists.newArrayList();
597                 rBuilder = new RepliesBuilder();
598                 rBuilder.setRp(this.rp);
599                 final List<Paths> paths = Lists.newArrayList();
600                 final PathsBuilder paBuilder = new PathsBuilder();
601                 paBuilder.setEro(this.ero);
602                 paBuilder.setLspa(this.lspa);
603                 paBuilder.setMetrics(Lists.newArrayList(this.metrics));
604                 paBuilder.setIro(this.iro);
605                 paBuilder.setOf(this.of);
606                 paths.add(paBuilder.build());
607                 rBuilder.setResult(new SuccessBuilder().setPaths(paths).build()).build();
608                 replies4.add(rBuilder.build());
609                 builder.setReplies(replies4);
610
611                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
612                 buf = Unpooled.buffer(result.length);
613                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
614                 assertArrayEquals(result, buf.array());
615         }
616
617         @Test
618         public void testUpdMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
619                 byte[] result = ByteArray.fileToBytes("src/test/resources/PCUpd.2.bin");
620
621                 final PCEPUpdateRequestMessageParser parser = new PCEPUpdateRequestMessageParser(this.objectRegistry);
622
623                 final PcupdMessageBuilder builder = new PcupdMessageBuilder();
624
625                 final List<Updates> updates = Lists.newArrayList();
626                 final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.updates.PathBuilder pBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.updates.PathBuilder();
627                 pBuilder.setEro(this.ero);
628                 pBuilder.setLspa(this.lspa);
629                 updates.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
630                 builder.setUpdates(updates);
631
632                 assertEquals(new PcupdBuilder().setPcupdMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
633                 ByteBuf buf = Unpooled.buffer(result.length);
634                 parser.serializeMessage(new PcupdBuilder().setPcupdMessage(builder.build()).build(), buf);
635                 assertArrayEquals(result, buf.array());
636
637                 result = ByteArray.fileToBytes("src/test/resources/PCUpd.5.bin");
638
639                 final List<Updates> updates1 = Lists.newArrayList();
640                 final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.updates.PathBuilder pBuilder1 = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcupd.message.pcupd.message.updates.PathBuilder();
641                 pBuilder1.setEro(this.ero);
642                 pBuilder1.setLspa(this.lspa);
643                 updates1.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
644                 updates1.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder1.build()).build());
645                 builder.setUpdates(updates1);
646
647                 assertEquals(new PcupdBuilder().setPcupdMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
648                 buf = Unpooled.buffer(result.length);
649                 parser.serializeMessage(new PcupdBuilder().setPcupdMessage(builder.build()).build(), buf);
650                 assertArrayEquals(result, buf.array());
651         }
652
653         @Test
654         public void testRptMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
655                 byte[] result = ByteArray.fileToBytes("src/test/resources/PCRpt.1.bin");
656
657                 final PCEPReportMessageParser parser = new PCEPReportMessageParser(this.objectRegistry);
658
659                 final PcrptMessageBuilder builder = new PcrptMessageBuilder();
660
661                 final List<Reports> reports = Lists.newArrayList();
662                 reports.add(new ReportsBuilder().setLsp(this.lsp).build());
663                 builder.setReports(reports);
664
665                 assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
666                 ByteBuf buf = Unpooled.buffer(result.length);
667                 parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
668                 assertArrayEquals(result, buf.array());
669
670                 result = ByteArray.fileToBytes("src/test/resources/PCRpt.2.bin");
671
672                 final List<Reports> reports1 = Lists.newArrayList();
673                 reports1.add(new ReportsBuilder().setLsp(this.lsp).setPath(new PathBuilder().setEro(this.ero).setLspa(this.lspa).build()).build());
674                 builder.setReports(reports1);
675
676                 assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
677                 buf = Unpooled.buffer(result.length);
678                 parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
679                 assertArrayEquals(result, buf.array());
680
681                 result = ByteArray.fileToBytes("src/test/resources/PCRpt.3.bin");
682
683                 final List<Reports> reports2 = Lists.newArrayList();
684                 final PathBuilder pBuilder = new PathBuilder();
685                 pBuilder.setEro(this.ero);
686                 pBuilder.setLspa(this.lspa);
687                 pBuilder.setMetrics(Lists.newArrayList(this.metrics, this.metrics));
688                 pBuilder.setRro(this.rro);
689                 reports2.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
690                 builder.setReports(reports2);
691
692                 assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
693                 buf = Unpooled.buffer(result.length);
694                 parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
695                 assertArrayEquals(result, buf.array());
696
697                 result = ByteArray.fileToBytes("src/test/resources/PCRpt.5.bin");
698
699                 final List<Reports> reports3 = Lists.newArrayList();
700                 final PathBuilder pBuilder1 = new PathBuilder();
701                 pBuilder1.setEro(this.ero);
702                 pBuilder1.setLspa(this.lspa);
703                 pBuilder1.setMetrics(Lists.newArrayList(this.metrics, this.metrics));
704                 pBuilder1.setRro(this.rro);
705                 reports3.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
706                 reports3.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder1.build()).build());
707                 builder.setReports(reports3);
708
709                 assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
710                 buf = Unpooled.buffer(result.length);
711                 parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
712                 assertArrayEquals(result, buf.array());
713         }
714
715         @Test
716         public void testPcinitMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
717                 final byte[] result = ByteArray.fileToBytes("src/test/resources/Pcinit.bin");
718
719                 final PcinitiateMessageParser parser = new PcinitiateMessageParser(this.objectRegistry);
720
721                 final PcinitiateMessageBuilder builder = new PcinitiateMessageBuilder();
722                 final RequestsBuilder rBuilder = new RequestsBuilder();
723
724                 final List<Requests> reqs = Lists.newArrayList();
725                 rBuilder.setSrp(this.srp);
726                 rBuilder.setLsp(this.lsp);
727                 rBuilder.setEro(this.ero);
728                 rBuilder.setLspa(this.lspa);
729                 rBuilder.setMetrics(Lists.newArrayList(this.metrics));
730                 rBuilder.setIro(this.iro);
731                 reqs.add(rBuilder.build());
732                 builder.setRequests(reqs);
733
734                 assertEquals(new PcinitiateBuilder().setPcinitiateMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
735                 final ByteBuf buf = Unpooled.buffer(result.length);
736                 parser.serializeMessage(new PcinitiateBuilder().setPcinitiateMessage(builder.build()).build(), buf);
737                 assertArrayEquals(result, buf.array());
738         }
739
740         @Test
741         public void testNotificationMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
742                 final CNotification cn1 = new CNotificationBuilder().setIgnore(false).setProcessingRule(false).setType((short) 1).setValue(
743                                 (short) 1).build();
744
745                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Notifications> innerNot = Lists.newArrayList();
746                 innerNot.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
747                                 cn1).build());
748                 final List<Rps> rps = Lists.newArrayList();
749                 rps.add(new RpsBuilder().setRp(this.rp).build());
750
751                 final byte[] result = ByteArray.fileToBytes("src/test/resources/PCNtf.5.bin");
752
753                 final PCEPNotificationMessageParser parser = new PCEPNotificationMessageParser(this.objectRegistry);
754                 final PcntfMessageBuilder builder = new PcntfMessageBuilder();
755
756                 final List<Notifications> nots = Lists.newArrayList();
757                 final NotificationsBuilder b = new NotificationsBuilder();
758                 b.setNotifications(innerNot);
759                 b.setRps(rps);
760                 nots.add(b.build());
761
762                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Notifications> innerNot1 = Lists.newArrayList();
763                 innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
764                                 cn1).build());
765                 innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
766                                 cn1).build());
767                 final List<Rps> rps1 = Lists.newArrayList();
768                 rps1.add(new RpsBuilder().setRp(this.rp).build());
769                 rps1.add(new RpsBuilder().setRp(this.rp).build());
770
771                 b.setNotifications(innerNot1);
772                 b.setRps(rps1);
773                 nots.add(b.build());
774                 builder.setNotifications(nots);
775
776                 assertEquals(new PcntfBuilder().setPcntfMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
777                 final ByteBuf buf = Unpooled.buffer(result.length);
778                 parser.serializeMessage(new PcntfBuilder().setPcntfMessage(builder.build()).build(), buf);
779                 assertArrayEquals(result, buf.array());
780         }
781
782         @Test
783         public void testErrorMsg() throws IOException, PCEPDeserializerException, PCEPDocumentedException {
784                 byte[] result = ByteArray.fileToBytes("src/test/resources/PCErr.3.bin");
785
786                 final ErrorObject error1 = new ErrorObjectBuilder().setIgnore(false).setProcessingRule(false).setType((short) 3).setValue((short) 1).build();
787
788                 final PCEPErrorMessageParser parser = new PCEPErrorMessageParser(this.objectRegistry);
789
790                 List<Errors> innerErr = Lists.newArrayList();
791                 innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
792
793                 final PcerrMessageBuilder builder = new PcerrMessageBuilder();
794                 builder.setErrors(innerErr);
795                 builder.setErrorType(new SessionBuilder().setOpen(this.open).build());
796
797                 assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
798                 ByteBuf buf = Unpooled.buffer(result.length);
799                 parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
800                 assertArrayEquals(result, buf.array());
801
802                 result = ByteArray.fileToBytes("src/test/resources/PCErr.5.bin");
803
804                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request.Rps> rps = Lists.newArrayList();
805                 rps.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request.RpsBuilder().setRp(
806                                 this.rp).build());
807
808                 innerErr = Lists.newArrayList();
809                 innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
810
811                 builder.setErrors(innerErr);
812                 builder.setErrorType(new RequestBuilder().setRps(rps).build());
813
814                 assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(), parser.parseMessage(result, Collections.<Message>emptyList()));
815                 buf = Unpooled.buffer(result.length);
816                 parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
817                 assertArrayEquals(result, buf.array());
818         }
819 }