bgp/parser-impl/src/main/java/org/opendaylight/protocol/bgp/parser/impl/ActivatorImpl.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
  13 import org.opendaylight.protocol.bgp.linkstate.LinkstateAttributeParser;
  14 import org.opendaylight.protocol.bgp.linkstate.LinkstateNlriParser;
  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.BGPUpdateMessageParser;
  19 import org.opendaylight.protocol.bgp.parser.impl.message.open.As4CapabilityHandler;
  20 import org.opendaylight.protocol.bgp.parser.impl.message.open.CapabilityParameterParser;
  21 import org.opendaylight.protocol.bgp.parser.impl.message.open.MultiProtocolCapabilityHandler;
  22 import org.opendaylight.protocol.bgp.parser.impl.message.update.AS4AggregatorAttributeParser;
  23 import org.opendaylight.protocol.bgp.parser.impl.message.update.AS4PathAttributeParser;
  24 import org.opendaylight.protocol.bgp.parser.impl.message.update.AggregatorAttributeParser;
  25 import org.opendaylight.protocol.bgp.parser.impl.message.update.AsPathAttributeParser;
  26 import org.opendaylight.protocol.bgp.parser.impl.message.update.AtomicAggregateAttributeParser;
  27 import org.opendaylight.protocol.bgp.parser.impl.message.update.ClusterIdAttributeParser;
  28 import org.opendaylight.protocol.bgp.parser.impl.message.update.CommunitiesAttributeParser;
  29 import org.opendaylight.protocol.bgp.parser.impl.message.update.ExtendedCommunitiesAttributeParser;
  30 import org.opendaylight.protocol.bgp.parser.impl.message.update.Ipv4NlriParser;
  31 import org.opendaylight.protocol.bgp.parser.impl.message.update.Ipv6NlriParser;
  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;
  62
  63 import com.google.common.base.Preconditions;
  64
  65 public final class ActivatorImpl implements ProviderActivator {
  66         private static final Logger logger = LoggerFactory.getLogger(ActivatorImpl.class);
  67         private List<AutoCloseable> registrations;
  68
  69         @Override
  70         public synchronized void start(final ProviderContext context) {
  71                 Preconditions.checkState(registrations == null);
  72                 final List<AutoCloseable> regs = new ArrayList<>();
  73
  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));
  78
  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));
  83
  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)));
  93
  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()));
 112
 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));
 117
 118                 final As4CapabilityHandler as4 = new As4CapabilityHandler();
 119                 regs.add(capReg.registerCapabilityParser(As4CapabilityHandler.CODE, as4));
 120                 regs.add(capReg.registerCapabilitySerializer(CAs4Bytes.class, as4));
 121
 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));
 126
 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));
 131
 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));
 136
 137                 final BGPNotificationMessageParser nmp = new BGPNotificationMessageParser();
 138                 regs.add(msgReg.registerMessageParser(BGPNotificationMessageParser.TYPE, nmp));
 139                 regs.add(msgReg.registerMessageSerializer(Notify.class, nmp));
 140
 141                 final BGPKeepAliveMessageParser kamp = new BGPKeepAliveMessageParser();
 142                 regs.add(msgReg.registerMessageParser(BGPKeepAliveMessageParser.TYPE, kamp));
 143                 regs.add(msgReg.registerMessageSerializer(Keepalive.class, kamp));
 144
 145                 registrations = regs;
 146         }
 147
 148         @Override
 149         public synchronized void stop() {
 150                 Preconditions.checkState(registrations != null);
 151
 152                 for (AutoCloseable r : registrations) {
 153                         try {
 154                                 r.close();
 155                         } catch (Exception e) {
 156                                 logger.warn("Failed to close registration", e);
 157                         }
 158                 }
 159
 160                 registrations = null;
 161         }
 162 }