X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FLocalTransactionContext.java;h=8c4dddc565d27aab4943e3ef61d99ce7d166e0f7;hp=9fad1f1016bd3e3e33af2566cc0defef2121cee9;hb=123afd8b015173c459f4937c84eb2e91286f65a8;hpb=6602310b78b5bf54899456e2efa867d116731267 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 9fad1f1016..8c4dddc565 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 @@ -45,7 +45,7 @@ abstract class LocalTransactionContext extends AbstractTransactionContext { @Override @SuppressWarnings("checkstyle:IllegalCatch") - public void executeModification(final AbstractModification modification) { + public void executeModification(final AbstractModification modification, final Boolean havePermit) { incrementModificationCount(); if (operationError == null) { try { @@ -57,7 +57,8 @@ abstract class LocalTransactionContext extends AbstractTransactionContext { } @Override - public void executeRead(final 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) { @@ -77,13 +78,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(); }