southbound/southbound-impl/src/main/java/org/opendaylight/ovsdb/southbound/transactions/md/OvsdbNodeRemoveCommand.java

   1 package org.opendaylight.ovsdb.southbound.transactions.md;
   2
   3 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
   4 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
   5 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
   6 import org.opendaylight.ovsdb.lib.message.TableUpdates;
   7 import org.opendaylight.ovsdb.lib.schema.DatabaseSchema;
   8 import org.opendaylight.ovsdb.southbound.OvsdbConnectionInstance;
   9 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.ManagedNodeEntry;
  11 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  12 import org.slf4j.Logger;
  13 import org.slf4j.LoggerFactory;
  14
  15 import com.google.common.base.Optional;
  16 import com.google.common.util.concurrent.CheckedFuture;
  17
  18 public class OvsdbNodeRemoveCommand extends AbstractTransactionCommand {
  19     private static final Logger LOG = LoggerFactory.getLogger(OvsdbNodeRemoveCommand.class);
  20
  21     public OvsdbNodeRemoveCommand(OvsdbConnectionInstance key,TableUpdates updates,DatabaseSchema dbSchema) {
  22         super(key,updates,dbSchema);
  23     }
  24
  25     @Override
  26     public void execute(ReadWriteTransaction transaction) {
  27         CheckedFuture<Optional<Node>, ReadFailedException> ovsdbNodeFuture = transaction.read(
  28                 LogicalDatastoreType.OPERATIONAL, getOvsdbConnectionInstance().getInstanceIdentifier());
  29         Optional<Node> ovsdbNodeOptional;
  30         try {
  31             ovsdbNodeOptional = ovsdbNodeFuture.get();
  32             if (ovsdbNodeOptional.isPresent()) {
  33                 Node ovsdbNode = ovsdbNodeOptional.get();
  34                 OvsdbNodeAugmentation ovsdbNodeAugmentation = ovsdbNode.getAugmentation(OvsdbNodeAugmentation.class);
  35                 if (ovsdbNodeAugmentation != null && ovsdbNodeAugmentation.getManagedNodeEntry() != null) {
  36                     for (ManagedNodeEntry managedNode : ovsdbNodeAugmentation.getManagedNodeEntry()) {
  37                         transaction.delete(LogicalDatastoreType.OPERATIONAL, managedNode.getBridgeRef().getValue());
  38                     }
  39                 } else {
  40                     LOG.warn("{} had no OvsdbNodeAugmentation", ovsdbNode);
  41                 }
  42                 transaction.delete(LogicalDatastoreType.OPERATIONAL,
  43                         getOvsdbConnectionInstance().getInstanceIdentifier());
  44             }
  45         } catch (Exception e) {
  46             LOG.warn("Failure to delete ovsdbNode {}",e);
  47         }
  48     }
  49
  50 }