Added the data store benchmark (dsbenchmark, Bug 4519, https://bugs.opendaylight...

[controller.git] / benchmark / dsbenchmark / src / main / java / org / opendaylight / dsbenchmark / simpletx / SimpletxBaDelete.java

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
new file mode 100644 (file)
index 0000000..976623f
--- /dev/null
+++ b/benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/simpletx/SimpletxBaDelete.java
@@ -0,0 +1,79 @@
+/*
+ * Copyright (c) 2015 Cisco Systems and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.dsbenchmark.simpletx;
+
+
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
+import org.opendaylight.dsbenchmark.DatastoreAbstractWriter;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.dsbenchmark.rev150105.StartTestInput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.dsbenchmark.rev150105.TestExec;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.dsbenchmark.rev150105.test.exec.OuterList;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.dsbenchmark.rev150105.test.exec.OuterListKey;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SimpletxBaDelete extends DatastoreAbstractWriter {
+    private static final Logger LOG = (Logger) LoggerFactory.getLogger(SimpletxBaDelete.class);
+    private DataBroker dataBroker;
+
+    public SimpletxBaDelete(DataBroker dataBroker, int outerListElem, int innerListElem, long writesPerTx) {
+        super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx);
+        this.dataBroker = dataBroker;
+        LOG.info("Created SimpletxBaDelete");
+    }
+
+    @Override
+    public void createList() {
+        LOG.info("DatastoreDelete: creating data in the data store");
+        // Dump the whole list into the data store in a single transaction
+        // with <outerListElem> PUTs on the transaction
+        SimpletxBaWrite dd = new SimpletxBaWrite(dataBroker,
+                                                 StartTestInput.Operation.PUT,
+                                                 outerListElem,
+                                                 innerListElem,
+                                                 outerListElem);
+        dd.createList();
+        dd.executeList();
+    }
+
+    @Override
+    public void executeList() {
+            WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
+            long putCnt = 0;
+
+            for (long l = 0; l < outerListElem; l++) {
+                InstanceIdentifier<OuterList> iid = InstanceIdentifier.create(TestExec.class)
+                                                        .child(OuterList.class, new OuterListKey((int)l));
+                tx.delete(LogicalDatastoreType.CONFIGURATION, iid);
+                putCnt++;
+                if (putCnt == writesPerTx) {
+                    try {
+                        tx.submit().checkedGet();
+                        txOk++;
+                    } catch (TransactionCommitFailedException e) {
+                        LOG.error("Transaction failed: {}", e.toString());
+                        txError++;
+                    }
+                    tx = dataBroker.newWriteOnlyTransaction();
+                    putCnt = 0;
+                }
+            }
+            if (putCnt != 0) {
+                try {
+                    tx.submit().checkedGet();
+                } catch (TransactionCommitFailedException e) {
+                    LOG.error("Transaction failed: {}", e.toString());
+                }
+            }
+    }
+}