Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fixup Augmentable and Identifiable methods changing
[controller.git]
/
benchmark
/
dsbenchmark
/
src
/
main
/
java
/
org
/
opendaylight
/
dsbenchmark
/
txchain
/
TxchainBaWrite.java
diff --git
a/benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/txchain/TxchainBaWrite.java
b/benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/txchain/TxchainBaWrite.java
index a0327a97029d2a4c0dbe68088bcf2bdd56d6afe6..b36404d52c848e5f51321bc7c6651d994c39882c 100644
(file)
--- a/
benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/txchain/TxchainBaWrite.java
+++ b/
benchmark/dsbenchmark/src/main/java/org/opendaylight/dsbenchmark/txchain/TxchainBaWrite.java
@@
-10,6
+10,7
@@
package org.opendaylight.dsbenchmark.txchain;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.MoreExecutors;
import java.util.List;
import org.opendaylight.controller.md.sal.binding.api.BindingTransactionChain;
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import java.util.List;
import org.opendaylight.controller.md.sal.binding.api.BindingTransactionChain;
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
@@
-58,7
+59,7
@@
public class TxchainBaWrite extends DatastoreAbstractWriter implements Transacti
for (OuterList element : this.list) {
InstanceIdentifier<OuterList> iid = InstanceIdentifier.create(TestExec.class)
for (OuterList element : this.list) {
InstanceIdentifier<OuterList> iid = InstanceIdentifier.create(TestExec.class)
- .child(OuterList.class, element.
getK
ey());
+ .child(OuterList.class, element.
k
ey());
if (oper == StartTestInput.Operation.PUT) {
tx.put(dsType, iid, element);
if (oper == StartTestInput.Operation.PUT) {
tx.put(dsType, iid, element);
@@
-81,7
+82,7
@@
public class TxchainBaWrite extends DatastoreAbstractWriter implements Transacti
LOG.error("Transaction failed, {}", t);
txError++;
}
LOG.error("Transaction failed, {}", t);
txError++;
}
- });
+ }
, MoreExecutors.directExecutor()
);
tx = chain.newWriteOnlyTransaction();
writeCnt = 0;
}
tx = chain.newWriteOnlyTransaction();
writeCnt = 0;
}
@@
-103,7
+104,7
@@
public class TxchainBaWrite extends DatastoreAbstractWriter implements Transacti
} catch (final IllegalStateException e) {
LOG.error("Transaction close failed,", e);
}
} catch (final IllegalStateException e) {
LOG.error("Transaction close failed,", e);
}
- LOG.debug("Transactions: submitted {}, completed {}", txSubmitted,
(txOk + txError)
);
+ LOG.debug("Transactions: submitted {}, completed {}", txSubmitted,
txOk + txError
);
}
@Override
}
@Override