ipv6service/impl/src/main/java/org/opendaylight/netvirt/ipv6service/NeutronNetworkChangeListener.java

   1 /*
   2  * Copyright (c) 2016, 2017 Red Hat, 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 package org.opendaylight.netvirt.ipv6service;
   9
  10 import javax.annotation.PreDestroy;
  11 import javax.inject.Inject;
  12 import javax.inject.Singleton;
  13 import org.opendaylight.infrautils.utils.concurrent.Executors;
  14 import org.opendaylight.mdsal.binding.api.DataBroker;
  15 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  16 import org.opendaylight.serviceutils.tools.listener.AbstractClusteredAsyncDataTreeChangeListener;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.mtu.ext.rev181114.NetworkMtuExtension;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.Networks;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.networks.Network;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
  21 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  22 import org.slf4j.Logger;
  23 import org.slf4j.LoggerFactory;
  24
  25 @Singleton
  26 public class NeutronNetworkChangeListener extends AbstractClusteredAsyncDataTreeChangeListener<Network> {
  27
  28     private static final Logger LOG = LoggerFactory.getLogger(NeutronNetworkChangeListener.class);
  29
  30     private final DataBroker dataBroker;
  31     private final IfMgr ifMgr;
  32
  33     @Inject
  34     public NeutronNetworkChangeListener(final DataBroker dataBroker, IfMgr ifMgr) {
  35         super(dataBroker, LogicalDatastoreType.CONFIGURATION, InstanceIdentifier.create(Neutron.class)
  36                 .child(Networks.class).child(Network.class),
  37                 Executors.newListeningSingleThreadExecutor("NeutronNetworkChangeListener", LOG));
  38         this.dataBroker = dataBroker;
  39         this.ifMgr = ifMgr;
  40     }
  41
  42     public void init() {
  43         LOG.info("{} init", getClass().getSimpleName());
  44     }
  45
  46     @Override
  47     @PreDestroy
  48     public void close() {
  49         super.close();
  50         Executors.shutdownAndAwaitTermination(getExecutorService());
  51     }
  52
  53     @Override
  54     public void add(InstanceIdentifier<Network> identifier, Network input) {
  55         int mtu = 0;
  56         LOG.debug("Add Network notification handler is invoked {} ", input);
  57         if (input.augmentation(NetworkMtuExtension.class) != null) {
  58             mtu = input.augmentation(NetworkMtuExtension.class).getMtu().toJava();
  59         }
  60         ifMgr.addNetwork(input.getUuid(), mtu);
  61     }
  62
  63     @Override
  64     public void remove(InstanceIdentifier<Network> identifier, Network input) {
  65         LOG.debug("Remove Network notification handler is invoked {} ", input);
  66         ifMgr.removeNetwork(input.getUuid());
  67     }
  68
  69     @Override
  70     public void update(InstanceIdentifier<Network> identifier, Network original, Network update) {
  71         LOG.debug("Update Network notification handler is invoked...");
  72     }
  73 }