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.OvsdbClientKey;
   9 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeRef;
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.ManagedNodeEntry;
  12 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  13 import org.slf4j.Logger;
  14 import org.slf4j.LoggerFactory;
  15
  16 import com.google.common.base.Optional;
  17 import com.google.common.util.concurrent.CheckedFuture;
  18
  19 public class OvsdbNodeRemoveCommand implements TransactionCommand {
  20     private static final Logger LOG = LoggerFactory.getLogger(OvsdbNodeRemoveCommand.class);
  21
  22     private OvsdbClientKey key;
  23
  24     public OvsdbNodeRemoveCommand(OvsdbClientKey key,TableUpdates updates,DatabaseSchema dbSchema) {
  25         this.key = key;
  26     }
  27
  28     @Override
  29     public void execute(ReadWriteTransaction transaction) {
  30         CheckedFuture<Optional<Node>, ReadFailedException> ovsdbNodeFuture = transaction.read(LogicalDatastoreType.OPERATIONAL, key.toInstanceIndentifier());
  31         Optional<Node> ovsdbNodeOptional;
  32         try {
  33             ovsdbNodeOptional = ovsdbNodeFuture.get();
  34             if(ovsdbNodeOptional.isPresent()) {
  35                 Node ovsdbNode = ovsdbNodeOptional.get();
  36                 OvsdbNodeAugmentation ovsdbNodeAugmentation = ovsdbNode.getAugmentation(OvsdbNodeAugmentation.class);
  37                 for(ManagedNodeEntry managedNode: ovsdbNodeAugmentation.getManagedNodeEntry()) {
  38                     transaction.delete(LogicalDatastoreType.OPERATIONAL, managedNode.getBridgeRef().getValue());
  39                 }
  40                 transaction.delete(LogicalDatastoreType.OPERATIONAL, key.toInstanceIndentifier());
  41             }
  42         } catch (Exception e) {
  43             LOG.warn("Failure to delete ovsdbNode {}",e);
  44         }
  45     }
  46
  47 }