neutron-ovsdb/src/main/java/org/opendaylight/groupbasedpolicy/neutron/ovsdb/NeutronOvsdb.java

   1 package org.opendaylight.groupbasedpolicy.neutron.ovsdb;
   2
   3 import static com.google.common.base.Preconditions.checkNotNull;
   4
   5 import java.util.ArrayList;
   6 import java.util.List;
   7
   8 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
   9 import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.EndpointService;
  11 import org.osgi.framework.BundleContext;
  12 import org.osgi.framework.ServiceRegistration;
  13
  14 public class NeutronOvsdb implements AutoCloseable {
  15
  16     private final List<ServiceRegistration<?>> registrations = new ArrayList<ServiceRegistration<?>>();
  17     private final TerminationPointDataChangeListener tpListener;
  18     private final NodeDataChangeListener nodeListener;
  19     private final NeutronGbpExternalGatewaysListener neutronGbpExternalGatewaysListener;
  20     private final NeutronGbpFloatingIpListener neutronGbpFloatingIpListener;
  21
  22     public NeutronOvsdb(DataBroker dataProvider, RpcProviderRegistry rpcProvider, BundleContext context) {
  23         checkNotNull(dataProvider);
  24         checkNotNull(rpcProvider);
  25         checkNotNull(context);
  26
  27         EndpointService epService = rpcProvider.getRpcService(EndpointService.class);
  28         tpListener = new TerminationPointDataChangeListener(dataProvider, epService);
  29         nodeListener = new NodeDataChangeListener(dataProvider);
  30         neutronGbpExternalGatewaysListener = new NeutronGbpExternalGatewaysListener(dataProvider);
  31         neutronGbpFloatingIpListener = new NeutronGbpFloatingIpListener(dataProvider);
  32     }
  33
  34     /**
  35      * @see java.lang.AutoCloseable#close()
  36      */
  37     @Override
  38     public void close() throws Exception {
  39         for (ServiceRegistration<?> registration : registrations) {
  40             registration.unregister();
  41         }
  42     }
  43
  44 }