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