2 * Copyright (c) 2016 Hewlett Packard Enterprise, Co. and others. All rights reserved.
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
9 package org.opendaylight.netvirt.natservice.internal;
11 import javax.annotation.PreDestroy;
12 import javax.inject.Inject;
13 import javax.inject.Singleton;
14 import org.opendaylight.infrautils.utils.concurrent.Executors;
15 import org.opendaylight.mdsal.binding.api.DataBroker;
16 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
17 import org.opendaylight.serviceutils.tools.listener.AbstractAsyncDataTreeChangeListener;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.Subnetmaps;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.Subnetmap;
20 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
21 import org.slf4j.Logger;
22 import org.slf4j.LoggerFactory;
25 public class SubnetmapListener extends AbstractAsyncDataTreeChangeListener<Subnetmap> {
26 private static final Logger LOG = LoggerFactory.getLogger(SubnetmapListener.class);
27 private final DataBroker dataBroker;
28 private final ExternalNetworkGroupInstaller externalNetworkGroupInstaller;
29 private final NatServiceCounters natServiceCounters;
32 public SubnetmapListener(final DataBroker dataBroker,
33 final ExternalNetworkGroupInstaller externalNetworkGroupInstaller,
34 NatServiceCounters natServiceCounters) {
35 super(dataBroker, LogicalDatastoreType.CONFIGURATION,
36 InstanceIdentifier.create(Subnetmaps.class).child(Subnetmap.class),
37 Executors.newListeningSingleThreadExecutor("SubnetmapListener", LOG));
38 this.dataBroker = dataBroker;
39 this.externalNetworkGroupInstaller = externalNetworkGroupInstaller;
40 this.natServiceCounters = natServiceCounters;
44 LOG.info("{} init", getClass().getSimpleName());
51 Executors.shutdownAndAwaitTermination(getExecutorService());
55 public void remove(InstanceIdentifier<Subnetmap> identifier, Subnetmap subnetmap) {
56 LOG.trace("remove key: {} value: {}", subnetmap.key(), subnetmap);
57 natServiceCounters.subnetmapRemove();
58 externalNetworkGroupInstaller.removeExtNetGroupEntries(subnetmap);
62 public void update(InstanceIdentifier<Subnetmap> identifier,
63 Subnetmap subnetmapBefore, Subnetmap subnetmapAfter) {
64 LOG.trace("update key: {}, original: {}, update: {}", subnetmapAfter.key(), subnetmapBefore, subnetmapAfter);
65 natServiceCounters.subnetmapUpdate();
66 externalNetworkGroupInstaller.installExtNetGroupEntries(subnetmapAfter);
70 public void add(InstanceIdentifier<Subnetmap> identifier, Subnetmap subnetmap) {
71 LOG.trace("add key: {} value: {}", subnetmap.key(), subnetmap);
72 natServiceCounters.subnetmapAdd();
73 externalNetworkGroupInstaller.installExtNetGroupEntries(subnetmap);