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