2 * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
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
8 package org.opendaylight.protocol.bgp.parser.impl;
10 import java.util.ArrayList;
11 import java.util.List;
13 import org.opendaylight.protocol.bgp.linkstate.LinkstateAttributeParser;
14 import org.opendaylight.protocol.bgp.parser.impl.message.BGPKeepAliveMessageParser;
15 import org.opendaylight.protocol.bgp.parser.impl.message.BGPNotificationMessageParser;
16 import org.opendaylight.protocol.bgp.parser.impl.message.BGPOpenMessageParser;
17 import org.opendaylight.protocol.bgp.parser.impl.message.BGPUpdateMessageParser;
18 import org.opendaylight.protocol.bgp.parser.impl.message.open.As4CapabilityHandler;
19 import org.opendaylight.protocol.bgp.parser.impl.message.open.CapabilityParameterParser;
20 import org.opendaylight.protocol.bgp.parser.impl.message.open.MultiProtocolCapabilityHandler;
21 import org.opendaylight.protocol.bgp.parser.impl.message.update.AS4AggregatorAttributeParser;
22 import org.opendaylight.protocol.bgp.parser.impl.message.update.AS4PathAttributeParser;
23 import org.opendaylight.protocol.bgp.parser.impl.message.update.AggregatorAttributeParser;
24 import org.opendaylight.protocol.bgp.parser.impl.message.update.AsPathAttributeParser;
25 import org.opendaylight.protocol.bgp.parser.impl.message.update.AtomicAggregateAttributeParser;
26 import org.opendaylight.protocol.bgp.parser.impl.message.update.ClusterIdAttributeParser;
27 import org.opendaylight.protocol.bgp.parser.impl.message.update.CommunitiesAttributeParser;
28 import org.opendaylight.protocol.bgp.parser.impl.message.update.ExtendedCommunitiesAttributeParser;
29 import org.opendaylight.protocol.bgp.parser.impl.message.update.Ipv4NlriParser;
30 import org.opendaylight.protocol.bgp.parser.impl.message.update.Ipv6NlriParser;
31 import org.opendaylight.protocol.bgp.parser.impl.message.update.LinkstateNlriParser;
32 import org.opendaylight.protocol.bgp.parser.impl.message.update.LocalPreferenceAttributeParser;
33 import org.opendaylight.protocol.bgp.parser.impl.message.update.MPReachAttributeParser;
34 import org.opendaylight.protocol.bgp.parser.impl.message.update.MPUnreachAttributeParser;
35 import org.opendaylight.protocol.bgp.parser.impl.message.update.MultiExitDiscriminatorAttributeParser;
36 import org.opendaylight.protocol.bgp.parser.impl.message.update.NextHopAttributeParser;
37 import org.opendaylight.protocol.bgp.parser.impl.message.update.OriginAttributeParser;
38 import org.opendaylight.protocol.bgp.parser.impl.message.update.OriginatorIdAttributeParser;
39 import org.opendaylight.protocol.bgp.parser.spi.AddressFamilyRegistry;
40 import org.opendaylight.protocol.bgp.parser.spi.AttributeRegistry;
41 import org.opendaylight.protocol.bgp.parser.spi.CapabilityRegistry;
42 import org.opendaylight.protocol.bgp.parser.spi.MessageRegistry;
43 import org.opendaylight.protocol.bgp.parser.spi.NlriRegistry;
44 import org.opendaylight.protocol.bgp.parser.spi.ParameterRegistry;
45 import org.opendaylight.protocol.bgp.parser.spi.ProviderActivator;
46 import org.opendaylight.protocol.bgp.parser.spi.ProviderContext;
47 import org.opendaylight.protocol.bgp.parser.spi.SubsequentAddressFamilyRegistry;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev130918.LinkstateAddressFamily;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev130918.LinkstateSubsequentAddressFamily;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130918.Keepalive;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130918.Notify;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130918.Open;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130918.open.BgpParameters;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130918.open.bgp.parameters.c.parameters.CAs4Bytes;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130918.open.bgp.parameters.c.parameters.CMultiprotocol;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.Ipv4AddressFamily;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.Ipv6AddressFamily;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.MplsLabeledVpnSubsequentAddressFamily;
59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.UnicastSubsequentAddressFamily;
60 import org.slf4j.Logger;
61 import org.slf4j.LoggerFactory;
63 import com.google.common.base.Preconditions;
65 public final class ActivatorImpl implements ProviderActivator {
66 private static final Logger logger = LoggerFactory.getLogger(ActivatorImpl.class);
67 private List<AutoCloseable> registrations;
70 public synchronized void start(final ProviderContext context) {
71 Preconditions.checkState(registrations == null);
72 final List<AutoCloseable> regs = new ArrayList<>();
74 final AddressFamilyRegistry afiReg = context.getAddressFamilyRegistry();
75 regs.add(afiReg.registerAddressFamily(Ipv4AddressFamily.class, 1));
76 regs.add(afiReg.registerAddressFamily(Ipv6AddressFamily.class, 2));
77 regs.add(afiReg.registerAddressFamily(LinkstateAddressFamily.class, 16388));
79 final SubsequentAddressFamilyRegistry safiReg = context.getSubsequentAddressFamilyRegistry();
80 regs.add(safiReg.registerSubsequentAddressFamily(UnicastSubsequentAddressFamily.class, 1));
81 regs.add(safiReg.registerSubsequentAddressFamily(LinkstateSubsequentAddressFamily.class, 71));
82 regs.add(safiReg.registerSubsequentAddressFamily(MplsLabeledVpnSubsequentAddressFamily.class, 128));
84 final NlriRegistry nlriReg = context.getNlriRegistry();
85 regs.add(nlriReg.registerNlriParser(Ipv4AddressFamily.class, UnicastSubsequentAddressFamily.class,
86 new Ipv4NlriParser()));
87 regs.add(nlriReg.registerNlriParser(Ipv6AddressFamily.class, UnicastSubsequentAddressFamily.class,
88 new Ipv6NlriParser()));
89 regs.add(nlriReg.registerNlriParser(LinkstateAddressFamily.class, LinkstateSubsequentAddressFamily.class,
90 new LinkstateNlriParser(false)));
91 regs.add(nlriReg.registerNlriParser(LinkstateAddressFamily.class, MplsLabeledVpnSubsequentAddressFamily.class,
92 new LinkstateNlriParser(true)));
94 final AttributeRegistry attrReg = context.getAttributeRegistry();
95 regs.add(attrReg.registerAttributeParser(OriginAttributeParser.TYPE, new OriginAttributeParser()));
96 regs.add(attrReg.registerAttributeParser(AsPathAttributeParser.TYPE, new AsPathAttributeParser()));
97 regs.add(attrReg.registerAttributeParser(NextHopAttributeParser.TYPE, new NextHopAttributeParser()));
98 regs.add(attrReg.registerAttributeParser(MultiExitDiscriminatorAttributeParser.TYPE,
99 new MultiExitDiscriminatorAttributeParser()));
100 regs.add(attrReg.registerAttributeParser(LocalPreferenceAttributeParser.TYPE, new LocalPreferenceAttributeParser()));
101 regs.add(attrReg.registerAttributeParser(AtomicAggregateAttributeParser.TYPE, new AtomicAggregateAttributeParser()));
102 regs.add(attrReg.registerAttributeParser(AggregatorAttributeParser.TYPE, new AggregatorAttributeParser()));
103 regs.add(attrReg.registerAttributeParser(CommunitiesAttributeParser.TYPE, new CommunitiesAttributeParser()));
104 regs.add(attrReg.registerAttributeParser(OriginatorIdAttributeParser.TYPE, new OriginatorIdAttributeParser()));
105 regs.add(attrReg.registerAttributeParser(ClusterIdAttributeParser.TYPE, new ClusterIdAttributeParser()));
106 regs.add(attrReg.registerAttributeParser(MPReachAttributeParser.TYPE, new MPReachAttributeParser(nlriReg)));
107 regs.add(attrReg.registerAttributeParser(MPUnreachAttributeParser.TYPE, new MPUnreachAttributeParser(nlriReg)));
108 regs.add(attrReg.registerAttributeParser(ExtendedCommunitiesAttributeParser.TYPE, new ExtendedCommunitiesAttributeParser()));
109 regs.add(attrReg.registerAttributeParser(AS4AggregatorAttributeParser.TYPE, new AS4AggregatorAttributeParser()));
110 regs.add(attrReg.registerAttributeParser(AS4PathAttributeParser.TYPE, new AS4PathAttributeParser()));
111 regs.add(attrReg.registerAttributeParser(LinkstateAttributeParser.TYPE, new LinkstateAttributeParser()));
113 final CapabilityRegistry capReg = context.getCapabilityRegistry();
114 final MultiProtocolCapabilityHandler multi = new MultiProtocolCapabilityHandler(afiReg, safiReg);
115 regs.add(capReg.registerCapabilityParser(MultiProtocolCapabilityHandler.CODE, multi));
116 regs.add(capReg.registerCapabilitySerializer(CMultiprotocol.class, multi));
118 final As4CapabilityHandler as4 = new As4CapabilityHandler();
119 regs.add(capReg.registerCapabilityParser(As4CapabilityHandler.CODE, as4));
120 regs.add(capReg.registerCapabilitySerializer(CAs4Bytes.class, as4));
122 final ParameterRegistry paramReg = context.getParameterRegistry();
123 final CapabilityParameterParser cpp = new CapabilityParameterParser(capReg);
124 regs.add(paramReg.registerParameterParser(CapabilityParameterParser.TYPE, cpp));
125 regs.add(paramReg.registerParameterSerializer(BgpParameters.class, cpp));
127 final MessageRegistry msgReg = context.getMessageRegistry();
128 final BGPOpenMessageParser omp = new BGPOpenMessageParser(paramReg);
129 regs.add(msgReg.registerMessageParser(BGPOpenMessageParser.TYPE, omp));
130 regs.add(msgReg.registerMessageSerializer(Open.class, omp));
132 final BGPUpdateMessageParser ump = new BGPUpdateMessageParser(attrReg);
133 regs.add(msgReg.registerMessageParser(BGPUpdateMessageParser.TYPE, ump));
134 // Serialization of Update message is not supported
135 // regs.add(msgReg.registerMessageSerializer(Update.class, ump));
137 final BGPNotificationMessageParser nmp = new BGPNotificationMessageParser();
138 regs.add(msgReg.registerMessageParser(BGPNotificationMessageParser.TYPE, nmp));
139 regs.add(msgReg.registerMessageSerializer(Notify.class, nmp));
141 final BGPKeepAliveMessageParser kamp = new BGPKeepAliveMessageParser();
142 regs.add(msgReg.registerMessageParser(BGPKeepAliveMessageParser.TYPE, kamp));
143 regs.add(msgReg.registerMessageSerializer(Keepalive.class, kamp));
145 registrations = regs;
149 public synchronized void stop() {
150 Preconditions.checkState(registrations != null);
152 for (AutoCloseable r : registrations) {
155 } catch (Exception e) {
156 logger.warn("Failed to close registration", e);
160 registrations = null;