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.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(OvsdbClientKey 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(LogicalDatastoreType.OPERATIONAL, getKey().toInstanceIndentifier());
  28         Optional<Node> ovsdbNodeOptional;
  29         try {
  30             ovsdbNodeOptional = ovsdbNodeFuture.get();
  31             if(ovsdbNodeOptional.isPresent()) {
  32                 Node ovsdbNode = ovsdbNodeOptional.get();
  33                 OvsdbNodeAugmentation ovsdbNodeAugmentation = ovsdbNode.getAugmentation(OvsdbNodeAugmentation.class);
  34                 for(ManagedNodeEntry managedNode: ovsdbNodeAugmentation.getManagedNodeEntry()) {
  35                     transaction.delete(LogicalDatastoreType.OPERATIONAL, managedNode.getBridgeRef().getValue());
  36                 }
  37                 transaction.delete(LogicalDatastoreType.OPERATIONAL, getKey().toInstanceIndentifier());
  38             }
  39         } catch (Exception e) {
  40             LOG.warn("Failure to delete ovsdbNode {}",e);
  41         }
  42     }
  43
  44 }