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