vpnservice/natservice/natservice-impl/src/main/java/org/opendaylight/netvirt/natservice/internal/SubnetmapListener.java

   1 /*
   2  * Copyright (c) 2016 Hewlett Packard Enterprise, Co. 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.netvirt.natservice.internal;
  10
  11 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  12 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  13 import org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.Subnetmaps;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.Subnetmap;
  16 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  17 import org.slf4j.Logger;
  18 import org.slf4j.LoggerFactory;
  19
  20 public class SubnetmapListener extends AsyncDataTreeChangeListenerBase<Subnetmap, SubnetmapListener> {
  21     private static final Logger LOG = LoggerFactory.getLogger(SubnetmapListener.class);
  22     private final DataBroker dataBroker;
  23     private final ExternalNetworkGroupInstaller externalNetworkGroupInstaller;
  24
  25     public SubnetmapListener(final DataBroker dataBroker, final ExternalNetworkGroupInstaller externalNetworkGroupInstaller) {
  26         super(Subnetmap.class, SubnetmapListener.class);
  27         this.dataBroker = dataBroker;
  28         this.externalNetworkGroupInstaller = externalNetworkGroupInstaller;
  29     }
  30
  31     public void init() {
  32         registerListener(LogicalDatastoreType.CONFIGURATION, dataBroker);
  33     }
  34
  35     @Override
  36     protected InstanceIdentifier<Subnetmap> getWildCardPath() {
  37         return InstanceIdentifier.create(Subnetmaps.class).child(Subnetmap.class);
  38     }
  39
  40     @Override
  41     protected void remove(InstanceIdentifier<Subnetmap> identifier, Subnetmap subnetmap) {
  42         LOG.trace("SubnetmapListener remove subnetmap method - key: " + identifier + ", value" + subnetmap);
  43         NatServiceCounters.subnetmap_remove.inc();
  44         externalNetworkGroupInstaller.removeExtNetGroupEntires(subnetmap);
  45     }
  46
  47     @Override
  48     protected void update(InstanceIdentifier<Subnetmap> identifier, Subnetmap subnetmapBefore, Subnetmap subnetmapAfter) {
  49         LOG.trace("SubnetmapListener update subnetmap method - key: " + identifier + ", original=" + subnetmapBefore + ", update=" + subnetmapAfter);
  50         NatServiceCounters.subnetmap_update.inc();
  51         externalNetworkGroupInstaller.installExtNetGroupEntires(subnetmapAfter);
  52     }
  53
  54     @Override
  55     protected void add(InstanceIdentifier<Subnetmap> identifier, Subnetmap subnetmap) {
  56         LOG.trace("SubnetmapListener add subnetmap method - key: " + identifier + ", value=" + subnetmap);
  57         NatServiceCounters.subnetmap_add.inc();
  58         externalNetworkGroupInstaller.installExtNetGroupEntires(subnetmap);
  59     }
  60
  61     @Override
  62     protected SubnetmapListener getDataTreeChangeListener() {
  63         return this;
  64     }
  65 }