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     public NeutronOvsdb(DataBroker dataProvider, RpcProviderRegistry rpcProvider, BundleContext context) {
  20         checkNotNull(dataProvider);
  21         checkNotNull(rpcProvider);
  22         checkNotNull(context);
  23
  24         EndpointService epService = rpcProvider.getRpcService(EndpointService.class);
  25         tpListener = new TerminationPointDataChangeListener(dataProvider, epService);
  26         nodeListener = new NodeDataChangeListener(dataProvider);
  27     }
  28
  29     /**
  30      * @see java.lang.AutoCloseable#close()
  31      */
  32     @Override
  33     public void close() throws Exception {
  34         for (ServiceRegistration<?> registration : registrations) {
  35             registration.unregister();
  36         }
  37     }
  38
  39 }