X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=benchmark%2Fdsbenchmark%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fdsbenchmark%2Fsimpletx%2FSimpletxBaWrite.java;fp=benchmark%2Fdsbenchmark%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fdsbenchmark%2Fsimpletx%2FSimpletxBaWrite.java;h=f0a0ba895a1a3bfead70beb78f4d613250ca63d3;hp=5357311e40a8704906f3aa33c10ef9a9458dab64;hb=fdc97fc0d771dcf17616282bc942b05243182a5a;hpb=9e525899b4f66248ac4efac0a70cf0dc74305f95 diff --git a/benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/simpletx/SimpletxBaWrite.java b/benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/simpletx/SimpletxBaWrite.java index 5357311e40..f0a0ba895a 100644 --- a/benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/simpletx/SimpletxBaWrite.java +++ b/benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/simpletx/SimpletxBaWrite.java @@ -44,15 +44,17 @@ public class SimpletxBaWrite extends DatastoreAbstractWriter { @Override public void executeList() { WriteTransaction tx = dataBroker.newWriteOnlyTransaction(); + LogicalDatastoreType dsType = getDataStoreType(); + long writeCnt = 0; for (OuterList element : this.list) { InstanceIdentifier iid = InstanceIdentifier.create(TestExec.class) .child(OuterList.class, element.getKey()); if (oper == StartTestInput.Operation.PUT) { - tx.put(LogicalDatastoreType.CONFIGURATION, iid, element); + tx.put(dsType, iid, element); } else { - tx.merge(LogicalDatastoreType.CONFIGURATION, iid, element); + tx.merge(dsType, iid, element); } writeCnt++; @@ -66,6 +68,8 @@ public class SimpletxBaWrite extends DatastoreAbstractWriter { txError++; } tx = dataBroker.newWriteOnlyTransaction(); + dsType = getDataStoreType(); + writeCnt = 0; } }