import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
+import java.util.concurrent.ExecutionException;
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
import org.opendaylight.openflowplugin.common.txchain.TransactionChainManager;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.FlowTopologyDiscoveryListener;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.LinkDiscovered;
try {
// read that checks if link exists (if we do not do this we might get an exception on delete)
linkOptional = manager.readFromTransaction(LogicalDatastoreType.OPERATIONAL,
- TopologyManagerUtil.linkPath(toTopologyLink(notification), iiToTopology)).checkedGet();
- } catch (ReadFailedException e) {
+ TopologyManagerUtil.linkPath(toTopologyLink(notification), iiToTopology)).get();
+ } catch (InterruptedException | ExecutionException e) {
LOG.warn("Error occurred when trying to read Link: {}", e.getMessage());
LOG.debug("Error occurred when trying to read Link.. ", e);
}
if (linkOptional.isPresent()) {
- manager.addDeleteOperationTotTxChain(LogicalDatastoreType.OPERATIONAL,
+ manager.addDeleteOperationToTxChain(LogicalDatastoreType.OPERATIONAL,
TopologyManagerUtil.linkPath(toTopologyLink(notification), iiToTopology));
}
}