transcriber/src/main/java/org/opendaylight/neutron/transcriber/NeutronTranscriberProvider.java

   1 /*
   2  * Copyright (c) 2015 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
   9 package org.opendaylight.neutron.transcriber;
  10
  11 import com.google.common.base.Preconditions;
  12 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  13 import org.opendaylight.neutron.spi.INeutronBgpvpnCRUD;
  14 import org.opendaylight.neutron.spi.INeutronCRUD;
  15 import org.opendaylight.neutron.spi.INeutronFirewallCRUD;
  16 import org.opendaylight.neutron.spi.INeutronFirewallPolicyCRUD;
  17 import org.opendaylight.neutron.spi.INeutronFirewallRuleCRUD;
  18 import org.opendaylight.neutron.spi.INeutronFloatingIPCRUD;
  19 import org.opendaylight.neutron.spi.INeutronL2gatewayCRUD;
  20 import org.opendaylight.neutron.spi.INeutronL2gatewayConnectionCRUD;
  21 import org.opendaylight.neutron.spi.INeutronLoadBalancerCRUD;
  22 import org.opendaylight.neutron.spi.INeutronLoadBalancerHealthMonitorCRUD;
  23 import org.opendaylight.neutron.spi.INeutronLoadBalancerListenerCRUD;
  24 import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolCRUD;
  25 import org.opendaylight.neutron.spi.INeutronMeteringLabelCRUD;
  26 import org.opendaylight.neutron.spi.INeutronMeteringLabelRuleCRUD;
  27 import org.opendaylight.neutron.spi.INeutronNetworkCRUD;
  28 import org.opendaylight.neutron.spi.INeutronPortCRUD;
  29 import org.opendaylight.neutron.spi.INeutronRouterCRUD;
  30 import org.opendaylight.neutron.spi.INeutronSFCFlowClassifierCRUD;
  31 import org.opendaylight.neutron.spi.INeutronSFCPortChainCRUD;
  32 import org.opendaylight.neutron.spi.INeutronSFCPortPairCRUD;
  33 import org.opendaylight.neutron.spi.INeutronSFCPortPairGroupCRUD;
  34 import org.opendaylight.neutron.spi.INeutronSecurityGroupCRUD;
  35 import org.opendaylight.neutron.spi.INeutronSecurityRuleCRUD;
  36 import org.opendaylight.neutron.spi.INeutronSubnetCRUD;
  37 import org.opendaylight.neutron.spi.INeutronVPNIKEPolicyCRUD;
  38 import org.opendaylight.neutron.spi.INeutronVPNIPSECPolicyCRUD;
  39 import org.opendaylight.neutron.spi.INeutronVPNIPSECSiteConnectionsCRUD;
  40 import org.opendaylight.neutron.spi.INeutronVPNServiceCRUD;
  41 import org.opendaylight.neutron.spi.INeutronQosPolicyCRUD;
  42 import org.osgi.framework.BundleContext;
  43 import org.osgi.framework.ServiceRegistration;
  44 import org.slf4j.Logger;
  45 import org.slf4j.LoggerFactory;
  46
  47 import java.util.ArrayList;
  48 import java.util.List;
  49
  50 public class NeutronTranscriberProvider
  51     implements AutoCloseable, NeutronTranscriber {
  52     private static final Logger LOGGER = LoggerFactory.getLogger(NeutronTranscriberProvider.class);
  53
  54     private BundleContext context;
  55     private DataBroker db;
  56     private final List<ServiceRegistration<? extends INeutronCRUD<?>>> registrations = new ArrayList<>();
  57     private final List<AutoCloseable> neutronInterfaces = new ArrayList<>();
  58
  59     private NeutronBgpvpnInterface bgpvpnInterface;
  60     private NeutronFirewallInterface firewallInterface;
  61     private NeutronFirewallPolicyInterface firewallPolicyInterface;
  62     private NeutronFirewallRuleInterface firewallRuleInterface;
  63     private NeutronFloatingIPInterface floatingIPInterface;
  64     private NeutronL2gatewayConnectionInterface l2gatewayConnectionInterface;
  65     private NeutronL2gatewayInterface l2gatewayInterface;
  66     private NeutronLoadBalancerHealthMonitorInterface loadBalancerHealthMonitorInterface;
  67     private NeutronLoadBalancerInterface loadBalancerInterface;
  68     private NeutronLoadBalancerListenerInterface loadBalancerListenerInterface;
  69     private NeutronLoadBalancerPoolInterface loadBalancerPoolInterface;
  70     private NeutronMeteringLabelInterface meteringLabelInterface;
  71     private NeutronMeteringLabelRuleInterface meteringLabelRuleInterface;
  72     private NeutronNetworkInterface networkInterface;
  73     private NeutronPortInterface portInterface;
  74     private NeutronRouterInterface routerInterface;
  75     private NeutronSecurityGroupInterface securityGroupInterface;
  76     private NeutronSecurityRuleInterface securityRuleInterface;
  77     private NeutronSubnetInterface subnetInterface;
  78     private NeutronVPNIKEPolicyInterface vPNIKEPolicyInterface;
  79     private NeutronVPNIPSECPolicyInterface vPNIPSECPolicyInterface;
  80     private NeutronVPNIPSECSiteConnectionsInterface vPNIPSECSiteConnectionsInterface;
  81     private NeutronVPNServiceInterface vPNServiceInterface;
  82     private NeutronSFCFlowClassifierInterface sfcFlowClassifierInterface;
  83     private NeutronSFCPortPairInterface sfcPortPairInterface;
  84     private NeutronSFCPortPairGroupInterface sfcPortPairGroupInterface;
  85     private NeutronSFCPortChainInterface sfcPortChainInterface;
  86     private NeutronQosPolicyInterface qosPolicyInterface;
  87
  88     public NeutronTranscriberProvider(BundleContext context, DataBroker db) {
  89         LOGGER.debug("DataBroker set to: {}", db);
  90         this.context = Preconditions.checkNotNull(context);
  91         this.db = Preconditions.checkNotNull(db);
  92     }
  93
  94     private <S extends INeutronCRUD<?>, T extends AutoCloseable /* & S */>
  95     void registerCRUDInterface(java.lang.Class<S> clazz, T crudInterface) {
  96         neutronInterfaces.add(crudInterface);
  97         @SuppressWarnings("unchecked")
  98         S sCrudInterface = (S)crudInterface;
  99         final ServiceRegistration<S> crudInterfaceRegistration =
 100                 context.registerService(clazz, sCrudInterface, null);
 101         registrations.add(crudInterfaceRegistration);
 102     }
 103
 104     public void init() {
 105         bgpvpnInterface = new NeutronBgpvpnInterface(db);
 106         registerCRUDInterface(INeutronBgpvpnCRUD.class, bgpvpnInterface);
 107
 108         firewallInterface = new NeutronFirewallInterface(db);
 109         registerCRUDInterface(INeutronFirewallCRUD.class, firewallInterface);
 110
 111         firewallPolicyInterface = new NeutronFirewallPolicyInterface(db);
 112         registerCRUDInterface(INeutronFirewallPolicyCRUD.class, firewallPolicyInterface);
 113
 114         firewallRuleInterface = new NeutronFirewallRuleInterface(db);
 115         registerCRUDInterface(INeutronFirewallRuleCRUD.class, firewallRuleInterface);
 116
 117         floatingIPInterface = new NeutronFloatingIPInterface(db);
 118         registerCRUDInterface(INeutronFloatingIPCRUD.class, floatingIPInterface);
 119
 120         l2gatewayConnectionInterface = new NeutronL2gatewayConnectionInterface(db);
 121         registerCRUDInterface(INeutronL2gatewayConnectionCRUD.class, l2gatewayConnectionInterface);
 122
 123         l2gatewayInterface = new NeutronL2gatewayInterface(db);
 124         registerCRUDInterface(INeutronL2gatewayCRUD.class, l2gatewayInterface);
 125
 126         loadBalancerHealthMonitorInterface = new NeutronLoadBalancerHealthMonitorInterface(db);
 127         registerCRUDInterface(INeutronLoadBalancerHealthMonitorCRUD.class, loadBalancerHealthMonitorInterface);
 128
 129         loadBalancerInterface = new NeutronLoadBalancerInterface(db);
 130         registerCRUDInterface(INeutronLoadBalancerCRUD.class, loadBalancerInterface);
 131
 132         loadBalancerListenerInterface = new NeutronLoadBalancerListenerInterface(db);
 133         registerCRUDInterface(INeutronLoadBalancerListenerCRUD.class, loadBalancerListenerInterface);
 134
 135         loadBalancerPoolInterface = new NeutronLoadBalancerPoolInterface(db);
 136         registerCRUDInterface(INeutronLoadBalancerPoolCRUD.class, loadBalancerPoolInterface);
 137
 138         meteringLabelInterface = new NeutronMeteringLabelInterface(db);
 139         registerCRUDInterface(INeutronMeteringLabelCRUD.class, meteringLabelInterface);
 140
 141         meteringLabelRuleInterface = new NeutronMeteringLabelRuleInterface(db);
 142         registerCRUDInterface(INeutronMeteringLabelRuleCRUD.class, meteringLabelRuleInterface);
 143
 144         networkInterface = new NeutronNetworkInterface(db);
 145         registerCRUDInterface(INeutronNetworkCRUD.class, networkInterface);
 146
 147         portInterface = new NeutronPortInterface(db);
 148         registerCRUDInterface(INeutronPortCRUD.class, portInterface);
 149
 150         routerInterface = new NeutronRouterInterface(db);
 151         registerCRUDInterface(INeutronRouterCRUD.class, routerInterface);
 152
 153         securityGroupInterface = new NeutronSecurityGroupInterface(db);
 154         registerCRUDInterface(INeutronSecurityGroupCRUD.class, securityGroupInterface);
 155
 156         securityRuleInterface = new NeutronSecurityRuleInterface(db);
 157         registerCRUDInterface(INeutronSecurityRuleCRUD.class, securityRuleInterface);
 158
 159         subnetInterface = new NeutronSubnetInterface(db);
 160         registerCRUDInterface(INeutronSubnetCRUD.class, subnetInterface);
 161
 162         vPNIKEPolicyInterface = new NeutronVPNIKEPolicyInterface(db);
 163         registerCRUDInterface(INeutronVPNIKEPolicyCRUD.class, vPNIKEPolicyInterface);
 164
 165         vPNIPSECPolicyInterface = new NeutronVPNIPSECPolicyInterface(db);
 166         registerCRUDInterface(INeutronVPNIPSECPolicyCRUD.class, vPNIPSECPolicyInterface);
 167
 168         vPNIPSECSiteConnectionsInterface = new NeutronVPNIPSECSiteConnectionsInterface(db);
 169         registerCRUDInterface(INeutronVPNIPSECSiteConnectionsCRUD.class, vPNIPSECSiteConnectionsInterface);
 170
 171         vPNServiceInterface = new NeutronVPNServiceInterface(db);
 172         registerCRUDInterface(INeutronVPNServiceCRUD.class, vPNServiceInterface);
 173
 174         sfcFlowClassifierInterface = new NeutronSFCFlowClassifierInterface(db);
 175         registerCRUDInterface(INeutronSFCFlowClassifierCRUD.class,sfcFlowClassifierInterface);
 176
 177         sfcPortPairInterface = new NeutronSFCPortPairInterface(db);
 178         registerCRUDInterface(INeutronSFCPortPairCRUD.class, sfcPortPairInterface);
 179
 180         sfcPortPairGroupInterface = new NeutronSFCPortPairGroupInterface(db);
 181         registerCRUDInterface(INeutronSFCPortPairGroupCRUD.class, sfcPortPairGroupInterface);
 182
 183         sfcPortChainInterface = new NeutronSFCPortChainInterface(db);
 184         registerCRUDInterface(INeutronSFCPortChainCRUD.class, sfcPortChainInterface);
 185
 186         qosPolicyInterface = new NeutronQosPolicyInterface(db);
 187         registerCRUDInterface(INeutronQosPolicyCRUD.class, qosPolicyInterface);
 188
 189         // We don't need context any more
 190         this.context = null;
 191     }
 192
 193     @Override
 194     public void close() throws Exception {
 195         for (final ServiceRegistration registration : registrations) {
 196             registration.unregister();
 197         }
 198         for (final AutoCloseable neutronCRUD : neutronInterfaces) {
 199             neutronCRUD.close();
 200         }
 201         neutronInterfaces.clear();
 202     }
 203 }