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.PostConstruct;
  11 import javax.inject.Inject;
  12 import javax.inject.Singleton;
  13 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  14 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  15 import org.opendaylight.genius.datastoreutils.AsyncClusteredDataTreeChangeListenerBase;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.Networks;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.networks.Network;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
  19 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  20 import org.slf4j.Logger;
  21 import org.slf4j.LoggerFactory;
  22
  23 @Singleton
  24 public class NeutronNetworkChangeListener extends AsyncClusteredDataTreeChangeListenerBase<Network,
  25         NeutronNetworkChangeListener> {
  26
  27     private static final Logger LOG = LoggerFactory.getLogger(NeutronNetworkChangeListener.class);
  28
  29     private final DataBroker dataBroker;
  30     private final IfMgr ifMgr;
  31
  32     @Inject
  33     public NeutronNetworkChangeListener(final DataBroker dataBroker, IfMgr ifMgr) {
  34         this.dataBroker = dataBroker;
  35         this.ifMgr = ifMgr;
  36     }
  37
  38     @PostConstruct
  39     public void init() {
  40         LOG.info("{} init", getClass().getSimpleName());
  41         registerListener(LogicalDatastoreType.CONFIGURATION, dataBroker);
  42     }
  43
  44     @Override
  45     protected InstanceIdentifier<Network> getWildCardPath() {
  46         return InstanceIdentifier.create(Neutron.class).child(Networks.class).child(Network.class);
  47     }
  48
  49     @Override
  50     protected void add(InstanceIdentifier<Network> identifier, Network input) {
  51         LOG.debug("Add Network notification handler is invoked {} ", input);
  52         ifMgr.addNetwork(input.getUuid());
  53     }
  54
  55     @Override
  56     protected void remove(InstanceIdentifier<Network> identifier, Network input) {
  57         LOG.debug("Remove Network notification handler is invoked {} ", input);
  58         ifMgr.removeNetwork(input.getUuid());
  59     }
  60
  61     @Override
  62     protected void update(InstanceIdentifier<Network> identifier, Network original, Network update) {
  63         LOG.debug("Update Network notification handler is invoked...");
  64     }
  65
  66     /* (non-Javadoc)
  67      * @see org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase#getDataTreeChangeListener()
  68      */
  69     @Override
  70     protected NeutronNetworkChangeListener getDataTreeChangeListener() {
  71         return NeutronNetworkChangeListener.this;
  72     }
  73
  74 }