pcep/ietf-stateful07/src/test/java/org/opendaylight/protocol/pcep/ietf/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.ietf;
   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.util.Collections;
  17 import java.util.List;
  18
  19 import org.junit.Before;
  20 import org.junit.Test;
  21 import org.opendaylight.protocol.pcep.ietf.initiated00.CInitiated00PCInitiateMessageParser;
  22 import org.opendaylight.protocol.pcep.ietf.initiated00.CrabbeInitiatedActivator;
  23 import org.opendaylight.protocol.pcep.ietf.stateful07.Stateful07PCReportMessageParser;
  24 import org.opendaylight.protocol.pcep.ietf.stateful07.Stateful07PCUpdateRequestMessageParser;
  25 import org.opendaylight.protocol.pcep.ietf.stateful07.StatefulActivator;
  26 import org.opendaylight.protocol.pcep.impl.Activator;
  27 import org.opendaylight.protocol.pcep.impl.message.PCEPCloseMessageParser;
  28 import org.opendaylight.protocol.pcep.impl.message.PCEPErrorMessageParser;
  29 import org.opendaylight.protocol.pcep.impl.message.PCEPKeepAliveMessageParser;
  30 import org.opendaylight.protocol.pcep.impl.message.PCEPNotificationMessageParser;
  31 import org.opendaylight.protocol.pcep.impl.message.PCEPOpenMessageParser;
  32 import org.opendaylight.protocol.pcep.impl.message.PCEPReplyMessageParser;
  33 import org.opendaylight.protocol.pcep.impl.message.PCEPRequestMessageParser;
  34 import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
  35 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
  36 import org.opendaylight.protocol.pcep.spi.pojo.SimplePCEPExtensionProviderContext;
  37 import org.opendaylight.protocol.util.ByteArray;
  38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Address;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ieee754.rev130819.Float32;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Lsp1;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Lsp1Builder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.PcinitiateBuilder;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Srp1;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Srp1Builder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.pcinitiate.message.PcinitiateMessageBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.pcinitiate.message.pcinitiate.message.Requests;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.pcinitiate.message.pcinitiate.message.RequestsBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.OperationalStatus;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.PcrptBuilder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.PcupdBuilder;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.PlspId;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SrpIdNumber;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Tlvs1;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Tlvs1Builder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.Lsp;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.LspBuilder;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.lsp.TlvsBuilder;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.PcrptMessageBuilder;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.Reports;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.ReportsBuilder;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcupd.message.PcupdMessageBuilder;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcupd.message.pcupd.message.Updates;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcupd.message.pcupd.message.UpdatesBuilder;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcupd.message.pcupd.message.updates.PathBuilder;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.Srp;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.SrpBuilder;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.stateful.capability.tlv.Stateful;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.stateful.capability.tlv.StatefulBuilder;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.CloseBuilder;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.KeepaliveBuilder;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.OpenBuilder;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcerrBuilder;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcntfBuilder;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcrepBuilder;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcreqBuilder;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.OfId;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.ProtocolVersion;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.RequestId;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.bandwidth.object.Bandwidth;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.bandwidth.object.BandwidthBuilder;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.message.CCloseMessageBuilder;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.object.CCloseBuilder;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.address.family.Ipv4CaseBuilder;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.address.family.ipv4._case.Ipv4Builder;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.object.EndpointsObj;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.object.EndpointsObjBuilder;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.Ero;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.EroBuilder;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.Iro;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.IroBuilder;
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.Subobject;
  93 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.SubobjectBuilder;
  94 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.keepalive.message.KeepaliveMessageBuilder;
  95 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.Metrics;
  96 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.MetricsBuilder;
  97 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.Lspa;
  98 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.LspaBuilder;
  99 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.metric.object.MetricBuilder;
 100 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotification;
 101 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotificationBuilder;
 102 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.Of;
 103 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.OfBuilder;
 104 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.message.OpenMessageBuilder;
 105 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.Open;
 106 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObject;
 107 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObjectBuilder;
 108 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.PcerrMessageBuilder;
 109 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.Errors;
 110 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.ErrorsBuilder;
 111 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.RequestCaseBuilder;
 112 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.SessionCaseBuilder;
 113 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request._case.RequestBuilder;
 114 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.session._case.SessionBuilder;
 115 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.PcntfMessageBuilder;
 116 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.Notifications;
 117 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.NotificationsBuilder;
 118 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Rps;
 119 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.RpsBuilder;
 120 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.PcrepMessageBuilder;
 121 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.Replies;
 122 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.RepliesBuilder;
 123 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.FailureCaseBuilder;
 124 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.SuccessCaseBuilder;
 125 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure._case.NoPath;
 126 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure._case.NoPathBuilder;
 127 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.SuccessBuilder;
 128 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;
 129 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;
 130 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.PcreqMessageBuilder;
 131 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.requests.SegmentComputationBuilder;
 132 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.requests.segment.computation.P2pBuilder;
 133 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.Rro;
 134 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.RroBuilder;
 135 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.Rp;
 136 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.RpBuilder;
 137 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.svec.object.Svec;
 138 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.svec.object.SvecBuilder;
 139 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.AttributeFilter;
 140 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumberCase;
 141 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumberCaseBuilder;
 142 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.as.number._case.AsNumberBuilder;
 143 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.subobject.type.UnnumberedCase;
 144 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.subobject.type.UnnumberedCaseBuilder;
 145 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.subobject.type.unnumbered._case.UnnumberedBuilder;
 146
 147 import com.google.common.collect.Lists;
 148
 149 public class PCEPValidatorTest {
 150
 151         private ObjectHandlerRegistry objectRegistry;
 152
 153         private Rp rpTrue;
 154         private Rp rpFalse;
 155         private Open open;
 156         private NoPath noPath;
 157         private Lspa lspa;
 158         private Bandwidth bandwidth;
 159         private Metrics metrics;
 160         private Iro iro;
 161         private Ero ero;
 162         private Rro rro;
 163         private Of of;
 164         private Srp srp;
 165         private Lsp lsp;
 166         private EndpointsObj endpoints;
 167         private Svec svec;
 168
 169         private AsNumberCase eroASSubobject;
 170         private UnnumberedCase rroUnnumberedSub;
 171
 172         private SimplePCEPExtensionProviderContext ctx;
 173         private Activator act;
 174
 175         @Before
 176         public void setUp() throws Exception {
 177                 this.ctx = new SimplePCEPExtensionProviderContext();
 178                 this.act = new Activator();
 179                 this.act.start(this.ctx);
 180                 this.objectRegistry = this.ctx.getObjectHandlerRegistry();
 181                 final RpBuilder rpBuilder = new RpBuilder();
 182                 rpBuilder.setProcessingRule(true);
 183                 rpBuilder.setIgnore(false);
 184                 rpBuilder.setReoptimization(false);
 185                 rpBuilder.setBiDirectional(false);
 186                 rpBuilder.setLoose(true);
 187                 rpBuilder.setMakeBeforeBreak(false);
 188                 rpBuilder.setOrder(false);
 189                 rpBuilder.setPathKey(false);
 190                 rpBuilder.setSupplyOf(false);
 191                 rpBuilder.setFragmentation(false);
 192                 rpBuilder.setP2mp(false);
 193                 rpBuilder.setEroCompression(false);
 194                 rpBuilder.setPriority((short) 1);
 195                 rpBuilder.setRequestId(new RequestId(10L));
 196                 this.rpTrue = rpBuilder.build();
 197                 rpBuilder.setProcessingRule(false);
 198                 this.rpFalse = rpBuilder.build();
 199
 200                 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();
 201                 openBuilder.setProcessingRule(false);
 202                 openBuilder.setIgnore(false);
 203                 openBuilder.setDeadTimer((short) 1);
 204                 openBuilder.setKeepalive((short) 1);
 205                 openBuilder.setSessionId((short) 0);
 206                 openBuilder.setVersion(new ProtocolVersion((short) 1));
 207                 openBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().build());
 208                 this.open = openBuilder.build();
 209
 210                 final NoPathBuilder npbuilder = new NoPathBuilder();
 211                 npbuilder.setProcessingRule(false);
 212                 npbuilder.setIgnore(false);
 213                 npbuilder.setNatureOfIssue((short) 0);
 214                 npbuilder.setUnsatisfiedConstraints(false);
 215                 this.noPath = npbuilder.build();
 216
 217                 final LspaBuilder lspaBuilder = new LspaBuilder();
 218                 lspaBuilder.setProcessingRule(false);
 219                 lspaBuilder.setIgnore(false);
 220                 lspaBuilder.setLocalProtectionDesired(false);
 221                 lspaBuilder.setHoldPriority((short) 0);
 222                 lspaBuilder.setSetupPriority((short) 0);
 223                 lspaBuilder.setExcludeAny(new AttributeFilter(0L));
 224                 lspaBuilder.setIncludeAll(new AttributeFilter(0L));
 225                 lspaBuilder.setIncludeAny(new AttributeFilter(0L));
 226                 lspaBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.lspa.TlvsBuilder().build());
 227                 this.lspa = lspaBuilder.build();
 228
 229                 final BandwidthBuilder bBuilder = new BandwidthBuilder();
 230                 bBuilder.setIgnore(false);
 231                 bBuilder.setProcessingRule(false);
 232                 bBuilder.setBandwidth(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.network.concepts.rev131125.Bandwidth(new Float32(new byte[4])));
 233                 this.bandwidth = bBuilder.build();
 234
 235                 final MetricBuilder mBuilder = new MetricBuilder();
 236                 mBuilder.setIgnore(false);
 237                 mBuilder.setProcessingRule(false);
 238                 mBuilder.setComputed(false);
 239                 mBuilder.setBound(false);
 240                 mBuilder.setMetricType((short) 1);
 241                 mBuilder.setValue(new Float32(new byte[4]));
 242                 this.metrics = new MetricsBuilder().setMetric(mBuilder.build()).build();
 243
 244                 this.eroASSubobject = new AsNumberCaseBuilder().setAsNumber(
 245                                 new AsNumberBuilder().setAsNumber(
 246                                                 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.AsNumber(0xFFFFL)).build()).build();
 247
 248                 this.rroUnnumberedSub = new UnnumberedCaseBuilder().setUnnumbered(
 249                                 new UnnumberedBuilder().setRouterId(0x00112233L).setInterfaceId(0x00ff00ffL).build()).build();
 250
 251                 final IroBuilder iroBuilder = new IroBuilder();
 252                 iroBuilder.setIgnore(false);
 253                 iroBuilder.setProcessingRule(false);
 254                 final List<Subobject> iroSubs = Lists.newArrayList();
 255                 iroSubs.add(new SubobjectBuilder().setSubobjectType(this.eroASSubobject).build());
 256                 iroBuilder.setSubobject(iroSubs);
 257                 this.iro = iroBuilder.build();
 258
 259                 final EroBuilder eroBuilder = new EroBuilder();
 260                 eroBuilder.setIgnore(false);
 261                 eroBuilder.setProcessingRule(false);
 262                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.Subobject> eroSubs = Lists.newArrayList();
 263                 eroSubs.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.SubobjectBuilder().setSubobjectType(
 264                                 this.eroASSubobject).setLoose(false).build());
 265                 eroBuilder.setSubobject(eroSubs);
 266                 this.ero = eroBuilder.build();
 267
 268                 final RroBuilder rroBuilder = new RroBuilder();
 269                 rroBuilder.setIgnore(false);
 270                 rroBuilder.setProcessingRule(false);
 271                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.rro.Subobject> rroSubs = Lists.newArrayList();
 272                 rroSubs.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.reported.route.object.rro.SubobjectBuilder().setSubobjectType(
 273                                 this.rroUnnumberedSub).setProtectionAvailable(false).setProtectionInUse(false).build());
 274                 rroBuilder.setSubobject(rroSubs);
 275                 this.rro = rroBuilder.build();
 276
 277                 final OfBuilder ofBuilder = new OfBuilder();
 278                 ofBuilder.setIgnore(false);
 279                 ofBuilder.setProcessingRule(false);
 280                 ofBuilder.setCode(new OfId(0));
 281                 this.of = ofBuilder.build();
 282
 283                 final SrpBuilder srpBuilder = new SrpBuilder();
 284                 srpBuilder.setIgnore(false);
 285                 srpBuilder.setProcessingRule(false);
 286                 srpBuilder.setOperationId(new SrpIdNumber(1L));
 287                 srpBuilder.addAugmentation(Srp1.class, new Srp1Builder().setRemove(false).build());
 288                 this.srp = srpBuilder.build();
 289
 290                 final LspBuilder lspBuilder = new LspBuilder();
 291                 lspBuilder.setIgnore(false);
 292                 lspBuilder.setProcessingRule(false);
 293                 lspBuilder.setAdministrative(false);
 294                 lspBuilder.setDelegate(false);
 295                 lspBuilder.setPlspId(new PlspId(0L));
 296                 lspBuilder.setOperational(OperationalStatus.Down);
 297                 lspBuilder.setSync(false);
 298                 lspBuilder.setRemove(false);
 299                 lspBuilder.setTlvs(new TlvsBuilder().build());
 300                 lspBuilder.addAugmentation(Lsp1.class, new Lsp1Builder().setCreate(false).build());
 301                 this.lsp = lspBuilder.build();
 302
 303                 final Ipv4Builder afi = new Ipv4Builder();
 304                 afi.setSourceIpv4Address(new Ipv4Address("255.255.255.255"));
 305                 afi.setDestinationIpv4Address(new Ipv4Address("255.255.255.255"));
 306
 307                 final EndpointsObjBuilder epBuilder = new EndpointsObjBuilder();
 308                 epBuilder.setIgnore(false);
 309                 epBuilder.setProcessingRule(true);
 310                 epBuilder.setAddressFamily(new Ipv4CaseBuilder().setIpv4(afi.build()).build());
 311                 this.endpoints = epBuilder.build();
 312
 313                 final SvecBuilder sBuilder = new SvecBuilder();
 314                 sBuilder.setIgnore(false);
 315                 sBuilder.setProcessingRule(false);
 316                 sBuilder.setLinkDiverse(false);
 317                 sBuilder.setNodeDiverse(false);
 318                 sBuilder.setSrlgDiverse(false);
 319                 sBuilder.setRequestsIds(Lists.newArrayList(new RequestId(1L)));
 320                 this.svec = sBuilder.build();
 321         }
 322
 323         @Test
 324         public void testOpenMsg() throws IOException, PCEPDeserializerException {
 325                 try (StatefulActivator a = new StatefulActivator()) {
 326                         a.start(this.ctx);
 327                         final byte[] result = ByteArray.fileToBytes("src/test/resources/PCEPOpenMessage1.bin");
 328                         final PCEPOpenMessageParser parser = new PCEPOpenMessageParser(this.ctx.getObjectHandlerRegistry());
 329                         final OpenMessageBuilder builder = new OpenMessageBuilder();
 330
 331                         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();
 332                         b.setProcessingRule(false);
 333                         b.setIgnore(false);
 334                         b.setVersion(new ProtocolVersion((short) 1));
 335                         b.setKeepalive((short) 30);
 336                         b.setDeadTimer((short) 120);
 337                         b.setSessionId((short) 1);
 338                         final Stateful tlv1 = new StatefulBuilder().setLspUpdateCapability(Boolean.TRUE).build();
 339                         b.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().addAugmentation(
 340                                         Tlvs1.class, new Tlvs1Builder().setStateful(tlv1).build()).build());
 341                         builder.setOpen(b.build());
 342
 343                         assertEquals(new OpenBuilder().setOpenMessage(builder.build()).build(),
 344                                         parser.parseMessage(result, Collections.<Message> emptyList()));
 345                         final ByteBuf buf = Unpooled.buffer(result.length);
 346                         parser.serializeMessage(new OpenBuilder().setOpenMessage(builder.build()).build(), buf);
 347                         assertArrayEquals(result, buf.array());
 348                 }
 349         }
 350
 351         @Test
 352         public void testKeepAliveMsg() throws IOException, PCEPDeserializerException {
 353                 final byte[] result = new byte[] {};
 354                 final PCEPKeepAliveMessageParser parser = new PCEPKeepAliveMessageParser(this.objectRegistry);
 355                 final KeepaliveBuilder builder = new KeepaliveBuilder().setKeepaliveMessage(new KeepaliveMessageBuilder().build());
 356
 357                 assertEquals(builder.build(), parser.parseMessage(result, Collections.<Message> emptyList()));
 358                 final ByteBuf buf = Unpooled.buffer(result.length);
 359                 parser.serializeMessage(builder.build(), buf);
 360                 assertArrayEquals(result, buf.array());
 361         }
 362
 363         @Test
 364         public void testCloseMsg() throws IOException, PCEPDeserializerException {
 365                 final byte[] result = ByteArray.fileToBytes("src/test/resources/PCEPCloseMessage1.bin");
 366
 367                 final PCEPCloseMessageParser parser = new PCEPCloseMessageParser(this.objectRegistry);
 368                 final CloseBuilder builder = new CloseBuilder().setCCloseMessage(new CCloseMessageBuilder().setCClose(
 369                                 new CCloseBuilder().setIgnore(false).setProcessingRule(false).setReason((short) 5).build()).build());
 370
 371                 assertEquals(builder.build(), parser.parseMessage(result, Collections.<Message> emptyList()));
 372                 final ByteBuf buf = Unpooled.buffer(result.length);
 373                 parser.serializeMessage(builder.build(), buf);
 374                 assertArrayEquals(result, buf.array());
 375         }
 376
 377         @Test
 378         public void testRequestMsg() throws IOException, PCEPDeserializerException {
 379                 byte[] result = ByteArray.fileToBytes("src/test/resources/PCEPRequestMessage1.bin");
 380
 381                 final PCEPRequestMessageParser parser = new PCEPRequestMessageParser(this.objectRegistry);
 382
 383                 final PcreqMessageBuilder builder = new PcreqMessageBuilder();
 384                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs1 = Lists.newArrayList();
 385                 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();
 386                 rBuilder.setRp(this.rpTrue);
 387                 rBuilder.setSegmentComputation(new SegmentComputationBuilder().setP2p(new P2pBuilder().setEndpointsObj(this.endpoints).build()).build());
 388                 reqs1.add(rBuilder.build());
 389                 builder.setRequests(reqs1);
 390
 391                 assertEquals(new PcreqBuilder().setPcreqMessage(builder.build()).build(),
 392                                 parser.parseMessage(result, Collections.<Message> emptyList()));
 393                 ByteBuf buf = Unpooled.buffer(result.length);
 394                 parser.serializeMessage(new PcreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 395
 396                 assertArrayEquals(result, buf.array());
 397
 398                 result = ByteArray.fileToBytes("src/test/resources/PCReq.3.bin");
 399
 400                 final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs2 = Lists.newArrayList();
 401                 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();
 402                 rBuilder1.setRp(this.rpTrue);
 403                 final P2pBuilder p2pBuilder = new P2pBuilder();
 404                 p2pBuilder.setEndpointsObj(this.endpoints);
 405                 p2pBuilder.setMetrics(Lists.newArrayList(this.metrics));
 406                 p2pBuilder.setIro(this.iro);
 407                 rBuilder1.setSegmentComputation(new SegmentComputationBuilder().setP2p(p2pBuilder.build()).build());
 408                 reqs2.add(rBuilder1.build());
 409                 builder.setRequests(reqs2);
 410                 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(
 411                                 this.svec).build()));
 412
 413                 assertEquals(new PcreqBuilder().setPcreqMessage(builder.build()).build(),
 414                                 parser.parseMessage(result, Collections.<Message> emptyList()));
 415                 buf = Unpooled.buffer(result.length);
 416                 parser.serializeMessage(new PcreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 417                 assertArrayEquals(result, buf.array());
 418         }
 419
 420         @Test
 421         public void testReplyMsg() throws IOException, PCEPDeserializerException {
 422                 // only RP
 423                 byte[] result = ByteArray.fileToBytes("src/test/resources/PCRep.1.bin");
 424
 425                 final PCEPReplyMessageParser parser = new PCEPReplyMessageParser(this.objectRegistry);
 426
 427                 final PcrepMessageBuilder builder = new PcrepMessageBuilder();
 428                 RepliesBuilder rBuilder = new RepliesBuilder();
 429
 430                 final List<Replies> replies1 = Lists.newArrayList();
 431                 rBuilder.setRp(this.rpTrue);
 432                 replies1.add(rBuilder.build());
 433                 builder.setReplies(replies1);
 434
 435                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(),
 436                                 parser.parseMessage(result, Collections.<Message> emptyList()));
 437                 ByteBuf buf = Unpooled.buffer(result.length);
 438                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 439                 assertArrayEquals(result, buf.array());
 440
 441                 // simple Failure
 442                 result = ByteArray.fileToBytes("src/test/resources/PCRep.2.bin");
 443                 final List<Replies> replies2 = Lists.newArrayList();
 444                 rBuilder = new RepliesBuilder();
 445                 rBuilder.setRp(this.rpTrue);
 446                 replies2.add(rBuilder.build());
 447                 final RepliesBuilder rBuilder2 = new RepliesBuilder();
 448                 rBuilder2.setRp(this.rpTrue);
 449                 rBuilder2.setResult(new FailureCaseBuilder().setNoPath(this.noPath).build());
 450                 replies2.add(rBuilder2.build());
 451                 builder.setReplies(replies2);
 452
 453                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(),
 454                                 parser.parseMessage(result, Collections.<Message> emptyList()));
 455                 buf = Unpooled.buffer(result.length);
 456                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 457                 assertArrayEquals(result, buf.array());
 458
 459                 // Failure with attributes
 460                 result = ByteArray.fileToBytes("src/test/resources/PCRep.3.bin");
 461                 final List<Replies> replies3 = Lists.newArrayList();
 462                 rBuilder = new RepliesBuilder();
 463                 rBuilder.setRp(this.rpTrue);
 464                 rBuilder.setResult(new FailureCaseBuilder().setNoPath(this.noPath).setLspa(this.lspa).setMetrics(Lists.newArrayList(this.metrics)).setIro(
 465                                 this.iro).build());
 466                 replies3.add(rBuilder.build());
 467                 builder.setReplies(replies3);
 468
 469                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(),
 470                                 parser.parseMessage(result, Collections.<Message> emptyList()));
 471                 buf = Unpooled.buffer(result.length);
 472                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 473                 assertArrayEquals(result, buf.array());
 474
 475                 // Success
 476                 result = ByteArray.fileToBytes("src/test/resources/PCRep.5.bin");
 477                 final List<Replies> replies4 = Lists.newArrayList();
 478                 rBuilder = new RepliesBuilder();
 479                 rBuilder.setRp(this.rpTrue);
 480                 final List<Paths> paths = Lists.newArrayList();
 481                 final PathsBuilder paBuilder = new PathsBuilder();
 482                 paBuilder.setEro(this.ero);
 483                 paBuilder.setLspa(this.lspa);
 484                 paBuilder.setMetrics(Lists.newArrayList(this.metrics));
 485                 paBuilder.setIro(this.iro);
 486                 paBuilder.setOf(this.of);
 487                 paths.add(paBuilder.build());
 488                 rBuilder.setResult(new SuccessCaseBuilder().setSuccess(new SuccessBuilder().setPaths(paths).build()).build()).build();
 489                 replies4.add(rBuilder.build());
 490                 builder.setReplies(replies4);
 491
 492                 assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(),
 493                                 parser.parseMessage(result, Collections.<Message> emptyList()));
 494                 buf = Unpooled.buffer(result.length);
 495                 parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 496                 assertArrayEquals(result, buf.array());
 497         }
 498
 499         @Test
 500         public void testUpdMsg() throws IOException, PCEPDeserializerException {
 501                 try (CrabbeInitiatedActivator a = new CrabbeInitiatedActivator()) {
 502                         a.start(this.ctx);
 503                         byte[] result = ByteArray.fileToBytes("src/test/resources/PCUpd.2.bin");
 504
 505                         final Stateful07PCUpdateRequestMessageParser parser = new Stateful07PCUpdateRequestMessageParser(this.ctx.getObjectHandlerRegistry());
 506
 507                         final PcupdMessageBuilder builder = new PcupdMessageBuilder();
 508
 509                         final List<Updates> updates = Lists.newArrayList();
 510                         final PathBuilder pBuilder = new PathBuilder();
 511                         pBuilder.setEro(this.ero);
 512                         pBuilder.setLspa(this.lspa);
 513                         updates.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 514                         builder.setUpdates(updates);
 515
 516                         assertEquals(new PcupdBuilder().setPcupdMessage(builder.build()).build(),
 517                                         parser.parseMessage(result, Collections.<Message> emptyList()));
 518                         ByteBuf buf = Unpooled.buffer(result.length);
 519                         parser.serializeMessage(new PcupdBuilder().setPcupdMessage(builder.build()).build(), buf);
 520                         assertArrayEquals(result, buf.array());
 521
 522                         result = ByteArray.fileToBytes("src/test/resources/PCUpd.5.bin");
 523
 524                         final List<Updates> updates1 = Lists.newArrayList();
 525                         final PathBuilder pBuilder1 = new PathBuilder();
 526                         pBuilder1.setEro(this.ero);
 527                         pBuilder1.setLspa(this.lspa);
 528                         updates1.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 529                         updates1.add(new UpdatesBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder1.build()).build());
 530                         builder.setUpdates(updates1);
 531
 532                         assertEquals(new PcupdBuilder().setPcupdMessage(builder.build()).build(),
 533                                         parser.parseMessage(result, Collections.<Message> emptyList()));
 534                         buf = Unpooled.buffer(result.length);
 535                         parser.serializeMessage(new PcupdBuilder().setPcupdMessage(builder.build()).build(), buf);
 536                         assertArrayEquals(result, buf.array());
 537                 }
 538         }
 539
 540         @Test
 541         public void testRptMsg() throws IOException, PCEPDeserializerException {
 542                 try (CrabbeInitiatedActivator a = new CrabbeInitiatedActivator()) {
 543                         a.start(this.ctx);
 544                         byte[] result = ByteArray.fileToBytes("src/test/resources/PCRpt.1.bin");
 545
 546                         final Stateful07PCReportMessageParser parser = new Stateful07PCReportMessageParser(this.ctx.getObjectHandlerRegistry());
 547
 548                         final PcrptMessageBuilder builder = new PcrptMessageBuilder();
 549
 550                         final List<Reports> reports = Lists.newArrayList();
 551                         reports.add(new ReportsBuilder().setLsp(this.lsp).build());
 552                         builder.setReports(reports);
 553
 554                         assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(),
 555                                         parser.parseMessage(result, Collections.<Message> emptyList()));
 556                         ByteBuf buf = Unpooled.buffer(result.length);
 557                         parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 558                         assertArrayEquals(result, buf.array());
 559
 560                         result = ByteArray.fileToBytes("src/test/resources/PCRpt.2.bin");
 561
 562                         final List<Reports> reports1 = Lists.newArrayList();
 563                         reports1.add(new ReportsBuilder().setLsp(this.lsp).setPath(
 564                                         new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder().setEro(
 565                                                         this.ero).setLspa(this.lspa).build()).build());
 566                         builder.setReports(reports1);
 567
 568                         assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(),
 569                                         parser.parseMessage(result, Collections.<Message> emptyList()));
 570                         buf = Unpooled.buffer(result.length);
 571                         parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 572                         assertArrayEquals(result, buf.array());
 573
 574                         result = ByteArray.fileToBytes("src/test/resources/PCRpt.3.bin");
 575
 576                         final List<Reports> reports2 = Lists.newArrayList();
 577                         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder pBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder();
 578                         pBuilder.setEro(this.ero);
 579                         pBuilder.setLspa(this.lspa);
 580                         pBuilder.setMetrics(Lists.newArrayList(this.metrics, this.metrics));
 581                         pBuilder.setRro(this.rro);
 582                         reports2.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 583                         builder.setReports(reports2);
 584
 585                         assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(),
 586                                         parser.parseMessage(result, Collections.<Message> emptyList()));
 587                         buf = Unpooled.buffer(result.length);
 588                         parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 589                         assertArrayEquals(result, buf.array());
 590
 591                         result = ByteArray.fileToBytes("src/test/resources/PCRpt.5.bin");
 592
 593                         final List<Reports> reports3 = Lists.newArrayList();
 594                         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder pBuilder1 = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder();
 595                         pBuilder1.setEro(this.ero);
 596                         pBuilder1.setLspa(this.lspa);
 597                         pBuilder1.setMetrics(Lists.newArrayList(this.metrics, this.metrics));
 598                         pBuilder1.setRro(this.rro);
 599                         reports3.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder.build()).build());
 600                         reports3.add(new ReportsBuilder().setSrp(this.srp).setLsp(this.lsp).setPath(pBuilder1.build()).build());
 601                         builder.setReports(reports3);
 602
 603                         assertEquals(new PcrptBuilder().setPcrptMessage(builder.build()).build(),
 604                                         parser.parseMessage(result, Collections.<Message> emptyList()));
 605                         buf = Unpooled.buffer(result.length);
 606                         parser.serializeMessage(new PcrptBuilder().setPcrptMessage(builder.build()).build(), buf);
 607                         assertArrayEquals(result, buf.array());
 608                 }
 609         }
 610
 611         @Test
 612         public void testPcinitMsg() throws IOException, PCEPDeserializerException {
 613                 try (CrabbeInitiatedActivator a = new CrabbeInitiatedActivator()) {
 614                         a.start(this.ctx);
 615                         final byte[] result = ByteArray.fileToBytes("src/test/resources/Pcinit.bin");
 616
 617                         final CInitiated00PCInitiateMessageParser parser = new CInitiated00PCInitiateMessageParser(this.ctx.getObjectHandlerRegistry());
 618
 619                         final PcinitiateMessageBuilder builder = new PcinitiateMessageBuilder();
 620                         final RequestsBuilder rBuilder = new RequestsBuilder();
 621
 622                         final List<Requests> reqs = Lists.newArrayList();
 623                         rBuilder.setSrp(this.srp);
 624                         rBuilder.setLsp(this.lsp);
 625                         rBuilder.setEro(this.ero);
 626                         rBuilder.setLspa(this.lspa);
 627                         rBuilder.setMetrics(Lists.newArrayList(this.metrics));
 628                         rBuilder.setIro(this.iro);
 629                         reqs.add(rBuilder.build());
 630                         builder.setRequests(reqs);
 631
 632                         assertEquals(new PcinitiateBuilder().setPcinitiateMessage(builder.build()).build(),
 633                                         parser.parseMessage(result, Collections.<Message> emptyList()));
 634                         final ByteBuf buf = Unpooled.buffer(result.length);
 635                         parser.serializeMessage(new PcinitiateBuilder().setPcinitiateMessage(builder.build()).build(), buf);
 636                         assertArrayEquals(result, buf.array());
 637                 }
 638         }
 639
 640         @Test
 641         public void testNotificationMsg() throws IOException, PCEPDeserializerException {
 642                 final CNotification cn1 = new CNotificationBuilder().setIgnore(false).setProcessingRule(false).setType((short) 1).setValue(
 643                                 (short) 1).build();
 644
 645                 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();
 646                 innerNot.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 647                                 cn1).build());
 648                 final List<Rps> rps = Lists.newArrayList();
 649                 rps.add(new RpsBuilder().setRp(this.rpFalse).build());
 650
 651                 final byte[] result = ByteArray.fileToBytes("src/test/resources/PCNtf.5.bin");
 652
 653                 final PCEPNotificationMessageParser parser = new PCEPNotificationMessageParser(this.objectRegistry);
 654                 final PcntfMessageBuilder builder = new PcntfMessageBuilder();
 655
 656                 final List<Notifications> nots = Lists.newArrayList();
 657                 final NotificationsBuilder b = new NotificationsBuilder();
 658                 b.setNotifications(innerNot);
 659                 b.setRps(rps);
 660                 nots.add(b.build());
 661
 662                 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();
 663                 innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 664                                 cn1).build());
 665                 innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 666                                 cn1).build());
 667                 final List<Rps> rps1 = Lists.newArrayList();
 668                 rps1.add(new RpsBuilder().setRp(this.rpFalse).build());
 669                 rps1.add(new RpsBuilder().setRp(this.rpFalse).build());
 670
 671                 b.setNotifications(innerNot1);
 672                 b.setRps(rps1);
 673                 nots.add(b.build());
 674                 builder.setNotifications(nots);
 675
 676                 assertEquals(new PcntfBuilder().setPcntfMessage(builder.build()).build(),
 677                                 parser.parseMessage(result, Collections.<Message> emptyList()));
 678                 final ByteBuf buf = Unpooled.buffer(result.length);
 679                 parser.serializeMessage(new PcntfBuilder().setPcntfMessage(builder.build()).build(), buf);
 680                 assertArrayEquals(result, buf.array());
 681         }
 682
 683         @Test
 684         public void testErrorMsg() throws IOException, PCEPDeserializerException {
 685                 try (StatefulActivator a = new StatefulActivator()) {
 686                         a.start(this.ctx);
 687                         byte[] result = ByteArray.fileToBytes("src/test/resources/PCErr.3.bin");
 688
 689                         final ErrorObject error1 = new ErrorObjectBuilder().setIgnore(false).setProcessingRule(false).setType((short) 3).setValue(
 690                                         (short) 1).build();
 691
 692                         final PCEPErrorMessageParser parser = new PCEPErrorMessageParser(this.ctx.getObjectHandlerRegistry());
 693
 694                         List<Errors> innerErr = Lists.newArrayList();
 695                         innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
 696
 697                         final PcerrMessageBuilder builder = new PcerrMessageBuilder();
 698                         builder.setErrors(innerErr);
 699                         builder.setErrorType(new SessionCaseBuilder().setSession(new SessionBuilder().setOpen(this.open).build()).build());
 700
 701                         assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(),
 702                                         parser.parseMessage(result, Collections.<Message> emptyList()));
 703                         ByteBuf buf = Unpooled.buffer(result.length);
 704                         parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
 705                         assertArrayEquals(result, buf.array());
 706
 707                         result = ByteArray.fileToBytes("src/test/resources/PCErr.5.bin");
 708
 709                         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();
 710                         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(
 711                                         this.rpFalse).build());
 712
 713                         innerErr = Lists.newArrayList();
 714                         innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
 715
 716                         builder.setErrors(innerErr);
 717                         builder.setErrorType(new RequestCaseBuilder().setRequest(new RequestBuilder().setRps(rps).build()).build());
 718
 719                         assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(),
 720                                         parser.parseMessage(result, Collections.<Message> emptyList()));
 721                         buf = Unpooled.buffer(result.length);
 722                         parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
 723                         assertArrayEquals(result, buf.array());
 724                 }
 725         }
 726 }