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;
}
}