X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=bgp%2Fparser-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fprotocol%2Fbgp%2Fparser%2Fimpl%2FBGPActivator.java;h=3bf4fedc0adda2c8c2472e04c4e102d2879b9f80;hb=8896ea0a68188dba41c89d23be96ccc15e60c546;hp=71c0a34ec0801359e4db2c9a14bf9cb38d1b457b;hpb=6a466fc2323c46828ad8e26b70af7ee815163a78;p=bgpcep.git diff --git a/bgp/parser-impl/src/main/java/org/opendaylight/protocol/bgp/parser/impl/BGPActivator.java b/bgp/parser-impl/src/main/java/org/opendaylight/protocol/bgp/parser/impl/BGPActivator.java index 71c0a34ec0..3bf4fedc0a 100644 --- a/bgp/parser-impl/src/main/java/org/opendaylight/protocol/bgp/parser/impl/BGPActivator.java +++ b/bgp/parser-impl/src/main/java/org/opendaylight/protocol/bgp/parser/impl/BGPActivator.java @@ -9,29 +9,32 @@ package org.opendaylight.protocol.bgp.parser.impl; import java.util.ArrayList; import java.util.List; +import javax.inject.Inject; +import javax.inject.Singleton; +import org.kohsuke.MetaInfServices; import org.opendaylight.protocol.bgp.parser.impl.message.BGPKeepAliveMessageParser; import org.opendaylight.protocol.bgp.parser.impl.message.BGPNotificationMessageParser; import org.opendaylight.protocol.bgp.parser.impl.message.BGPOpenMessageParser; +import org.opendaylight.protocol.bgp.parser.impl.message.BGPRouteRefreshMessageParser; import org.opendaylight.protocol.bgp.parser.impl.message.BGPUpdateMessageParser; import org.opendaylight.protocol.bgp.parser.impl.message.open.AddPathCapabilityHandler; import org.opendaylight.protocol.bgp.parser.impl.message.open.As4CapabilityHandler; import org.opendaylight.protocol.bgp.parser.impl.message.open.BgpExtendedMessageCapabilityHandler; import org.opendaylight.protocol.bgp.parser.impl.message.open.CapabilityParameterParser; import org.opendaylight.protocol.bgp.parser.impl.message.open.GracefulCapabilityHandler; +import org.opendaylight.protocol.bgp.parser.impl.message.open.LlGracefulCapabilityHandler; import org.opendaylight.protocol.bgp.parser.impl.message.open.MultiProtocolCapabilityHandler; import org.opendaylight.protocol.bgp.parser.impl.message.open.RouteRefreshCapabilityHandler; import org.opendaylight.protocol.bgp.parser.impl.message.update.AS4AggregatorAttributeParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.AS4PathAttributeParser; -import org.opendaylight.protocol.bgp.parser.impl.message.update.AdvertizedRoutesSerializer; import org.opendaylight.protocol.bgp.parser.impl.message.update.AggregatorAttributeParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.AigpAttributeParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.AsPathAttributeParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.AtomicAggregateAttributeParser; +import org.opendaylight.protocol.bgp.parser.impl.message.update.BgpPrefixSidAttributeParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.ClusterIdAttributeParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.CommunitiesAttributeParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.ExtendedCommunitiesAttributeParser; -import org.opendaylight.protocol.bgp.parser.impl.message.update.Ipv4NlriParser; -import org.opendaylight.protocol.bgp.parser.impl.message.update.Ipv6NlriParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.LocalPreferenceAttributeParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.MPReachAttributeParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.MPUnreachAttributeParser; @@ -39,99 +42,112 @@ import org.opendaylight.protocol.bgp.parser.impl.message.update.MultiExitDiscrim import org.opendaylight.protocol.bgp.parser.impl.message.update.NextHopAttributeParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.OriginAttributeParser; import org.opendaylight.protocol.bgp.parser.impl.message.update.OriginatorIdAttributeParser; -import org.opendaylight.protocol.bgp.parser.impl.message.update.WithdrawnRoutesSerializer; +import org.opendaylight.protocol.bgp.parser.impl.message.update.UnrecognizedAttributesSerializer; import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.AsTwoOctetSpecificEcHandler; +import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.EncapsulationEC; import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.Ipv4SpecificEcHandler; +import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.LinkBandwidthEC; import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.OpaqueEcHandler; import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.RouteOriginAsTwoOctetEcHandler; import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.RouteOriginIpv4EcHandler; -import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.RouteTargetAsTwoOctetEcHandler; -import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.RouteTargetIpv4EcHandler; -import org.opendaylight.protocol.bgp.parser.impl.message.update.next.hop.Ipv4NextHopParserSerializer; -import org.opendaylight.protocol.bgp.parser.impl.message.update.next.hop.Ipv6NextHopParserSerializer; -import org.opendaylight.protocol.bgp.parser.spi.AbstractBGPExtensionProviderActivator; +import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.SourceASHandler; +import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.VrfRouteImportHandler; +import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.four.octect.as.specific.Generic4OctASEcHandler; +import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.four.octect.as.specific.RouteOrigin4OctectASEcHandler; +import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.four.octect.as.specific.SourceAS4OctectHandler; +import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.route.target.RouteTarget4OctectASEcHandler; +import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.route.target.RouteTargetAsTwoOctetEcHandler; +import org.opendaylight.protocol.bgp.parser.impl.message.update.extended.communities.route.target.RouteTargetIpv4EcHandler; import org.opendaylight.protocol.bgp.parser.spi.AddressFamilyRegistry; +import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionProviderActivator; import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionProviderContext; import org.opendaylight.protocol.bgp.parser.spi.NlriRegistry; import org.opendaylight.protocol.bgp.parser.spi.SubsequentAddressFamilyRegistry; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.Keepalive; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.Notify; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.Open; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.Update; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.message.BgpParameters; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.message.bgp.parameters.optional.capabilities.c.parameters.As4BytesCapability; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.message.bgp.parameters.optional.capabilities.c.parameters.BgpExtendedMessageCapability; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.Aggregator; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.Aigp; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.AsPath; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.AtomicAggregate; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.ClusterId; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.Communities; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.ExtendedCommunities; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.LocalPref; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.MultiExitDisc; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.Origin; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.attributes.OriginatorId; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.update.message.WithdrawnRoutes; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.open.bgp.parameters.optional.capabilities.c.parameters.AddPathCapability; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.open.bgp.parameters.optional.capabilities.c.parameters.GracefulRestartCapability; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.open.bgp.parameters.optional.capabilities.c.parameters.MultiprotocolCapability; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.open.bgp.parameters.optional.capabilities.c.parameters.RouteRefreshCapability; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.MpReachNlri; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.MpUnreachNlri; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.update.attributes.mp.reach.nlri.AdvertizedRoutes; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.Ipv4AddressFamily; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.Ipv6AddressFamily; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.MplsLabeledVpnSubsequentAddressFamily; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.NextHop; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.UnicastSubsequentAddressFamily; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.AsSpecificExtendedCommunityCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.Inet4SpecificExtendedCommunityCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.OpaqueExtendedCommunityCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.RouteOriginExtendedCommunityCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.RouteOriginIpv4Case; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.RouteTargetExtendedCommunityCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.RouteTargetIpv4Case; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.next.hop.c.next.hop.Ipv4NextHopCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.next.hop.c.next.hop.Ipv6NextHopCase; - -public final class BGPActivator extends AbstractBGPExtensionProviderActivator { - +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.Keepalive; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.Notify; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.Open; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.Update; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.BgpParameters; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.c.parameters.As4BytesCapability; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.open.message.bgp.parameters.optional.capabilities.c.parameters.BgpExtendedMessageCapability; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.Aggregator; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.Aigp; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.AsPath; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.AtomicAggregate; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.BgpPrefixSid; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.ClusterId; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.Communities; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.ExtendedCommunities; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.LocalPref; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.MultiExitDisc; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.Origin; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.OriginatorId; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.path.attributes.attributes.UnrecognizedAttributes; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.RouteRefresh; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.attributes.reach.MpReachNlri; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.attributes.unreach.MpUnreachNlri; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.AddPathCapability; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.GracefulRestartCapability; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.LlGracefulRestartCapability; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.MultiprotocolCapability; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.RouteRefreshCapability; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.Ipv4AddressFamily; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.Ipv6AddressFamily; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.MplsLabeledVpnSubsequentAddressFamily; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.NextHop; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.UnicastSubsequentAddressFamily; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.As4GenericSpecExtendedCommunityCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.As4RouteOriginExtendedCommunityCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.As4RouteTargetExtendedCommunityCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.AsSpecificExtendedCommunityCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.EncapsulationCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.Inet4SpecificExtendedCommunityCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.LinkBandwidthCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.OpaqueExtendedCommunityCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.RouteOriginExtendedCommunityCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.RouteOriginIpv4Case; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.RouteTargetExtendedCommunityCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.RouteTargetIpv4Case; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.SourceAs4ExtendedCommunityCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.SourceAsExtendedCommunityCase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.extended.community.extended.community.VrfRouteImportExtendedCommunityCase; +import org.opendaylight.yangtools.concepts.Registration; +import org.osgi.service.component.annotations.Component; + +@Singleton +@Component(immediate = true, property = "type=org.opendaylight.protocol.bgp.parser.impl.BGPActivator") +@MetaInfServices +public final class BGPActivator implements BGPExtensionProviderActivator { private static final int IPV4_AFI = 1; private static final int IPV6_AFI = 2; private static final int UNICAST_SAFI = 1; private static final int VPN_SAFI = 128; - @Override - protected List startImpl(final BGPExtensionProviderContext context) { - final List regs = new ArrayList<>(); - - regs.add(context.registerNlriSerializer(AdvertizedRoutes.class, new AdvertizedRoutesSerializer())); - regs.add(context.registerNlriSerializer(WithdrawnRoutes.class, new WithdrawnRoutesSerializer())); - - regs.add(context.registerAddressFamily(Ipv4AddressFamily.class, IPV4_AFI)); - regs.add(context.registerAddressFamily(Ipv6AddressFamily.class, IPV6_AFI)); + @Inject + public BGPActivator() { + // Exposed for DI + } - regs.add(context.registerSubsequentAddressFamily(UnicastSubsequentAddressFamily.class, UNICAST_SAFI)); - regs.add(context.registerSubsequentAddressFamily(MplsLabeledVpnSubsequentAddressFamily.class, VPN_SAFI)); + @Override + public List start(final BGPExtensionProviderContext context) { + final List regs = new ArrayList<>(); - final Ipv4NextHopParserSerializer ipv4NextHopParser = new Ipv4NextHopParserSerializer(); - regs.add(context.registerNlriParser(Ipv4AddressFamily.class, UnicastSubsequentAddressFamily.class, - new Ipv4NlriParser(), ipv4NextHopParser, Ipv4NextHopCase.class)); + regs.add(context.registerAddressFamily(Ipv4AddressFamily.VALUE, IPV4_AFI)); + regs.add(context.registerAddressFamily(Ipv6AddressFamily.VALUE, IPV6_AFI)); - final Ipv6NextHopParserSerializer ipv6NextHopParser = new Ipv6NextHopParserSerializer(); - regs.add(context.registerNlriParser(Ipv6AddressFamily.class, UnicastSubsequentAddressFamily.class, new - Ipv6NlriParser(), ipv6NextHopParser, Ipv6NextHopCase.class)); + regs.add(context.registerSubsequentAddressFamily(UnicastSubsequentAddressFamily.VALUE, UNICAST_SAFI)); + regs.add(context.registerSubsequentAddressFamily(MplsLabeledVpnSubsequentAddressFamily.VALUE, VPN_SAFI)); - this.registerExtendedCommunities(regs, context); - this.registerCapabilityParsers(regs, context); - this.registerAttributeParsers(regs, context); - this.registerMessageParsers(regs, context); + registerExtendedCommunities(regs, context); + registerCapabilityParsers(regs, context); + registerAttributeParsers(regs, context); + registerMessageParsers(regs, context); return regs; } - private void registerCapabilityParsers(final List regs, final BGPExtensionProviderContext context) { + private static void registerCapabilityParsers(final List regs, + final BGPExtensionProviderContext context) { final AddressFamilyRegistry afiReg = context.getAddressFamilyRegistry(); final SubsequentAddressFamilyRegistry safiReg = context.getSubsequentAddressFamilyRegistry(); @@ -155,6 +171,10 @@ public final class BGPActivator extends AbstractBGPExtensionProviderActivator { regs.add(context.registerCapabilitySerializer(GracefulRestartCapability.class, grace)); regs.add(context.registerCapabilityParser(GracefulCapabilityHandler.CODE, grace)); + final LlGracefulCapabilityHandler llgrace = new LlGracefulCapabilityHandler(afiReg, safiReg); + regs.add(context.registerCapabilitySerializer(LlGracefulRestartCapability.class, llgrace)); + regs.add(context.registerCapabilityParser(LlGracefulCapabilityHandler.CODE, llgrace)); + final CapabilityParameterParser cpp = new CapabilityParameterParser(context.getCapabilityRegistry()); regs.add(context.registerParameterParser(CapabilityParameterParser.TYPE, cpp)); regs.add(context.registerParameterSerializer(BgpParameters.class, cpp)); @@ -164,7 +184,13 @@ public final class BGPActivator extends AbstractBGPExtensionProviderActivator { regs.add(context.registerCapabilitySerializer(BgpExtendedMessageCapability.class, bgpextmessage)); } - private void registerAttributeParsers(final List regs, final BGPExtensionProviderContext context) { + private static void registerAttributeParsers(final List regs, + final BGPExtensionProviderContext context) { + final BgpPrefixSidAttributeParser prefixSidAttributeParser + = new BgpPrefixSidAttributeParser(context.getBgpPrefixSidTlvRegistry()); + regs.add(context.registerAttributeSerializer(BgpPrefixSid.class, prefixSidAttributeParser)); + regs.add(context.registerAttributeParser(BgpPrefixSidAttributeParser.TYPE, prefixSidAttributeParser)); + final OriginAttributeParser originAttributeParser = new OriginAttributeParser(); regs.add(context.registerAttributeSerializer(Origin.class, originAttributeParser)); regs.add(context.registerAttributeParser(OriginAttributeParser.TYPE, originAttributeParser)); @@ -181,9 +207,11 @@ public final class BGPActivator extends AbstractBGPExtensionProviderActivator { regs.add(context.registerAttributeSerializer(NextHop.class, nextHopAttributeParser)); regs.add(context.registerAttributeParser(NextHopAttributeParser.TYPE, nextHopAttributeParser)); - final MultiExitDiscriminatorAttributeParser multiExitDiscriminatorAttributeParser = new MultiExitDiscriminatorAttributeParser(); + final MultiExitDiscriminatorAttributeParser multiExitDiscriminatorAttributeParser + = new MultiExitDiscriminatorAttributeParser(); regs.add(context.registerAttributeSerializer(MultiExitDisc.class, multiExitDiscriminatorAttributeParser)); - regs.add(context.registerAttributeParser(MultiExitDiscriminatorAttributeParser.TYPE, multiExitDiscriminatorAttributeParser)); + regs.add(context.registerAttributeParser(MultiExitDiscriminatorAttributeParser.TYPE, + multiExitDiscriminatorAttributeParser)); final LocalPreferenceAttributeParser localPreferenceAttributeParser = new LocalPreferenceAttributeParser(); regs.add(context.registerAttributeSerializer(LocalPref.class, localPreferenceAttributeParser)); @@ -193,11 +221,13 @@ public final class BGPActivator extends AbstractBGPExtensionProviderActivator { regs.add(context.registerAttributeSerializer(AtomicAggregate.class, atomicAggregateAttributeParser)); regs.add(context.registerAttributeParser(AtomicAggregateAttributeParser.TYPE, atomicAggregateAttributeParser)); - final AggregatorAttributeParser as4AggregatorAttributeParser = new AggregatorAttributeParser(context.getReferenceCache()); + final AggregatorAttributeParser as4AggregatorAttributeParser + = new AggregatorAttributeParser(context.getReferenceCache()); regs.add(context.registerAttributeSerializer(Aggregator.class, as4AggregatorAttributeParser)); regs.add(context.registerAttributeParser(AggregatorAttributeParser.TYPE, as4AggregatorAttributeParser)); - final CommunitiesAttributeParser communitiesAttributeParser = new CommunitiesAttributeParser(context.getReferenceCache()); + final CommunitiesAttributeParser communitiesAttributeParser + = new CommunitiesAttributeParser(context.getReferenceCache()); regs.add(context.registerAttributeSerializer(Communities.class, communitiesAttributeParser)); regs.add(context.registerAttributeParser(CommunitiesAttributeParser.TYPE, communitiesAttributeParser)); @@ -219,20 +249,28 @@ public final class BGPActivator extends AbstractBGPExtensionProviderActivator { regs.add(context.registerAttributeSerializer(MpUnreachNlri.class, mpUnreachAttributeParser)); regs.add(context.registerAttributeParser(MPUnreachAttributeParser.TYPE, mpUnreachAttributeParser)); - final ExtendedCommunitiesAttributeParser extendedCommunitiesAttributeParser = new ExtendedCommunitiesAttributeParser(context.getExtendedCommunityReistry()); + final ExtendedCommunitiesAttributeParser extendedCommunitiesAttributeParser + = new ExtendedCommunitiesAttributeParser(context.getExtendedCommunityRegistry()); regs.add(context.registerAttributeSerializer(ExtendedCommunities.class, extendedCommunitiesAttributeParser)); - regs.add(context.registerAttributeParser(ExtendedCommunitiesAttributeParser.TYPE, extendedCommunitiesAttributeParser)); + regs.add(context.registerAttributeParser(ExtendedCommunitiesAttributeParser.TYPE, + extendedCommunitiesAttributeParser)); - regs.add(context.registerAttributeParser(AS4AggregatorAttributeParser.TYPE, new AS4AggregatorAttributeParser())); + regs.add(context.registerAttributeParser(AS4AggregatorAttributeParser.TYPE, + new AS4AggregatorAttributeParser())); regs.add(context.registerAttributeParser(AS4PathAttributeParser.TYPE, new AS4PathAttributeParser())); + + regs.add(context.registerAttributeSerializer(UnrecognizedAttributes.class, + new UnrecognizedAttributesSerializer())); } - private void registerMessageParsers(final List regs, final BGPExtensionProviderContext context) { + private static void registerMessageParsers(final List regs, + final BGPExtensionProviderContext context) { final BGPOpenMessageParser omp = new BGPOpenMessageParser(context.getParameterRegistry()); regs.add(context.registerMessageParser(BGPOpenMessageParser.TYPE, omp)); regs.add(context.registerMessageSerializer(Open.class, omp)); - final BGPUpdateMessageParser ump = new BGPUpdateMessageParser(context.getAttributeRegistry()); + final BGPUpdateMessageParser ump = new BGPUpdateMessageParser(context.getAttributeRegistry(), + context.getNlriRegistry()); regs.add(context.registerMessageParser(BGPUpdateMessageParser.TYPE, ump)); regs.add(context.registerMessageSerializer(Update.class, ump)); @@ -243,56 +281,110 @@ public final class BGPActivator extends AbstractBGPExtensionProviderActivator { final BGPKeepAliveMessageParser kamp = new BGPKeepAliveMessageParser(); regs.add(context.registerMessageParser(BGPKeepAliveMessageParser.TYPE, kamp)); regs.add(context.registerMessageSerializer(Keepalive.class, kamp)); + + final AddressFamilyRegistry afiReg = context.getAddressFamilyRegistry(); + final SubsequentAddressFamilyRegistry safiReg = context.getSubsequentAddressFamilyRegistry(); + final BGPRouteRefreshMessageParser rrmp = new BGPRouteRefreshMessageParser(afiReg, safiReg); + regs.add(context.registerMessageParser(BGPRouteRefreshMessageParser.TYPE, rrmp)); + regs.add(context.registerMessageSerializer(RouteRefresh.class, rrmp)); } - private void registerExtendedCommunities(final List regs, final BGPExtensionProviderContext context) { + private static void registerExtendedCommunities(final List regs, + final BGPExtensionProviderContext context) { final AsTwoOctetSpecificEcHandler twoOctetSpecificEcHandler = new AsTwoOctetSpecificEcHandler(); - regs.add(context.registerExtendedCommunityParser(twoOctetSpecificEcHandler.getType(true), twoOctetSpecificEcHandler.getSubType(), - twoOctetSpecificEcHandler)); - regs.add(context.registerExtendedCommunityParser(twoOctetSpecificEcHandler.getType(false), twoOctetSpecificEcHandler.getSubType(), - twoOctetSpecificEcHandler)); - regs.add(context.registerExtendedCommunitySerializer(AsSpecificExtendedCommunityCase.class, twoOctetSpecificEcHandler)); + regs.add(context.registerExtendedCommunityParser(twoOctetSpecificEcHandler.getType(true), + twoOctetSpecificEcHandler.getSubType(), twoOctetSpecificEcHandler)); + regs.add(context.registerExtendedCommunityParser(twoOctetSpecificEcHandler.getType(false), + twoOctetSpecificEcHandler.getSubType(), twoOctetSpecificEcHandler)); + regs.add(context.registerExtendedCommunitySerializer(AsSpecificExtendedCommunityCase.class, + twoOctetSpecificEcHandler)); final Ipv4SpecificEcHandler ipv4SpecificEcHandler = new Ipv4SpecificEcHandler(); - regs.add(context.registerExtendedCommunityParser(ipv4SpecificEcHandler.getType(true), ipv4SpecificEcHandler.getSubType(), - ipv4SpecificEcHandler)); - regs.add(context.registerExtendedCommunityParser(ipv4SpecificEcHandler.getType(false), ipv4SpecificEcHandler.getSubType(), - ipv4SpecificEcHandler)); - regs.add(context.registerExtendedCommunitySerializer(Inet4SpecificExtendedCommunityCase.class, ipv4SpecificEcHandler)); + regs.add(context.registerExtendedCommunityParser(ipv4SpecificEcHandler.getType(true), + ipv4SpecificEcHandler.getSubType(), ipv4SpecificEcHandler)); + regs.add(context.registerExtendedCommunityParser(ipv4SpecificEcHandler.getType(false), + ipv4SpecificEcHandler.getSubType(), ipv4SpecificEcHandler)); + regs.add(context.registerExtendedCommunitySerializer(Inet4SpecificExtendedCommunityCase.class, + ipv4SpecificEcHandler)); final OpaqueEcHandler opaqueEcHandler = new OpaqueEcHandler(); - regs.add(context.registerExtendedCommunityParser(opaqueEcHandler.getType(true), opaqueEcHandler.getSubType(), - opaqueEcHandler)); - regs.add(context.registerExtendedCommunityParser(opaqueEcHandler.getType(false), opaqueEcHandler.getSubType(), - opaqueEcHandler)); + regs.add(context.registerExtendedCommunityParser(opaqueEcHandler.getType(true), + opaqueEcHandler.getSubType(), opaqueEcHandler)); + regs.add(context.registerExtendedCommunityParser(opaqueEcHandler.getType(false), + opaqueEcHandler.getSubType(), opaqueEcHandler)); regs.add(context.registerExtendedCommunitySerializer(OpaqueExtendedCommunityCase.class, opaqueEcHandler)); final RouteOriginAsTwoOctetEcHandler routeOriginAS2bEcHandler = new RouteOriginAsTwoOctetEcHandler(); - regs.add(context.registerExtendedCommunityParser(routeOriginAS2bEcHandler.getType(true), routeOriginAS2bEcHandler.getSubType(), - routeOriginAS2bEcHandler)); - regs.add(context.registerExtendedCommunityParser(routeOriginAS2bEcHandler.getType(false), routeOriginAS2bEcHandler.getSubType(), - routeOriginAS2bEcHandler)); - regs.add(context.registerExtendedCommunitySerializer(RouteOriginExtendedCommunityCase.class, routeOriginAS2bEcHandler)); + regs.add(context.registerExtendedCommunityParser(routeOriginAS2bEcHandler.getType(true), + routeOriginAS2bEcHandler.getSubType(), routeOriginAS2bEcHandler)); + regs.add(context.registerExtendedCommunityParser(routeOriginAS2bEcHandler.getType(false), + routeOriginAS2bEcHandler.getSubType(), routeOriginAS2bEcHandler)); + regs.add(context.registerExtendedCommunitySerializer(RouteOriginExtendedCommunityCase.class, + routeOriginAS2bEcHandler)); final RouteTargetAsTwoOctetEcHandler routeTargetAS2bEcHandler = new RouteTargetAsTwoOctetEcHandler(); - regs.add(context.registerExtendedCommunityParser(routeTargetAS2bEcHandler.getType(true), routeTargetAS2bEcHandler.getSubType(), - routeTargetAS2bEcHandler)); - regs.add(context.registerExtendedCommunityParser(routeTargetAS2bEcHandler.getType(false), routeTargetAS2bEcHandler.getSubType(), - routeTargetAS2bEcHandler)); - regs.add(context.registerExtendedCommunitySerializer(RouteTargetExtendedCommunityCase.class, routeTargetAS2bEcHandler)); + regs.add(context.registerExtendedCommunityParser(routeTargetAS2bEcHandler.getType(true), + routeTargetAS2bEcHandler.getSubType(), routeTargetAS2bEcHandler)); + regs.add(context.registerExtendedCommunityParser(routeTargetAS2bEcHandler.getType(false), + routeTargetAS2bEcHandler.getSubType(), routeTargetAS2bEcHandler)); + regs.add(context.registerExtendedCommunitySerializer(RouteTargetExtendedCommunityCase.class, + routeTargetAS2bEcHandler)); final RouteOriginIpv4EcHandler routeOriginIpv4EcHandler = new RouteOriginIpv4EcHandler(); - regs.add(context.registerExtendedCommunityParser(routeOriginIpv4EcHandler.getType(true), routeOriginIpv4EcHandler.getSubType(), - routeOriginIpv4EcHandler)); - regs.add(context.registerExtendedCommunityParser(routeOriginIpv4EcHandler.getType(false), routeOriginIpv4EcHandler.getSubType(), - routeOriginIpv4EcHandler)); + regs.add(context.registerExtendedCommunityParser(routeOriginIpv4EcHandler.getType(true), + routeOriginIpv4EcHandler.getSubType(), routeOriginIpv4EcHandler)); + regs.add(context.registerExtendedCommunityParser(routeOriginIpv4EcHandler.getType(false), + routeOriginIpv4EcHandler.getSubType(), routeOriginIpv4EcHandler)); regs.add(context.registerExtendedCommunitySerializer(RouteOriginIpv4Case.class, routeOriginIpv4EcHandler)); final RouteTargetIpv4EcHandler routeTargetIpv4EcHandler = new RouteTargetIpv4EcHandler(); - regs.add(context.registerExtendedCommunityParser(routeTargetIpv4EcHandler.getType(true), routeTargetIpv4EcHandler.getSubType(), - routeTargetIpv4EcHandler)); - regs.add(context.registerExtendedCommunityParser(routeTargetIpv4EcHandler.getType(false), routeTargetIpv4EcHandler.getSubType(), - routeTargetIpv4EcHandler)); + regs.add(context.registerExtendedCommunityParser(routeTargetIpv4EcHandler.getType(true), + routeTargetIpv4EcHandler.getSubType(), routeTargetIpv4EcHandler)); + regs.add(context.registerExtendedCommunityParser(routeTargetIpv4EcHandler.getType(false), + routeTargetIpv4EcHandler.getSubType(), routeTargetIpv4EcHandler)); regs.add(context.registerExtendedCommunitySerializer(RouteTargetIpv4Case.class, routeTargetIpv4EcHandler)); + + final LinkBandwidthEC linkBandwidthECHandler = new LinkBandwidthEC(); + regs.add(context.registerExtendedCommunityParser(linkBandwidthECHandler.getType(false), + linkBandwidthECHandler.getSubType(), linkBandwidthECHandler)); + regs.add(context.registerExtendedCommunitySerializer(LinkBandwidthCase.class, linkBandwidthECHandler)); + + final Generic4OctASEcHandler gen4OctASEcHandler = new Generic4OctASEcHandler(); + regs.add(context.registerExtendedCommunityParser(gen4OctASEcHandler.getType(true), + gen4OctASEcHandler.getSubType(), gen4OctASEcHandler)); + regs.add(context.registerExtendedCommunityParser(gen4OctASEcHandler.getType(false), + gen4OctASEcHandler.getSubType(), gen4OctASEcHandler)); + regs.add(context.registerExtendedCommunitySerializer(As4GenericSpecExtendedCommunityCase.class, + gen4OctASEcHandler)); + + final RouteTarget4OctectASEcHandler rt4ASHandler = new RouteTarget4OctectASEcHandler(); + regs.add(context.registerExtendedCommunityParser(rt4ASHandler.getType(true), + rt4ASHandler.getSubType(), rt4ASHandler)); + regs.add(context.registerExtendedCommunitySerializer(As4RouteTargetExtendedCommunityCase.class, rt4ASHandler)); + + final RouteOrigin4OctectASEcHandler rOrig4Oct = new RouteOrigin4OctectASEcHandler(); + regs.add(context.registerExtendedCommunityParser(rOrig4Oct.getType(true), rOrig4Oct.getSubType(), rOrig4Oct)); + regs.add(context.registerExtendedCommunitySerializer(As4RouteOriginExtendedCommunityCase.class, rOrig4Oct)); + + final EncapsulationEC encapsulationECHandler = new EncapsulationEC(); + regs.add(context.registerExtendedCommunityParser(encapsulationECHandler.getType(true), + encapsulationECHandler.getSubType(), encapsulationECHandler)); + regs.add(context.registerExtendedCommunitySerializer(EncapsulationCase.class, encapsulationECHandler)); + + final VrfRouteImportHandler vrfRouteImportHandler = new VrfRouteImportHandler(); + regs.add(context.registerExtendedCommunityParser(vrfRouteImportHandler.getType(true), + vrfRouteImportHandler.getSubType(), vrfRouteImportHandler)); + regs.add(context.registerExtendedCommunitySerializer(VrfRouteImportExtendedCommunityCase.class, + vrfRouteImportHandler)); + + final SourceAS4OctectHandler source4ASHandler = new SourceAS4OctectHandler(); + regs.add(context.registerExtendedCommunityParser(source4ASHandler.getType(true), + source4ASHandler.getSubType(), source4ASHandler)); + regs.add(context.registerExtendedCommunitySerializer(SourceAs4ExtendedCommunityCase.class, source4ASHandler)); + + final SourceASHandler sourceASHandler = new SourceASHandler(); + regs.add(context.registerExtendedCommunityParser(sourceASHandler.getType(true), + sourceASHandler.getSubType(), sourceASHandler)); + regs.add(context.registerExtendedCommunitySerializer(SourceAsExtendedCommunityCase.class, sourceASHandler)); } }