bgp/parser-impl/src/main/java/org/opendaylight/protocol/bgp/parser/impl/BGPActivator.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.bgp.parser.impl;
   9
  10 import java.util.ArrayList;
  11 import java.util.List;
  12 import javax.inject.Inject;
  13 import javax.inject.Singleton;
  14 import org.kohsuke.MetaInfServices;
  15 import org.opendaylight.protocol.bgp.parser.impl.message.BGPKeepAliveMessageParser;
  16 import org.opendaylight.protocol.bgp.parser.impl.message.BGPNotificationMessageParser;
  17 import org.opendaylight.protocol.bgp.parser.impl.message.BGPOpenMessageParser;
  18 import org.opendaylight.protocol.bgp.parser.impl.message.BGPRouteRefreshMessageParser;
  19 import org.opendaylight.protocol.bgp.parser.impl.message.BGPUpdateMessageParser;
  20 import org.opendaylight.protocol.bgp.parser.impl.message.open.AddPathCapabilityHandler;
  21 import org.opendaylight.protocol.bgp.parser.impl.message.open.As4CapabilityHandler;
  22 import org.opendaylight.protocol.bgp.parser.impl.message.open.BgpExtendedMessageCapabilityHandler;
  23 import org.opendaylight.protocol.bgp.parser.impl.message.open.CapabilityParameterParser;
  24 import org.opendaylight.protocol.bgp.parser.impl.message.open.GracefulCapabilityHandler;
  25 import org.opendaylight.protocol.bgp.parser.impl.message.open.LlGracefulCapabilityHandler;
  26 import org.opendaylight.protocol.bgp.parser.impl.message.open.MultiProtocolCapabilityHandler;
  27 import org.opendaylight.protocol.bgp.parser.impl.message.open.RouteRefreshCapabilityHandler;
  28 import org.opendaylight.protocol.bgp.parser.impl.message.update.AS4AggregatorAttributeParser;
  29 import org.opendaylight.protocol.bgp.parser.impl.message.update.AS4PathAttributeParser;
  30 import org.opendaylight.protocol.bgp.parser.impl.message.update.AggregatorAttributeParser;
  31 import org.opendaylight.protocol.bgp.parser.impl.message.update.AigpAttributeParser;
  32 import org.opendaylight.protocol.bgp.parser.impl.message.update.AsPathAttributeParser;
  33 import org.opendaylight.protocol.bgp.parser.impl.message.update.AtomicAggregateAttributeParser;
  34 import org.opendaylight.protocol.bgp.parser.impl.message.update.BgpPrefixSidAttributeParser;
  35 import org.opendaylight.protocol.bgp.parser.impl.message.update.ClusterIdAttributeParser;
  36 import org.opendaylight.protocol.bgp.parser.impl.message.update.CommunitiesAttributeParser;
  37 import org.opendaylight.protocol.bgp.parser.impl.message.update.ExtendedCommunitiesAttributeParser;
  38 import org.opendaylight.protocol.bgp.parser.impl.message.update.LocalPreferenceAttributeParser;
  39 import org.opendaylight.protocol.bgp.parser.impl.message.update.MPReachAttributeParser;
  40 import org.opendaylight.protocol.bgp.parser.impl.message.update.MPUnreachAttributeParser;
  41 import org.opendaylight.protocol.bgp.parser.impl.message.update.MultiExitDiscriminatorAttributeParser;
  42 import org.opendaylight.protocol.bgp.parser.impl.message.update.NextHopAttributeParser;
  43 import org.opendaylight.protocol.bgp.parser.impl.message.update.OriginAttributeParser;
  44 import org.opendaylight.protocol.bgp.parser.impl.message.update.OriginatorIdAttributeParser;
  45 import org.opendaylight.protocol.bgp.parser.impl.message.update.UnrecognizedAttributesSerializer;
  46 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.AsTwoOctetSpecificEcHandler;
  47 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.EncapsulationEC;
  48 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.Ipv4SpecificEcHandler;
  49 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.LinkBandwidthEC;
  50 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.OpaqueEcHandler;
  51 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.RouteOriginAsTwoOctetEcHandler;
  52 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.RouteOriginIpv4EcHandler;
  53 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.SourceASHandler;
  54 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.VrfRouteImportHandler;
  55 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.four.octect.as.specific.Generic4OctASEcHandler;
  56 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.four.octect.as.specific.RouteOrigin4OctectASEcHandler;
  57 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.four.octect.as.specific.SourceAS4OctectHandler;
  58 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.route.target.RouteTarget4OctectASEcHandler;
  59 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.route.target.RouteTargetAsTwoOctetEcHandler;
  60 import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.route.target.RouteTargetIpv4EcHandler;
  61 import org.opendaylight.protocol.bgp.parser.spi.AbstractBGPExtensionProviderActivator;
  62 import org.opendaylight.protocol.bgp.parser.spi.AddressFamilyRegistry;
  63 import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionProviderActivator;
  64 import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionProviderContext;
  65 import org.opendaylight.protocol.bgp.parser.spi.NlriRegistry;
  66 import org.opendaylight.protocol.bgp.parser.spi.SubsequentAddressFamilyRegistry;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.Keepalive;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.Notify;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.Open;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.Update;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.BgpParameters;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.c.parameters.As4BytesCapability;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.c.parameters.BgpExtendedMessageCapability;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.Aggregator;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.Aigp;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.AsPath;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.AtomicAggregate;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.BgpPrefixSid;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.ClusterId;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.Communities;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.ExtendedCommunities;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.LocalPref;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.MultiExitDisc;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.Origin;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.OriginatorId;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.UnrecognizedAttributes;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.RouteRefresh;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.AddPathCapability;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.GracefulRestartCapability;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.LlGracefulRestartCapability;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.MultiprotocolCapability;
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.RouteRefreshCapability;
  93 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.update.attributes.MpReachNlri;
  94 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.update.attributes.MpUnreachNlri;
  95 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.Ipv4AddressFamily;
  96 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.Ipv6AddressFamily;
  97 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.MplsLabeledVpnSubsequentAddressFamily;
  98 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.NextHop;
  99 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.UnicastSubsequentAddressFamily;
 100 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.As4GenericSpecExtendedCommunityCase;
 101 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.As4RouteOriginExtendedCommunityCase;
 102 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.As4RouteTargetExtendedCommunityCase;
 103 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.AsSpecificExtendedCommunityCase;
 104 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.EncapsulationCase;
 105 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.Inet4SpecificExtendedCommunityCase;
 106 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.LinkBandwidthCase;
 107 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.OpaqueExtendedCommunityCase;
 108 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.RouteOriginExtendedCommunityCase;
 109 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.RouteOriginIpv4Case;
 110 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.RouteTargetExtendedCommunityCase;
 111 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.RouteTargetIpv4Case;
 112 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.SourceAs4ExtendedCommunityCase;
 113 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.SourceAsExtendedCommunityCase;
 114 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.VrfRouteImportExtendedCommunityCase;
 115 import org.opendaylight.yangtools.concepts.Registration;
 116 import org.osgi.service.component.annotations.Component;
 117
 118 @Singleton
 119 @Component(immediate = true, service = BGPExtensionProviderActivator.class,
 120            property = "type=org.opendaylight.protocol.bgp.parser.impl.BGPActivator")
 121 @MetaInfServices(value = BGPExtensionProviderActivator.class)
 122 public final class BGPActivator extends AbstractBGPExtensionProviderActivator {
 123     private static final int IPV4_AFI = 1;
 124     private static final int IPV6_AFI = 2;
 125
 126     private static final int UNICAST_SAFI = 1;
 127     private static final int VPN_SAFI = 128;
 128
 129     @Inject
 130     public BGPActivator() {
 131         // Exposed for DI
 132     }
 133
 134     @Override
 135     protected List<Registration> startImpl(final BGPExtensionProviderContext context) {
 136         final List<Registration> regs = new ArrayList<>();
 137
 138         regs.add(context.registerAddressFamily(Ipv4AddressFamily.class, IPV4_AFI));
 139         regs.add(context.registerAddressFamily(Ipv6AddressFamily.class, IPV6_AFI));
 140
 141         regs.add(context.registerSubsequentAddressFamily(UnicastSubsequentAddressFamily.class, UNICAST_SAFI));
 142         regs.add(context.registerSubsequentAddressFamily(MplsLabeledVpnSubsequentAddressFamily.class, VPN_SAFI));
 143
 144         registerExtendedCommunities(regs, context);
 145         registerCapabilityParsers(regs, context);
 146         registerAttributeParsers(regs, context);
 147         registerMessageParsers(regs, context);
 148         return regs;
 149     }
 150
 151     private static void registerCapabilityParsers(final List<Registration> regs,
 152             final BGPExtensionProviderContext context) {
 153         final AddressFamilyRegistry afiReg = context.getAddressFamilyRegistry();
 154         final SubsequentAddressFamilyRegistry safiReg = context.getSubsequentAddressFamilyRegistry();
 155
 156         final MultiProtocolCapabilityHandler multi = new MultiProtocolCapabilityHandler(afiReg, safiReg);
 157         regs.add(context.registerCapabilityParser(MultiProtocolCapabilityHandler.CODE, multi));
 158         regs.add(context.registerCapabilitySerializer(MultiprotocolCapability.class, multi));
 159
 160         final AddPathCapabilityHandler addPath = new AddPathCapabilityHandler(afiReg, safiReg);
 161         regs.add(context.registerCapabilityParser(AddPathCapabilityHandler.CODE, addPath));
 162         regs.add(context.registerCapabilitySerializer(AddPathCapability.class, addPath));
 163
 164         final RouteRefreshCapabilityHandler routeRefresh = new RouteRefreshCapabilityHandler();
 165         regs.add(context.registerCapabilityParser(RouteRefreshCapabilityHandler.CODE, routeRefresh));
 166         regs.add(context.registerCapabilitySerializer(RouteRefreshCapability.class, routeRefresh));
 167
 168         final As4CapabilityHandler as4 = new As4CapabilityHandler();
 169         regs.add(context.registerCapabilityParser(As4CapabilityHandler.CODE, as4));
 170         regs.add(context.registerCapabilitySerializer(As4BytesCapability.class, as4));
 171
 172         final GracefulCapabilityHandler grace = new GracefulCapabilityHandler(afiReg, safiReg);
 173         regs.add(context.registerCapabilitySerializer(GracefulRestartCapability.class, grace));
 174         regs.add(context.registerCapabilityParser(GracefulCapabilityHandler.CODE, grace));
 175
 176         final LlGracefulCapabilityHandler llgrace = new LlGracefulCapabilityHandler(afiReg, safiReg);
 177         regs.add(context.registerCapabilitySerializer(LlGracefulRestartCapability.class, llgrace));
 178         regs.add(context.registerCapabilityParser(LlGracefulCapabilityHandler.CODE, llgrace));
 179
 180         final CapabilityParameterParser cpp = new CapabilityParameterParser(context.getCapabilityRegistry());
 181         regs.add(context.registerParameterParser(CapabilityParameterParser.TYPE, cpp));
 182         regs.add(context.registerParameterSerializer(BgpParameters.class, cpp));
 183
 184         final BgpExtendedMessageCapabilityHandler bgpextmessage = new BgpExtendedMessageCapabilityHandler();
 185         regs.add(context.registerCapabilityParser(BgpExtendedMessageCapabilityHandler.CODE, bgpextmessage));
 186         regs.add(context.registerCapabilitySerializer(BgpExtendedMessageCapability.class, bgpextmessage));
 187     }
 188
 189     private static void registerAttributeParsers(final List<Registration> regs,
 190             final BGPExtensionProviderContext context) {
 191         final BgpPrefixSidAttributeParser prefixSidAttributeParser
 192                 = new BgpPrefixSidAttributeParser(context.getBgpPrefixSidTlvRegistry());
 193         regs.add(context.registerAttributeSerializer(BgpPrefixSid.class, prefixSidAttributeParser));
 194         regs.add(context.registerAttributeParser(BgpPrefixSidAttributeParser.TYPE, prefixSidAttributeParser));
 195
 196         final OriginAttributeParser originAttributeParser = new OriginAttributeParser();
 197         regs.add(context.registerAttributeSerializer(Origin.class, originAttributeParser));
 198         regs.add(context.registerAttributeParser(OriginAttributeParser.TYPE, originAttributeParser));
 199
 200         final AigpAttributeParser aigpAttributeParser = new AigpAttributeParser();
 201         regs.add(context.registerAttributeSerializer(Aigp.class, aigpAttributeParser));
 202         regs.add(context.registerAttributeParser(AigpAttributeParser.TYPE, aigpAttributeParser));
 203
 204         final AsPathAttributeParser asPathAttributeParser = new AsPathAttributeParser(context.getReferenceCache());
 205         regs.add(context.registerAttributeSerializer(AsPath.class, asPathAttributeParser));
 206         regs.add(context.registerAttributeParser(AsPathAttributeParser.TYPE, asPathAttributeParser));
 207
 208         final NextHopAttributeParser nextHopAttributeParser = new NextHopAttributeParser();
 209         regs.add(context.registerAttributeSerializer(NextHop.class, nextHopAttributeParser));
 210         regs.add(context.registerAttributeParser(NextHopAttributeParser.TYPE, nextHopAttributeParser));
 211
 212         final MultiExitDiscriminatorAttributeParser multiExitDiscriminatorAttributeParser
 213                 = new MultiExitDiscriminatorAttributeParser();
 214         regs.add(context.registerAttributeSerializer(MultiExitDisc.class, multiExitDiscriminatorAttributeParser));
 215         regs.add(context.registerAttributeParser(MultiExitDiscriminatorAttributeParser.TYPE,
 216                 multiExitDiscriminatorAttributeParser));
 217
 218         final LocalPreferenceAttributeParser localPreferenceAttributeParser = new LocalPreferenceAttributeParser();
 219         regs.add(context.registerAttributeSerializer(LocalPref.class, localPreferenceAttributeParser));
 220         regs.add(context.registerAttributeParser(LocalPreferenceAttributeParser.TYPE, localPreferenceAttributeParser));
 221
 222         final AtomicAggregateAttributeParser atomicAggregateAttributeParser = new AtomicAggregateAttributeParser();
 223         regs.add(context.registerAttributeSerializer(AtomicAggregate.class, atomicAggregateAttributeParser));
 224         regs.add(context.registerAttributeParser(AtomicAggregateAttributeParser.TYPE, atomicAggregateAttributeParser));
 225
 226         final AggregatorAttributeParser as4AggregatorAttributeParser
 227                 = new AggregatorAttributeParser(context.getReferenceCache());
 228         regs.add(context.registerAttributeSerializer(Aggregator.class, as4AggregatorAttributeParser));
 229         regs.add(context.registerAttributeParser(AggregatorAttributeParser.TYPE, as4AggregatorAttributeParser));
 230
 231         final CommunitiesAttributeParser communitiesAttributeParser
 232                 = new CommunitiesAttributeParser(context.getReferenceCache());
 233         regs.add(context.registerAttributeSerializer(Communities.class, communitiesAttributeParser));
 234         regs.add(context.registerAttributeParser(CommunitiesAttributeParser.TYPE, communitiesAttributeParser));
 235
 236         final OriginatorIdAttributeParser originatorIdAttributeParser = new OriginatorIdAttributeParser();
 237         regs.add(context.registerAttributeSerializer(OriginatorId.class, originatorIdAttributeParser));
 238         regs.add(context.registerAttributeParser(OriginatorIdAttributeParser.TYPE, originatorIdAttributeParser));
 239
 240         final ClusterIdAttributeParser clusterIdAttributeParser = new ClusterIdAttributeParser();
 241         regs.add(context.registerAttributeSerializer(ClusterId.class, clusterIdAttributeParser));
 242         regs.add(context.registerAttributeParser(ClusterIdAttributeParser.TYPE, clusterIdAttributeParser));
 243
 244         final NlriRegistry nlriReg = context.getNlriRegistry();
 245
 246         final MPReachAttributeParser mpReachAttributeParser = new MPReachAttributeParser(nlriReg);
 247         regs.add(context.registerAttributeSerializer(MpReachNlri.class, mpReachAttributeParser));
 248         regs.add(context.registerAttributeParser(MPReachAttributeParser.TYPE, mpReachAttributeParser));
 249
 250         final MPUnreachAttributeParser mpUnreachAttributeParser = new MPUnreachAttributeParser(nlriReg);
 251         regs.add(context.registerAttributeSerializer(MpUnreachNlri.class, mpUnreachAttributeParser));
 252         regs.add(context.registerAttributeParser(MPUnreachAttributeParser.TYPE, mpUnreachAttributeParser));
 253
 254         final ExtendedCommunitiesAttributeParser extendedCommunitiesAttributeParser
 255                 = new ExtendedCommunitiesAttributeParser(context.getExtendedCommunityRegistry());
 256         regs.add(context.registerAttributeSerializer(ExtendedCommunities.class, extendedCommunitiesAttributeParser));
 257         regs.add(context.registerAttributeParser(ExtendedCommunitiesAttributeParser.TYPE,
 258                 extendedCommunitiesAttributeParser));
 259
 260         regs.add(context.registerAttributeParser(AS4AggregatorAttributeParser.TYPE,
 261                 new AS4AggregatorAttributeParser()));
 262         regs.add(context.registerAttributeParser(AS4PathAttributeParser.TYPE, new AS4PathAttributeParser()));
 263
 264         regs.add(context.registerAttributeSerializer(UnrecognizedAttributes.class,
 265                 new UnrecognizedAttributesSerializer()));
 266     }
 267
 268     private static void registerMessageParsers(final List<Registration> regs,
 269             final BGPExtensionProviderContext context) {
 270         final BGPOpenMessageParser omp = new BGPOpenMessageParser(context.getParameterRegistry());
 271         regs.add(context.registerMessageParser(BGPOpenMessageParser.TYPE, omp));
 272         regs.add(context.registerMessageSerializer(Open.class, omp));
 273
 274         final BGPUpdateMessageParser ump = new BGPUpdateMessageParser(context.getAttributeRegistry(),
 275             context.getNlriRegistry());
 276         regs.add(context.registerMessageParser(BGPUpdateMessageParser.TYPE, ump));
 277         regs.add(context.registerMessageSerializer(Update.class, ump));
 278
 279         final BGPNotificationMessageParser nmp = new BGPNotificationMessageParser();
 280         regs.add(context.registerMessageParser(BGPNotificationMessageParser.TYPE, nmp));
 281         regs.add(context.registerMessageSerializer(Notify.class, nmp));
 282
 283         final BGPKeepAliveMessageParser kamp = new BGPKeepAliveMessageParser();
 284         regs.add(context.registerMessageParser(BGPKeepAliveMessageParser.TYPE, kamp));
 285         regs.add(context.registerMessageSerializer(Keepalive.class, kamp));
 286
 287         final AddressFamilyRegistry afiReg = context.getAddressFamilyRegistry();
 288         final SubsequentAddressFamilyRegistry safiReg = context.getSubsequentAddressFamilyRegistry();
 289         final BGPRouteRefreshMessageParser rrmp = new BGPRouteRefreshMessageParser(afiReg, safiReg);
 290         regs.add(context.registerMessageParser(BGPRouteRefreshMessageParser.TYPE, rrmp));
 291         regs.add(context.registerMessageSerializer(RouteRefresh.class, rrmp));
 292     }
 293
 294     private static void registerExtendedCommunities(final List<Registration> regs,
 295             final BGPExtensionProviderContext context) {
 296         final AsTwoOctetSpecificEcHandler twoOctetSpecificEcHandler = new AsTwoOctetSpecificEcHandler();
 297         regs.add(context.registerExtendedCommunityParser(twoOctetSpecificEcHandler.getType(true),
 298                 twoOctetSpecificEcHandler.getSubType(), twoOctetSpecificEcHandler));
 299         regs.add(context.registerExtendedCommunityParser(twoOctetSpecificEcHandler.getType(false),
 300                 twoOctetSpecificEcHandler.getSubType(), twoOctetSpecificEcHandler));
 301         regs.add(context.registerExtendedCommunitySerializer(AsSpecificExtendedCommunityCase.class,
 302                 twoOctetSpecificEcHandler));
 303
 304         final Ipv4SpecificEcHandler ipv4SpecificEcHandler = new Ipv4SpecificEcHandler();
 305         regs.add(context.registerExtendedCommunityParser(ipv4SpecificEcHandler.getType(true),
 306                 ipv4SpecificEcHandler.getSubType(), ipv4SpecificEcHandler));
 307         regs.add(context.registerExtendedCommunityParser(ipv4SpecificEcHandler.getType(false),
 308                 ipv4SpecificEcHandler.getSubType(), ipv4SpecificEcHandler));
 309         regs.add(context.registerExtendedCommunitySerializer(Inet4SpecificExtendedCommunityCase.class,
 310                 ipv4SpecificEcHandler));
 311
 312         final OpaqueEcHandler opaqueEcHandler = new OpaqueEcHandler();
 313         regs.add(context.registerExtendedCommunityParser(opaqueEcHandler.getType(true),
 314                 opaqueEcHandler.getSubType(), opaqueEcHandler));
 315         regs.add(context.registerExtendedCommunityParser(opaqueEcHandler.getType(false),
 316                 opaqueEcHandler.getSubType(), opaqueEcHandler));
 317         regs.add(context.registerExtendedCommunitySerializer(OpaqueExtendedCommunityCase.class, opaqueEcHandler));
 318
 319         final RouteOriginAsTwoOctetEcHandler routeOriginAS2bEcHandler = new RouteOriginAsTwoOctetEcHandler();
 320         regs.add(context.registerExtendedCommunityParser(routeOriginAS2bEcHandler.getType(true),
 321                 routeOriginAS2bEcHandler.getSubType(), routeOriginAS2bEcHandler));
 322         regs.add(context.registerExtendedCommunityParser(routeOriginAS2bEcHandler.getType(false),
 323                 routeOriginAS2bEcHandler.getSubType(), routeOriginAS2bEcHandler));
 324         regs.add(context.registerExtendedCommunitySerializer(RouteOriginExtendedCommunityCase.class,
 325                 routeOriginAS2bEcHandler));
 326
 327         final RouteTargetAsTwoOctetEcHandler routeTargetAS2bEcHandler = new RouteTargetAsTwoOctetEcHandler();
 328         regs.add(context.registerExtendedCommunityParser(routeTargetAS2bEcHandler.getType(true),
 329                 routeTargetAS2bEcHandler.getSubType(), routeTargetAS2bEcHandler));
 330         regs.add(context.registerExtendedCommunityParser(routeTargetAS2bEcHandler.getType(false),
 331                 routeTargetAS2bEcHandler.getSubType(), routeTargetAS2bEcHandler));
 332         regs.add(context.registerExtendedCommunitySerializer(RouteTargetExtendedCommunityCase.class,
 333                 routeTargetAS2bEcHandler));
 334
 335         final RouteOriginIpv4EcHandler routeOriginIpv4EcHandler = new RouteOriginIpv4EcHandler();
 336         regs.add(context.registerExtendedCommunityParser(routeOriginIpv4EcHandler.getType(true),
 337                 routeOriginIpv4EcHandler.getSubType(), routeOriginIpv4EcHandler));
 338         regs.add(context.registerExtendedCommunityParser(routeOriginIpv4EcHandler.getType(false),
 339                 routeOriginIpv4EcHandler.getSubType(), routeOriginIpv4EcHandler));
 340         regs.add(context.registerExtendedCommunitySerializer(RouteOriginIpv4Case.class, routeOriginIpv4EcHandler));
 341
 342         final RouteTargetIpv4EcHandler routeTargetIpv4EcHandler = new RouteTargetIpv4EcHandler();
 343         regs.add(context.registerExtendedCommunityParser(routeTargetIpv4EcHandler.getType(true),
 344                 routeTargetIpv4EcHandler.getSubType(), routeTargetIpv4EcHandler));
 345         regs.add(context.registerExtendedCommunityParser(routeTargetIpv4EcHandler.getType(false),
 346                 routeTargetIpv4EcHandler.getSubType(), routeTargetIpv4EcHandler));
 347         regs.add(context.registerExtendedCommunitySerializer(RouteTargetIpv4Case.class, routeTargetIpv4EcHandler));
 348
 349         final LinkBandwidthEC linkBandwidthECHandler = new LinkBandwidthEC();
 350         regs.add(context.registerExtendedCommunityParser(linkBandwidthECHandler.getType(false),
 351                 linkBandwidthECHandler.getSubType(), linkBandwidthECHandler));
 352         regs.add(context.registerExtendedCommunitySerializer(LinkBandwidthCase.class, linkBandwidthECHandler));
 353
 354         final Generic4OctASEcHandler gen4OctASEcHandler = new Generic4OctASEcHandler();
 355         regs.add(context.registerExtendedCommunityParser(gen4OctASEcHandler.getType(true),
 356                 gen4OctASEcHandler.getSubType(), gen4OctASEcHandler));
 357         regs.add(context.registerExtendedCommunityParser(gen4OctASEcHandler.getType(false),
 358                 gen4OctASEcHandler.getSubType(), gen4OctASEcHandler));
 359         regs.add(context.registerExtendedCommunitySerializer(As4GenericSpecExtendedCommunityCase.class,
 360                 gen4OctASEcHandler));
 361
 362         final RouteTarget4OctectASEcHandler rt4ASHandler = new RouteTarget4OctectASEcHandler();
 363         regs.add(context.registerExtendedCommunityParser(rt4ASHandler.getType(true),
 364                 rt4ASHandler.getSubType(), rt4ASHandler));
 365         regs.add(context.registerExtendedCommunitySerializer(As4RouteTargetExtendedCommunityCase.class, rt4ASHandler));
 366
 367         final RouteOrigin4OctectASEcHandler rOrig4Oct = new RouteOrigin4OctectASEcHandler();
 368         regs.add(context.registerExtendedCommunityParser(rOrig4Oct.getType(true), rOrig4Oct.getSubType(), rOrig4Oct));
 369         regs.add(context.registerExtendedCommunitySerializer(As4RouteOriginExtendedCommunityCase.class, rOrig4Oct));
 370
 371         final EncapsulationEC encapsulationECHandler = new EncapsulationEC();
 372         regs.add(context.registerExtendedCommunityParser(encapsulationECHandler.getType(true),
 373                 encapsulationECHandler.getSubType(), encapsulationECHandler));
 374         regs.add(context.registerExtendedCommunitySerializer(EncapsulationCase.class, encapsulationECHandler));
 375
 376         final VrfRouteImportHandler vrfRouteImportHandler = new VrfRouteImportHandler();
 377         regs.add(context.registerExtendedCommunityParser(vrfRouteImportHandler.getType(true),
 378                 vrfRouteImportHandler.getSubType(), vrfRouteImportHandler));
 379         regs.add(context.registerExtendedCommunitySerializer(VrfRouteImportExtendedCommunityCase.class,
 380                 vrfRouteImportHandler));
 381
 382         final SourceAS4OctectHandler source4ASHandler = new SourceAS4OctectHandler();
 383         regs.add(context.registerExtendedCommunityParser(source4ASHandler.getType(true),
 384                 source4ASHandler.getSubType(), source4ASHandler));
 385         regs.add(context.registerExtendedCommunitySerializer(SourceAs4ExtendedCommunityCase.class, source4ASHandler));
 386
 387         final SourceASHandler sourceASHandler = new SourceASHandler();
 388         regs.add(context.registerExtendedCommunityParser(sourceASHandler.getType(true),
 389                 sourceASHandler.getSubType(), sourceASHandler));
 390         regs.add(context.registerExtendedCommunitySerializer(SourceAsExtendedCommunityCase.class, sourceASHandler));
 391     }
 392 }