"Data format:-binding-aware or binding-independent";
}
+ leaf data-store {
+ mandatory true;
+ type enumeration {
+ enum "CONFIG" {
+ value 1;
+ }
+ enum "OPERATIONAL" {
+ value 2;
+ }
+ enum "BOTH" {
+ value 3;
+ }
+ }
+ }
leaf outerElements {
type uint32;
default 100000;
package org.opendaylight.dsbenchmark;
+import java.util.Random;
+
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
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.StartTestInput.DataStore;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public abstract class DatastoreAbstractWriter {
+ private static final Logger LOG = LoggerFactory.getLogger(DatastoreAbstractWriter.class);
+
protected final int outerListElem;
protected final int innerListElem;
protected final long writesPerTx;
protected final StartTestInput.Operation oper;
+ protected final StartTestInput.DataStore dataStore;
+ protected final Random rn = new Random();
+
protected int txOk = 0;
protected int txError = 0;
public DatastoreAbstractWriter(StartTestInput.Operation oper,
- int outerListElem, int innerListElem, long writesPerTx) {
+ int outerListElem, int innerListElem, long writesPerTx, DataStore dataStore) {
this.outerListElem = outerListElem;
this.innerListElem = innerListElem;
this.writesPerTx = writesPerTx;
this.oper = oper;
+ this.dataStore = dataStore;
+ LOG.info("DatastoreAbstractWriter created: {}", this);
}
public abstract void createList();
return txOk;
}
+ protected LogicalDatastoreType getDataStoreType() {
+ final LogicalDatastoreType dsType;
+ if (dataStore == DataStore.CONFIG) {
+ dsType = LogicalDatastoreType.CONFIGURATION;
+ }
+ else if (dataStore == DataStore.OPERATIONAL) {
+ dsType = LogicalDatastoreType.OPERATIONAL;
+ }
+ else
+ {
+ if (rn.nextInt() % 2 != 0) {
+ dsType = LogicalDatastoreType.OPERATIONAL;
+ } else {
+ dsType = LogicalDatastoreType.CONFIGURATION;
+ }
+ }
+ return dsType;
+ }
}
tx.put(LogicalDatastoreType.CONFIGURATION, TEST_EXEC_IID, data);
try {
tx.submit().checkedGet();
- LOG.info("DataStore test data cleaned up");
+ LOG.info("DataStore config test data cleaned up");
} catch (TransactionCommitFailedException e) {
- LOG.info("Failed to cleanup DataStore test data");
+ LOG.info("Failed to cleanup DataStore configtest data");
+ throw new IllegalStateException(e);
+ }
+
+ tx = dataBroker.newWriteOnlyTransaction();
+ tx.put(LogicalDatastoreType.OPERATIONAL, TEST_EXEC_IID, data);
+ try {
+ tx.submit().checkedGet();
+ LOG.info("DataStore operational test data cleaned up");
+ } catch (TransactionCommitFailedException e) {
+ LOG.info("Failed to cleanup DataStore operational test data");
throw new IllegalStateException(e);
}
StartTestInput.TransactionType txType = input.getTransactionType();
StartTestInput.Operation oper = input.getOperation();
StartTestInput.DataFormat dataFormat = input.getDataFormat();
+ StartTestInput.DataStore dataStore = input.getDataStore();
int outerListElem = input.getOuterElements().intValue();
int innerListElem = input.getInnerElements().intValue();
int writesPerTx = input.getPutsPerTx().intValue();
if (dataFormat == StartTestInput.DataFormat.BINDINGAWARE) {
if (StartTestInput.Operation.DELETE == oper) {
retVal = new SimpletxBaDelete(this.dataBroker, outerListElem,
- innerListElem,writesPerTx);
+ innerListElem,writesPerTx, dataStore);
} else if (StartTestInput.Operation.READ == oper) {
retVal = new SimpletxBaRead(this.dataBroker, outerListElem,
- innerListElem,writesPerTx);
+ innerListElem, writesPerTx, dataStore);
} else {
retVal = new SimpletxBaWrite(this.dataBroker, oper, outerListElem,
- innerListElem,writesPerTx);
+ innerListElem, writesPerTx, dataStore);
}
} else {
if (StartTestInput.Operation.DELETE == oper) {
retVal = new SimpletxDomDelete(this.domDataBroker, outerListElem,
- innerListElem, writesPerTx);
+ innerListElem, writesPerTx, dataStore);
} else if (StartTestInput.Operation.READ == oper) {
retVal = new SimpletxDomRead(this.domDataBroker, outerListElem,
- innerListElem, writesPerTx);
+ innerListElem, writesPerTx, dataStore);
} else {
retVal = new SimpletxDomWrite(this.domDataBroker, oper, outerListElem,
- innerListElem,writesPerTx);
+ innerListElem, writesPerTx, dataStore);
}
}
} else {
if (dataFormat == StartTestInput.DataFormat.BINDINGAWARE) {
if (StartTestInput.Operation.DELETE == oper) {
retVal = new TxchainBaDelete(this.bindingDataBroker, outerListElem,
- innerListElem, writesPerTx);
+ innerListElem, writesPerTx, dataStore);
} else if (StartTestInput.Operation.READ == oper) {
retVal = new TxchainBaRead(this.bindingDataBroker,outerListElem,
- innerListElem,writesPerTx);
+ innerListElem,writesPerTx, dataStore);
} else {
retVal = new TxchainBaWrite(this.bindingDataBroker, oper, outerListElem,
- innerListElem,writesPerTx);
+ innerListElem, writesPerTx, dataStore);
}
} else {
if (StartTestInput.Operation.DELETE == oper) {
retVal = new TxchainDomDelete(this.domDataBroker, outerListElem,
- innerListElem, writesPerTx);
+ innerListElem, writesPerTx, dataStore);
} else if (StartTestInput.Operation.READ == oper) {
retVal = new TxchainDomRead(this.domDataBroker, outerListElem,
- innerListElem, writesPerTx);
+ innerListElem, writesPerTx, dataStore);
} else {
retVal = new TxchainDomWrite(this.domDataBroker, oper, outerListElem,
- innerListElem,writesPerTx);
+ innerListElem,writesPerTx, dataStore);
}
}
}
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.StartTestInput.DataStore;
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;
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);
+ public SimpletxBaDelete(DataBroker dataBroker, int outerListElem, int innerListElem,
+ long writesPerTx, DataStore dataStore) {
+ super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.dataBroker = dataBroker;
LOG.info("Created SimpletxBaDelete");
}
StartTestInput.Operation.PUT,
outerListElem,
innerListElem,
- outerListElem);
+ outerListElem,
+ dataStore);
dd.createList();
dd.executeList();
}
import com.google.common.base.Optional;
import com.google.common.util.concurrent.CheckedFuture;
+
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.binding.api.ReadTransaction;
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
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.StartTestInput.DataStore;
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;
private static final Logger LOG = (Logger) LoggerFactory.getLogger(SimpletxBaRead.class);
private DataBroker dataBroker;
- public SimpletxBaRead(DataBroker dataBroker, int outerListElem, int innerListElem, long writesPerTx) {
- super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx);
+ public SimpletxBaRead(DataBroker dataBroker, int outerListElem, int innerListElem,
+ long writesPerTx, DataStore dataStore) {
+ super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.dataBroker = dataBroker;
LOG.info("Created SimpletxBaRead");
}
StartTestInput.Operation.PUT,
outerListElem,
innerListElem,
- outerListElem);
+ outerListElem,
+ dataStore);
dd.createList();
dd.executeList();
}
import org.opendaylight.dsbenchmark.BaListBuilder;
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.StartTestInput.DataStore;
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.yangtools.yang.binding.InstanceIdentifier;
private List<OuterList> list;
public SimpletxBaWrite(DataBroker dataBroker, StartTestInput.Operation oper,
- int outerListElem, int innerListElem, long writesPerTx) {
- super(oper, outerListElem, innerListElem, writesPerTx);
+ int outerListElem, int innerListElem, long writesPerTx, DataStore dataStore) {
+ super(oper, outerListElem, innerListElem, writesPerTx, dataStore);
this.dataBroker = dataBroker;
LOG.info("Created SimpletxBaWrite");
}
import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction;
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.StartTestInput.DataStore;
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.yangtools.yang.common.QName;
private final DOMDataBroker domDataBroker;
public SimpletxDomDelete(DOMDataBroker domDataBroker, int outerListElem,
- int innerListElem, long writesPerTx) {
- super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx);
+ int innerListElem, long writesPerTx, DataStore dataStore) {
+ super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
LOG.info("Created simpleTxDomDelete");
}
StartTestInput.Operation.PUT,
outerListElem,
innerListElem,
- outerListElem);
+ outerListElem,
+ dataStore);
dd.createList();
dd.executeList();
}
import com.google.common.base.Optional;
import com.google.common.util.concurrent.CheckedFuture;
+
import org.opendaylight.controller.md.sal.dom.api.DOMDataReadOnlyTransaction;
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
import org.opendaylight.controller.md.sal.dom.api.DOMDataBroker;
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.StartTestInput.DataStore;
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.yangtools.yang.common.QName;
private final DOMDataBroker domDataBroker;
public SimpletxDomRead(DOMDataBroker domDataBroker, int outerListElem,
- int innerListElem, long writesPerTx) {
- super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx);
+ int innerListElem, long writesPerTx, DataStore dataStore) {
+ super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
LOG.info("Created simpleTxDomRead");
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
SimpletxDomWrite dd = new SimpletxDomWrite(domDataBroker,
- StartTestInput.Operation.PUT,
- outerListElem,
- innerListElem,
- outerListElem);
+ StartTestInput.Operation.PUT,
+ outerListElem,
+ innerListElem,
+ outerListElem,
+ dataStore);
dd.createList();
dd.executeList();
}
import org.opendaylight.dsbenchmark.DatastoreAbstractWriter;
import org.opendaylight.dsbenchmark.DomListBuilder;
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.StartTestInput.DataStore;
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.yangtools.yang.data.api.YangInstanceIdentifier;
private List<MapEntryNode> list;
public SimpletxDomWrite(DOMDataBroker domDataBroker, StartTestInput.Operation oper,
- int outerListElem, int innerListElem, long putsPerTx ) {
- super(oper, outerListElem, innerListElem, putsPerTx);
+ int outerListElem, int innerListElem, long putsPerTx, DataStore dataStore ) {
+ super(oper, outerListElem, innerListElem, putsPerTx, dataStore);
this.domDataBroker = domDataBroker;
LOG.info("Created SimpletxDomWrite");
}
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.StartTestInput.DataStore;
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;
private static final Logger LOG = (Logger) LoggerFactory.getLogger(TxchainBaDelete.class);
private DataBroker bindingDataBroker;
- public TxchainBaDelete(DataBroker bindingDataBroker, int outerListElem, int innerListElem, long writesPerTx) {
- super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx);
+ public TxchainBaDelete(DataBroker bindingDataBroker, int outerListElem, int innerListElem, long writesPerTx, DataStore dataStore) {
+ super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.bindingDataBroker = bindingDataBroker;
LOG.info("Created TxchainBaDelete");
}
StartTestInput.Operation.PUT,
outerListElem,
innerListElem,
- outerListElem);
+ outerListElem,
+ dataStore);
dd.createList();
dd.executeList();
}
import com.google.common.base.Optional;
import com.google.common.util.concurrent.CheckedFuture;
+
import org.opendaylight.controller.md.sal.binding.api.BindingTransactionChain;
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.binding.api.ReadTransaction;
import org.opendaylight.controller.md.sal.common.api.data.*;
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.StartTestInput.DataStore;
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;
private static final Logger LOG = (Logger) LoggerFactory.getLogger(TxchainBaRead.class);
private DataBroker bindingDataBroker;
- public TxchainBaRead(DataBroker bindingDataBroker, int outerListElem, int innerListElem, long writesPerTx) {
- super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx);
+ public TxchainBaRead(DataBroker bindingDataBroker, int outerListElem, int innerListElem, long writesPerTx, DataStore dataStore) {
+ super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.bindingDataBroker = bindingDataBroker;
LOG.info("Created TxchainBaRead");
}
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
TxchainBaWrite dd = new TxchainBaWrite(bindingDataBroker,
- StartTestInput.Operation.PUT,
- outerListElem,
- innerListElem,
- outerListElem);
+ StartTestInput.Operation.PUT,
+ outerListElem,
+ innerListElem,
+ outerListElem,
+ dataStore);
dd.createList();
dd.executeList();
}
package org.opendaylight.dsbenchmark.txchain;
import java.util.List;
+import java.util.Random;
import org.opendaylight.controller.md.sal.binding.api.BindingTransactionChain;
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
import org.opendaylight.dsbenchmark.BaListBuilder;
import org.opendaylight.dsbenchmark.DatastoreAbstractWriter;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.dsbenchmark.rev150105.StartTestInput.DataStore;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.dsbenchmark.rev150105.StartTestInput.Operation;
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;
private List<OuterList> list;
public TxchainBaWrite(DataBroker bindingDataBroker, Operation oper,
- int outerListElem, int innerListElem, long writesPerTx) {
- super(oper, outerListElem, innerListElem, writesPerTx);
+ int outerListElem, int innerListElem, long writesPerTx, DataStore dataStore) {
+ super(oper, outerListElem, innerListElem, writesPerTx, dataStore);
this.bindingDataBroker = bindingDataBroker;
LOG.info("Created TxchainBaWrite");
}
BindingTransactionChain chain = bindingDataBroker.createTransactionChain(this);
WriteTransaction tx = chain.newWriteOnlyTransaction();
+ LogicalDatastoreType dsType = getDataStoreType();
for (OuterList element : this.list) {
InstanceIdentifier<OuterList> 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++;
}
});
tx = chain.newWriteOnlyTransaction();
+ dsType = getDataStoreType();
writeCnt = 0;
}
}
import org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain;
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.StartTestInput.DataStore;
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.yangtools.yang.common.QName;
private static final Logger LOG = LoggerFactory.getLogger(TxchainBaWrite.class);
private final DOMDataBroker domDataBroker;
- public TxchainDomDelete(DOMDataBroker domDataBroker, int outerListElem, int innerListElem, long writesPerTx) {
- super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx);
+ public TxchainDomDelete(DOMDataBroker domDataBroker, int outerListElem, int innerListElem,
+ long writesPerTx, DataStore dataStore) {
+ super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
LOG.info("Created TxchainDomDelete");
}
StartTestInput.Operation.PUT,
outerListElem,
innerListElem,
- outerListElem);
+ outerListElem,
+ dataStore);
dd.createList();
dd.executeList();
}
import com.google.common.base.Optional;
import com.google.common.util.concurrent.CheckedFuture;
+
import org.opendaylight.controller.md.sal.common.api.data.*;
import org.opendaylight.controller.md.sal.dom.api.DOMDataBroker;
import org.opendaylight.controller.md.sal.dom.api.DOMDataReadOnlyTransaction;
import org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain;
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.StartTestInput.DataStore;
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.yangtools.yang.common.QName;
private static final Logger LOG = LoggerFactory.getLogger(TxchainDomRead.class);
private final DOMDataBroker domDataBroker;
- public TxchainDomRead(DOMDataBroker domDataBroker, int outerListElem, int innerListElem, long writesPerTx) {
- super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx);
+ public TxchainDomRead(DOMDataBroker domDataBroker, int outerListElem, int innerListElem,
+ long writesPerTx, DataStore dataStore) {
+ super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
LOG.info("Created TxchainDomDelete");
}
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
TxchainDomWrite dd = new TxchainDomWrite(domDataBroker,
- StartTestInput.Operation.PUT,
- outerListElem,
- innerListElem,
- outerListElem);
+ StartTestInput.Operation.PUT,
+ outerListElem,
+ innerListElem,
+ outerListElem,
+ dataStore);
dd.createList();
dd.executeList();
}
import org.opendaylight.dsbenchmark.DatastoreAbstractWriter;
import org.opendaylight.dsbenchmark.DomListBuilder;
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.StartTestInput.DataStore;
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.yangtools.yang.data.api.YangInstanceIdentifier;
private List<MapEntryNode> list;
public TxchainDomWrite(DOMDataBroker domDataBroker, StartTestInput.Operation oper, int outerListElem,
- int innerListElem, long writesPerTx) {
- super(oper, outerListElem, innerListElem, writesPerTx);
+ int innerListElem, long writesPerTx, DataStore dataStore) {
+ super(oper, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
LOG.info("Created TxchainDomWrite");
}