nemo-renderers/openflow-renderer/src/main/java/org/opendaylight/nemo/renderer/openflow/physicalnetwork/OFLinkListener.java

   1 /*
   2  * Copyright (c) 2015 Huawei, 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
   9 package org.opendaylight.nemo.renderer.openflow.physicalnetwork;
  10
  11 import java.util.Collection;
  12 import org.opendaylight.controller.md.sal.binding.api.DataObjectModification;
  13 import org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener;
  14 import org.opendaylight.controller.md.sal.binding.api.DataTreeModification;
  15 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Link;
  16 import org.slf4j.Logger;
  17 import org.slf4j.LoggerFactory;
  18
  19 /**
  20  * Created by hj on 11/5/15.
  21  */
  22 public class OFLinkListener implements DataTreeChangeListener<Link> {
  23     private static final Logger log = LoggerFactory.getLogger(OFLinkListener.class);
  24     final private PhysicalNetworkAdapter pnConverter;
  25
  26     protected OFLinkListener(PhysicalNetworkAdapter pnConverter) {
  27         this.pnConverter = pnConverter;
  28     }
  29
  30     @Override
  31     public void onDataTreeChanged(Collection<DataTreeModification<Link>> changes) {
  32         for (DataTreeModification<Link> change: changes) {
  33             DataObjectModification<Link> rootNode = change.getRootNode();
  34             switch (rootNode.getModificationType()) {
  35                 case WRITE:
  36                 case SUBTREE_MODIFIED:
  37                     final Link updatedLink = rootNode.getDataAfter();
  38                     log.debug("OF link updated:{}", updatedLink.getKey());
  39                     pnConverter.ofLinkAdded(updatedLink);
  40                     break;
  41                 case DELETE:
  42                     final Link deletedLink = rootNode.getDataBefore();
  43                     log.debug("OF link removed:{}", deletedLink.getKey());
  44                     pnConverter.ofLinkRemoved(deletedLink);
  45                     break;
  46                 default:
  47                     break;
  48             }
  49         }
  50     }
  51 }