southbound/southbound-impl/src/main/java/org/opendaylight/ovsdb/southbound/ovsdb/transact/BridgeOperationalState.java

   1 /*
   2  * Copyright (c) 2015 Cisco Systems, 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.ovsdb.southbound.ovsdb.transact;
  10
  11 import java.util.Collection;
  12 import java.util.Optional;
  13
  14 import org.opendaylight.mdsal.binding.api.DataBroker;
  15 import org.opendaylight.mdsal.binding.api.DataTreeModification;
  16 import org.opendaylight.mdsal.binding.api.ReadTransaction;
  17 import org.opendaylight.ovsdb.southbound.SouthboundUtil;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentation;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ControllerEntry;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ControllerEntryKey;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ProtocolEntry;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ProtocolEntryKey;
  24 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  25 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
  26 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPointKey;
  27 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  28 import org.slf4j.Logger;
  29 import org.slf4j.LoggerFactory;
  30
  31 public class BridgeOperationalState {
  32     private static final Logger LOG = LoggerFactory.getLogger(BridgeOperationalState.class);
  33     private DataBroker db;
  34
  35     public BridgeOperationalState(DataBroker db, DataChangeEvent changes) {
  36         this.db = db;
  37     }
  38
  39     public BridgeOperationalState(DataBroker db, Collection<DataTreeModification<Node>> changes) {
  40         this.db = db;
  41     }
  42
  43     @SuppressWarnings("IllegalCatch")
  44     public Optional<Node> getBridgeNode(InstanceIdentifier<?> iid) {
  45         InstanceIdentifier<Node> nodeIid = iid.firstIdentifierOf(Node.class);
  46         Optional<Node> bridgeNode = Optional.empty();
  47         try (ReadTransaction transaction = db.newReadOnlyTransaction()) {
  48             bridgeNode = SouthboundUtil.readNode(transaction, nodeIid);
  49         } catch (Exception exp) {
  50             LOG.error("Error in getting the brideNode for {}", iid, exp);
  51         }
  52         return bridgeNode;
  53     }
  54
  55     public Optional<OvsdbBridgeAugmentation> getOvsdbBridgeAugmentation(InstanceIdentifier<?> iid) {
  56         Optional<Node> nodeOptional = getBridgeNode(iid);
  57         if (nodeOptional.isPresent()) {
  58             return Optional.ofNullable(nodeOptional.get().augmentation(OvsdbBridgeAugmentation.class));
  59         }
  60         return Optional.empty();
  61     }
  62
  63     public Optional<TerminationPoint> getBridgeTerminationPoint(InstanceIdentifier<?> iid) {
  64         if (iid != null) {
  65             Optional<Node> nodeOptional = getBridgeNode(iid);
  66             if (nodeOptional.isPresent() && nodeOptional.get().getTerminationPoint() != null) {
  67                 TerminationPointKey key = iid.firstKeyOf(TerminationPoint.class);
  68                 if (key != null) {
  69                     for (TerminationPoint tp:nodeOptional.get().getTerminationPoint()) {
  70                         if (tp.key().equals(key)) {
  71                             return Optional.of(tp);
  72                         }
  73                     }
  74                 }
  75             } else {
  76                 LOG.debug("TerminationPoints or Operational BridgeNode missing for {}", iid);
  77             }
  78         }
  79         return Optional.empty();
  80     }
  81
  82     public Optional<OvsdbTerminationPointAugmentation> getOvsdbTerminationPointAugmentation(InstanceIdentifier<?> iid) {
  83         Optional<TerminationPoint> tpOptional = getBridgeTerminationPoint(iid);
  84         if (tpOptional.isPresent()) {
  85             return Optional.ofNullable(tpOptional.get().augmentation(OvsdbTerminationPointAugmentation.class));
  86         }
  87         return Optional.empty();
  88     }
  89
  90     public Optional<ControllerEntry> getControllerEntry(InstanceIdentifier<?> iid) {
  91         if (iid != null) {
  92             Optional<OvsdbBridgeAugmentation> ovsdbBridgeOptional = getOvsdbBridgeAugmentation(iid);
  93             if (ovsdbBridgeOptional.isPresent() && ovsdbBridgeOptional.get().getControllerEntry() != null) {
  94                 ControllerEntryKey key = iid.firstKeyOf(ControllerEntry.class);
  95                 if (key != null) {
  96                     for (ControllerEntry entry: ovsdbBridgeOptional.get().getControllerEntry()) {
  97                         if (entry.key().equals(key)) {
  98                             return Optional.of(entry);
  99                         }
 100                     }
 101                 }
 102             }
 103         }
 104         return Optional.empty();
 105     }
 106
 107     public Optional<ProtocolEntry> getProtocolEntry(InstanceIdentifier<ProtocolEntry> iid) {
 108         if (iid != null) {
 109             Optional<OvsdbBridgeAugmentation> ovsdbBridgeOptional = getOvsdbBridgeAugmentation(iid);
 110             if (ovsdbBridgeOptional.isPresent() && ovsdbBridgeOptional.get().getProtocolEntry() != null) {
 111                 ProtocolEntryKey key = iid.firstKeyOf(ProtocolEntry.class);
 112                 if (key != null) {
 113                     for (ProtocolEntry entry: ovsdbBridgeOptional.get().getProtocolEntry()) {
 114                         if (entry.key().equals(key)) {
 115                             return Optional.of(entry);
 116                         }
 117                     }
 118                 }
 119             }
 120         }
 121         return Optional.empty();
 122     }
 123
 124 }