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
  13 import com.google.common.collect.Lists;
  14 import io.netty.buffer.ByteBuf;
  15 import io.netty.buffer.Unpooled;
  16 import java.io.IOException;
  17 import java.util.ArrayList;
  18 import java.util.Collections;
  19 import java.util.List;
  20 import org.junit.Before;
  21 import org.junit.Test;
  22 import org.opendaylight.protocol.pcep.impl.message.PCEPCloseMessageParser;
  23 import org.opendaylight.protocol.pcep.impl.message.PCEPErrorMessageParser;
  24 import org.opendaylight.protocol.pcep.impl.message.PCEPKeepAliveMessageParser;
  25 import org.opendaylight.protocol.pcep.impl.message.PCEPNotificationMessageParser;
  26 import org.opendaylight.protocol.pcep.impl.message.PCEPOpenMessageParser;
  27 import org.opendaylight.protocol.pcep.impl.message.PCEPReplyMessageParser;
  28 import org.opendaylight.protocol.pcep.impl.message.PCEPRequestMessageParser;
  29 import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
  30 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
  31 import org.opendaylight.protocol.pcep.spi.pojo.SimplePCEPExtensionProviderContext;
  32 import org.opendaylight.protocol.util.ByteArray;
  33 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Address;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ieee754.rev130819.Float32;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.CloseBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.KeepaliveBuilder;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.OpenBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcerrBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcntfBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcrepBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcreqBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.OfId;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.ProtocolVersion;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.RequestId;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.message.CCloseMessageBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.object.CCloseBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.address.family.Ipv4CaseBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.address.family.ipv4._case.Ipv4Builder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.object.EndpointsObj;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.object.EndpointsObjBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.Ero;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.EroBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.Iro;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.IroBuilder;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.Subobject;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.SubobjectBuilder;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.keepalive.message.KeepaliveMessageBuilder;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.Metrics;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.MetricsBuilder;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.Lspa;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.LspaBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.metric.object.MetricBuilder;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotification;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotificationBuilder;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.Of;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.OfBuilder;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.message.OpenMessageBuilder;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.Open;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObject;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObjectBuilder;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.PcerrMessageBuilder;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.Errors;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.ErrorsBuilder;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.RequestCaseBuilder;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.SessionCaseBuilder;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request._case.RequestBuilder;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.session._case.SessionBuilder;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.PcntfMessageBuilder;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.Notifications;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.NotificationsBuilder;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Rps;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.RpsBuilder;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.PcrepMessageBuilder;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.Replies;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.RepliesBuilder;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.FailureCaseBuilder;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.SuccessCaseBuilder;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure._case.NoPath;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure._case.NoPathBuilder;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.SuccessBuilder;
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.success.Paths;
  93 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.success.PathsBuilder;
  94 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.PcreqMessageBuilder;
  95 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.requests.SegmentComputationBuilder;
  96 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.requests.segment.computation.P2pBuilder;
  97 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.Rp;
  98 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.RpBuilder;
  99 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.svec.object.Svec;
 100 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.svec.object.SvecBuilder;
 101 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.AttributeFilter;
 102 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumberCase;
 103 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumberCaseBuilder;
 104 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.as.number._case.AsNumberBuilder;
 105
 106 public class PCEPValidatorTest {
 107
 108     private ObjectRegistry objectRegistry;
 109
 110     private Open open;
 111     private Rp rpTrue;
 112     private Rp rpFalse;
 113     private NoPath noPath;
 114     private Lspa lspa;
 115     private Metrics metrics;
 116     private Iro iro;
 117     private Ero ero;
 118     private Of of;
 119     private EndpointsObj endpoints;
 120     private Svec svec;
 121
 122     private AsNumberCase eroASSubobject;
 123
 124     private SimplePCEPExtensionProviderContext ctx;
 125     private Activator act;
 126
 127     @Before
 128     public void setUp() throws Exception {
 129         this.ctx = new SimplePCEPExtensionProviderContext();
 130         this.act = new Activator();
 131         this.act.start(this.ctx);
 132         this.objectRegistry = this.ctx.getObjectHandlerRegistry();
 133         final RpBuilder rpBuilder = new RpBuilder();
 134         rpBuilder.setProcessingRule(true);
 135         rpBuilder.setIgnore(false);
 136         rpBuilder.setReoptimization(false);
 137         rpBuilder.setBiDirectional(false);
 138         rpBuilder.setLoose(true);
 139         rpBuilder.setMakeBeforeBreak(false);
 140         rpBuilder.setOrder(false);
 141         rpBuilder.setPathKey(false);
 142         rpBuilder.setSupplyOf(false);
 143         rpBuilder.setFragmentation(false);
 144         rpBuilder.setP2mp(false);
 145         rpBuilder.setEroCompression(false);
 146         rpBuilder.setPriority((short) 1);
 147         rpBuilder.setRequestId(new RequestId(10L));
 148         this.rpTrue = rpBuilder.build();
 149         rpBuilder.setProcessingRule(false);
 150         this.rpFalse = rpBuilder.build();
 151
 152         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();
 153         openBuilder.setProcessingRule(false);
 154         openBuilder.setIgnore(false);
 155         openBuilder.setDeadTimer((short) 1);
 156         openBuilder.setKeepalive((short) 1);
 157         openBuilder.setSessionId((short) 0);
 158         openBuilder.setVersion(new ProtocolVersion((short) 1));
 159         openBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().build());
 160         this.open = openBuilder.build();
 161
 162         final NoPathBuilder npbuilder = new NoPathBuilder();
 163         npbuilder.setProcessingRule(false);
 164         npbuilder.setIgnore(false);
 165         npbuilder.setNatureOfIssue((short) 0);
 166         npbuilder.setUnsatisfiedConstraints(false);
 167         this.noPath = npbuilder.build();
 168
 169         final LspaBuilder lspaBuilder = new LspaBuilder();
 170         lspaBuilder.setProcessingRule(false);
 171         lspaBuilder.setIgnore(false);
 172         lspaBuilder.setLocalProtectionDesired(false);
 173         lspaBuilder.setHoldPriority((short) 0);
 174         lspaBuilder.setSetupPriority((short) 0);
 175         lspaBuilder.setExcludeAny(new AttributeFilter(0L));
 176         lspaBuilder.setIncludeAll(new AttributeFilter(0L));
 177         lspaBuilder.setIncludeAny(new AttributeFilter(0L));
 178         lspaBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.lspa.TlvsBuilder().build());
 179         this.lspa = lspaBuilder.build();
 180
 181         final MetricBuilder mBuilder = new MetricBuilder();
 182         mBuilder.setIgnore(false);
 183         mBuilder.setProcessingRule(false);
 184         mBuilder.setComputed(false);
 185         mBuilder.setBound(false);
 186         mBuilder.setMetricType((short) 1);
 187         mBuilder.setValue(new Float32(new byte[4]));
 188         this.metrics = new MetricsBuilder().setMetric(mBuilder.build()).build();
 189
 190         this.eroASSubobject = new AsNumberCaseBuilder().setAsNumber(
 191             new AsNumberBuilder().setAsNumber(
 192                 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.AsNumber(0xFFFFL)).build()).build();
 193
 194         final IroBuilder iroBuilder = new IroBuilder();
 195         iroBuilder.setIgnore(false);
 196         iroBuilder.setProcessingRule(false);
 197         final List<Subobject> iroSubs = Lists.newArrayList();
 198         iroSubs.add(new SubobjectBuilder().setSubobjectType(this.eroASSubobject).build());
 199         iroBuilder.setSubobject(iroSubs);
 200         this.iro = iroBuilder.build();
 201
 202         final EroBuilder eroBuilder = new EroBuilder();
 203         eroBuilder.setIgnore(false);
 204         eroBuilder.setProcessingRule(false);
 205         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.Subobject> eroSubs = Lists.newArrayList();
 206         eroSubs.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.SubobjectBuilder().setSubobjectType(
 207             this.eroASSubobject).setLoose(false).build());
 208         eroBuilder.setSubobject(eroSubs);
 209         this.ero = eroBuilder.build();
 210
 211         final OfBuilder ofBuilder = new OfBuilder();
 212         ofBuilder.setIgnore(false);
 213         ofBuilder.setProcessingRule(false);
 214         ofBuilder.setCode(new OfId(0));
 215         this.of = ofBuilder.build();
 216
 217         final Ipv4Builder afi = new Ipv4Builder();
 218         afi.setSourceIpv4Address(new Ipv4Address("255.255.255.255"));
 219         afi.setDestinationIpv4Address(new Ipv4Address("255.255.255.255"));
 220
 221         final EndpointsObjBuilder epBuilder = new EndpointsObjBuilder();
 222         epBuilder.setIgnore(false);
 223         epBuilder.setProcessingRule(true);
 224         epBuilder.setAddressFamily(new Ipv4CaseBuilder().setIpv4(afi.build()).build());
 225         this.endpoints = epBuilder.build();
 226
 227         final SvecBuilder sBuilder = new SvecBuilder();
 228         sBuilder.setIgnore(false);
 229         sBuilder.setProcessingRule(false);
 230         sBuilder.setLinkDiverse(false);
 231         sBuilder.setNodeDiverse(false);
 232         sBuilder.setSrlgDiverse(false);
 233         sBuilder.setRequestsIds(Lists.newArrayList(new RequestId(1L)));
 234         this.svec = sBuilder.build();
 235     }
 236
 237     @Test
 238     public void testOpenMsg() throws IOException, PCEPDeserializerException {
 239         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPOpenMessage1.bin"));
 240         final PCEPOpenMessageParser parser = new PCEPOpenMessageParser(this.ctx.getObjectHandlerRegistry());
 241         final OpenMessageBuilder builder = new OpenMessageBuilder();
 242
 243         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();
 244         b.setProcessingRule(false);
 245         b.setIgnore(false);
 246         b.setVersion(new ProtocolVersion((short) 1));
 247         b.setKeepalive((short) 30);
 248         b.setDeadTimer((short) 120);
 249         b.setSessionId((short) 1);
 250         b.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().build());
 251         builder.setOpen(b.build());
 252
 253         assertEquals(new OpenBuilder().setOpenMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 254             result.readableBytes() - 4), Collections.<Message> emptyList()));
 255         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 256         parser.serializeMessage(new OpenBuilder().setOpenMessage(builder.build()).build(), buf);
 257         assertArrayEquals(result.array(), buf.array());
 258     }
 259
 260     @Test
 261     public void testKeepAliveMsg() throws IOException, PCEPDeserializerException {
 262         final ByteBuf result = Unpooled.wrappedBuffer(new byte[] { 32, 2, 0, 4 });
 263         final PCEPKeepAliveMessageParser parser = new PCEPKeepAliveMessageParser(this.objectRegistry);
 264         final KeepaliveBuilder builder = new KeepaliveBuilder().setKeepaliveMessage(new KeepaliveMessageBuilder().build());
 265
 266         assertEquals(builder.build(), parser.parseMessage(result.slice(4, result.readableBytes() - 4), Collections.<Message> emptyList()));
 267         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 268         parser.serializeMessage(builder.build(), buf);
 269         assertArrayEquals(result.array(), buf.array());
 270     }
 271
 272     @Test
 273     public void testCloseMsg() throws IOException, PCEPDeserializerException {
 274         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPCloseMessage1.bin"));
 275
 276         final PCEPCloseMessageParser parser = new PCEPCloseMessageParser(this.objectRegistry);
 277         final CloseBuilder builder = new CloseBuilder().setCCloseMessage(new CCloseMessageBuilder().setCClose(
 278             new CCloseBuilder().setIgnore(false).setProcessingRule(false).setReason((short) 5).build()).build());
 279
 280         assertEquals(builder.build(), parser.parseMessage(result.slice(4, result.readableBytes() - 4), Collections.<Message> emptyList()));
 281         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 282         parser.serializeMessage(builder.build(), buf);
 283         assertArrayEquals(result.array(), buf.array());
 284     }
 285
 286     @Test
 287     public void testRequestMsg() throws IOException, PCEPDeserializerException {
 288         ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPRequestMessage1.bin"));
 289
 290         final PCEPRequestMessageParser parser = new PCEPRequestMessageParser(this.objectRegistry);
 291
 292         final PcreqMessageBuilder builder = new PcreqMessageBuilder();
 293         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs1 = Lists.newArrayList();
 294         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder rBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder();
 295         rBuilder.setRp(this.rpTrue);
 296         rBuilder.setSegmentComputation(new SegmentComputationBuilder().setP2p(new P2pBuilder().setEndpointsObj(this.endpoints).build()).build());
 297         reqs1.add(rBuilder.build());
 298         builder.setRequests(reqs1);
 299
 300         assertEquals(new PcreqBuilder().setPcreqMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 301             result.readableBytes() - 4), Collections.<Message> emptyList()));
 302         ByteBuf buf = Unpooled.buffer(result.readableBytes());
 303         parser.serializeMessage(new PcreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 304
 305         assertArrayEquals(result.array(), buf.array());
 306
 307         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCReq.3.bin"));
 308
 309         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs2 = Lists.newArrayList();
 310         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder rBuilder1 = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder();
 311         rBuilder1.setRp(this.rpTrue);
 312         final P2pBuilder p2pBuilder = new P2pBuilder();
 313         p2pBuilder.setEndpointsObj(this.endpoints);
 314         p2pBuilder.setMetrics(Lists.newArrayList(this.metrics));
 315         p2pBuilder.setIro(this.iro);
 316         rBuilder1.setSegmentComputation(new SegmentComputationBuilder().setP2p(p2pBuilder.build()).build());
 317         reqs2.add(rBuilder1.build());
 318         builder.setRequests(reqs2);
 319         builder.setSvec(Lists.newArrayList(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.SvecBuilder().setSvec(
 320             this.svec).build()));
 321
 322         assertEquals(new PcreqBuilder().setPcreqMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 323             result.readableBytes() - 4), Collections.<Message> emptyList()));
 324         buf = Unpooled.buffer(result.readableBytes());
 325         parser.serializeMessage(new PcreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 326         assertArrayEquals(result.array(), buf.array());
 327     }
 328
 329     @Test
 330     public void testReplyMsg() throws IOException, PCEPDeserializerException {
 331         // only RP
 332         ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.1.bin"));
 333
 334         final PCEPReplyMessageParser parser = new PCEPReplyMessageParser(this.objectRegistry);
 335
 336         final PcrepMessageBuilder builder = new PcrepMessageBuilder();
 337         RepliesBuilder rBuilder = new RepliesBuilder();
 338
 339         final List<Replies> replies1 = Lists.newArrayList();
 340         rBuilder.setRp(this.rpTrue);
 341         replies1.add(rBuilder.build());
 342         builder.setReplies(replies1);
 343
 344         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 345             result.readableBytes() - 4), Collections.<Message> emptyList()));
 346         ByteBuf buf = Unpooled.buffer(result.readableBytes());
 347         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 348         assertArrayEquals(result.array(), buf.array());
 349
 350         // simple Failure
 351         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.2.bin"));
 352         final List<Replies> replies2 = Lists.newArrayList();
 353         rBuilder = new RepliesBuilder();
 354         rBuilder.setRp(this.rpTrue);
 355         replies2.add(rBuilder.build());
 356         final RepliesBuilder rBuilder2 = new RepliesBuilder();
 357         rBuilder2.setRp(this.rpTrue);
 358         rBuilder2.setResult(new FailureCaseBuilder().setNoPath(this.noPath).build());
 359         replies2.add(rBuilder2.build());
 360         builder.setReplies(replies2);
 361
 362         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 363             result.readableBytes() - 4), Collections.<Message> emptyList()));
 364         buf = Unpooled.buffer(result.readableBytes());
 365         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 366         assertArrayEquals(result.array(), buf.array());
 367
 368         // Failure with attributes
 369         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.3.bin"));
 370         final List<Replies> replies3 = Lists.newArrayList();
 371         rBuilder = new RepliesBuilder();
 372         rBuilder.setRp(this.rpTrue);
 373         rBuilder.setResult(new FailureCaseBuilder().setNoPath(this.noPath).setLspa(this.lspa).setMetrics(Lists.newArrayList(this.metrics)).setIro(
 374             this.iro).build());
 375         replies3.add(rBuilder.build());
 376         builder.setReplies(replies3);
 377
 378         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 379             result.readableBytes() - 4), Collections.<Message> emptyList()));
 380         buf = Unpooled.buffer(result.readableBytes());
 381         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 382         assertArrayEquals(result.array(), buf.array());
 383
 384         // Success
 385         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.5.bin"));
 386         final List<Replies> replies4 = Lists.newArrayList();
 387         rBuilder = new RepliesBuilder();
 388         rBuilder.setRp(this.rpTrue);
 389         final List<Paths> paths = Lists.newArrayList();
 390         final PathsBuilder paBuilder = new PathsBuilder();
 391         paBuilder.setEro(this.ero);
 392         paBuilder.setLspa(this.lspa);
 393         paBuilder.setMetrics(Lists.newArrayList(this.metrics));
 394         paBuilder.setIro(this.iro);
 395         paBuilder.setOf(this.of);
 396         paths.add(paBuilder.build());
 397         rBuilder.setResult(new SuccessCaseBuilder().setSuccess(new SuccessBuilder().setPaths(paths).build()).build()).build();
 398         replies4.add(rBuilder.build());
 399         builder.setReplies(replies4);
 400
 401         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 402             result.readableBytes() - 4), Collections.<Message> emptyList()));
 403         buf = Unpooled.buffer(result.readableBytes());
 404         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 405         assertArrayEquals(result.array(), buf.array());
 406     }
 407
 408     @Test
 409     public void testNotificationMsg() throws IOException, PCEPDeserializerException {
 410         final CNotification cn1 = new CNotificationBuilder().setIgnore(false).setProcessingRule(false).setType((short) 1).setValue(
 411             (short) 1).build();
 412
 413         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();
 414         innerNot.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 415             cn1).build());
 416         final List<Rps> rps = Lists.newArrayList();
 417         rps.add(new RpsBuilder().setRp(this.rpFalse).build());
 418
 419         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCNtf.5.bin"));
 420
 421         final PCEPNotificationMessageParser parser = new PCEPNotificationMessageParser(this.objectRegistry);
 422         final PcntfMessageBuilder builder = new PcntfMessageBuilder();
 423
 424         final List<Notifications> nots = Lists.newArrayList();
 425         final NotificationsBuilder b = new NotificationsBuilder();
 426         b.setNotifications(innerNot);
 427         b.setRps(rps);
 428         nots.add(b.build());
 429
 430         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();
 431         innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 432             cn1).build());
 433         innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 434             cn1).build());
 435         final List<Rps> rps1 = Lists.newArrayList();
 436         rps1.add(new RpsBuilder().setRp(this.rpFalse).build());
 437         rps1.add(new RpsBuilder().setRp(this.rpFalse).build());
 438
 439         b.setNotifications(innerNot1);
 440         b.setRps(rps1);
 441         nots.add(b.build());
 442         builder.setNotifications(nots);
 443
 444         assertEquals(new PcntfBuilder().setPcntfMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 445             result.readableBytes() - 4), Collections.<Message> emptyList()));
 446         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 447         parser.serializeMessage(new PcntfBuilder().setPcntfMessage(builder.build()).build(), buf);
 448         assertArrayEquals(result.array(), buf.array());
 449     }
 450
 451     @Test
 452     public void testErrorMsg() throws IOException, PCEPDeserializerException {
 453         ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCErr.5.bin"));
 454
 455         ErrorObject error1 = new ErrorObjectBuilder().setIgnore(false).setProcessingRule(false).setType((short) 3).setValue((short) 1).build();
 456
 457         final PCEPErrorMessageParser parser = new PCEPErrorMessageParser(this.ctx.getObjectHandlerRegistry());
 458
 459         List<Errors> innerErr = new ArrayList<>();
 460
 461         final PcerrMessageBuilder builder = new PcerrMessageBuilder();
 462
 463         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request._case.request.Rps> rps = Lists.newArrayList();
 464         rps.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request._case.request.RpsBuilder().setRp(
 465             this.rpFalse).build());
 466
 467         innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
 468
 469         builder.setErrors(innerErr);
 470         builder.setErrorType(new RequestCaseBuilder().setRequest(new RequestBuilder().setRps(rps).build()).build());
 471
 472         assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 473             result.readableBytes() - 4), Collections.<Message> emptyList()));
 474         ByteBuf buf = Unpooled.buffer(result.readableBytes());
 475         parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
 476         assertArrayEquals(result.array(), buf.array());
 477
 478         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCErr.3.bin"));
 479
 480         error1 = new ErrorObjectBuilder().setIgnore(false).setProcessingRule(false).setType((short) 3).setValue((short) 1).build();
 481
 482         innerErr = new ArrayList<>();
 483         innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
 484
 485         builder.setErrors(innerErr);
 486         builder.setErrorType(new SessionCaseBuilder().setSession(new SessionBuilder().setOpen(this.open).build()).build());
 487
 488         assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 489             result.readableBytes() - 4), Collections.<Message> emptyList()));
 490         buf = Unpooled.buffer(result.readableBytes());
 491         parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
 492         assertArrayEquals(result.array(), buf.array());
 493     }
 494 }