X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=benchmark%2Fdsbenchmark%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fdsbenchmark%2Fsimpletx%2FSimpletxBaDelete.java;h=a165ea0a03b442f1708a0fdecb2a79d403dd49c0;hb=cd184f0a4226f20838c72ac1fdaf6fa19585df3b;hp=4d67d4c90a7e99c9bd1d2407182ea1a407741eb6;hpb=625723b875800d5c421061f09cd5f387ccb59e62;p=controller.git diff --git a/benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/simpletx/SimpletxBaDelete.java b/benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/simpletx/SimpletxBaDelete.java index 4d67d4c90a..a165ea0a03 100644 --- a/benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/simpletx/SimpletxBaDelete.java +++ b/benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/simpletx/SimpletxBaDelete.java @@ -25,18 +25,18 @@ import org.slf4j.LoggerFactory; public class SimpletxBaDelete extends DatastoreAbstractWriter { private static final Logger LOG = LoggerFactory.getLogger(SimpletxBaDelete.class); - private DataBroker dataBroker; + private final DataBroker dataBroker; - public SimpletxBaDelete(DataBroker dataBroker, int outerListElem, int innerListElem, - long writesPerTx, DataStore dataStore) { + public SimpletxBaDelete(final DataBroker dataBroker, final int outerListElem, final int innerListElem, + final long writesPerTx, final DataStore dataStore) { super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore); this.dataBroker = dataBroker; - LOG.info("Created SimpletxBaDelete"); + LOG.debug("Created SimpletxBaDelete"); } @Override public void createList() { - LOG.info("DatastoreDelete: creating data in the data store"); + LOG.debug("DatastoreDelete: creating data in the data store"); // Dump the whole list into the data store in a single transaction // with PUTs on the transaction SimpletxBaWrite dd = new SimpletxBaWrite(dataBroker, @@ -51,19 +51,21 @@ public class SimpletxBaDelete extends DatastoreAbstractWriter { @Override public void executeList() { + final LogicalDatastoreType dsType = getDataStoreType(); + WriteTransaction tx = dataBroker.newWriteOnlyTransaction(); long putCnt = 0; for (long l = 0; l < outerListElem; l++) { InstanceIdentifier iid = InstanceIdentifier.create(TestExec.class) .child(OuterList.class, new OuterListKey((int)l)); - tx.delete(LogicalDatastoreType.CONFIGURATION, iid); + tx.delete(dsType, iid); putCnt++; if (putCnt == writesPerTx) { try { tx.submit().checkedGet(); txOk++; - } catch (TransactionCommitFailedException e) { + } catch (final TransactionCommitFailedException e) { LOG.error("Transaction failed: {}", e); txError++; } @@ -74,7 +76,7 @@ public class SimpletxBaDelete extends DatastoreAbstractWriter { if (putCnt != 0) { try { tx.submit().checkedGet(); - } catch (TransactionCommitFailedException e) { + } catch (final TransactionCommitFailedException e) { LOG.error("Transaction failed: {}", e); } }