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.SouthboundMapper;
   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.ConnectionInfo;
  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 extends AbstractTransactionCommand {
  20     private static final Logger LOG = LoggerFactory.getLogger(OvsdbNodeRemoveCommand.class);
  21
  22     public OvsdbNodeRemoveCommand(ConnectionInfo key,TableUpdates updates,DatabaseSchema dbSchema) {
  23         super(key,updates,dbSchema);
  24     }
  25
  26     @Override
  27     public void execute(ReadWriteTransaction transaction) {
  28         CheckedFuture<Optional<Node>, ReadFailedException> ovsdbNodeFuture = transaction.read(
  29                 LogicalDatastoreType.OPERATIONAL, SouthboundMapper.createInstanceIdentifier(getConnectionInfo()));
  30         Optional<Node> ovsdbNodeOptional;
  31         try {
  32             ovsdbNodeOptional = ovsdbNodeFuture.get();
  33             if (ovsdbNodeOptional.isPresent()) {
  34                 Node ovsdbNode = ovsdbNodeOptional.get();
  35                 OvsdbNodeAugmentation ovsdbNodeAugmentation = ovsdbNode.getAugmentation(OvsdbNodeAugmentation.class);
  36                 if (ovsdbNodeAugmentation != null && ovsdbNodeAugmentation.getManagedNodeEntry() != null) {
  37                     for (ManagedNodeEntry managedNode : ovsdbNodeAugmentation.getManagedNodeEntry()) {
  38                         transaction.delete(LogicalDatastoreType.OPERATIONAL, managedNode.getBridgeRef().getValue());
  39                     }
  40                 } else {
  41                     LOG.warn("{} had no OvsdbNodeAugmentation", ovsdbNode);
  42                 }
  43                 transaction.delete(LogicalDatastoreType.OPERATIONAL,
  44                         SouthboundMapper.createInstanceIdentifier(getConnectionInfo()));
  45             }
  46         } catch (Exception e) {
  47             LOG.warn("Failure to delete ovsdbNode {}",e);
  48         }
  49     }
  50
  51 }