X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FLocalTransactionContext.java;h=0cdb6ab38f8edda806e1e6406a75803c8c54ba06;hb=d6a2de22e12b36ac43cfc5f68e62331ec1194b83;hp=76bafb75d3003a911f1b1207f55a919b0c08e2f0;hpb=621482f62c83ca4e53468bf3f61656628862cc8c;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/LocalTransactionContext.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/LocalTransactionContext.java index 76bafb75d3..0cdb6ab38f 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/LocalTransactionContext.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/LocalTransactionContext.java @@ -44,7 +44,7 @@ abstract class LocalTransactionContext extends AbstractTransactionContext { @Override @SuppressWarnings("checkstyle:IllegalCatch") - public void executeModification(AbstractModification modification) { + public void executeModification(final AbstractModification modification, final Boolean havePermit) { incrementModificationCount(); if (operationError == null) { try { @@ -56,7 +56,8 @@ abstract class LocalTransactionContext extends AbstractTransactionContext { } @Override - public void executeRead(AbstractRead readCmd, final SettableFuture proxyFuture) { + public void executeRead(final AbstractRead readCmd, final SettableFuture proxyFuture, + final Boolean havePermit) { Futures.addCallback(readCmd.apply(getReadDelegate()), new FutureCallback() { @Override public void onSuccess(final T result) { @@ -76,13 +77,13 @@ abstract class LocalTransactionContext extends AbstractTransactionContext { } @Override - public Future readyTransaction() { + public Future readyTransaction(final Boolean havePermit) { final LocalThreePhaseCommitCohort cohort = ready(); return cohort.initiateCoordinatedCommit(); } @Override - public Future directCommit() { + public Future directCommit(final Boolean havePermit) { final LocalThreePhaseCommitCohort cohort = ready(); return cohort.initiateDirectCommit(); }