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%2FRemoteTransactionContext.java;h=29783a6e7dd4c19cb75971e4732cb2d57e018042;hb=b90ef95072662f8a8a479b6a4bd49376a54e9fb7;hp=d0bef0000e7e1a72432f914c9e25d906196faea8;hpb=e448e4e5f1f071aa61152b2f49b239d878c0a580;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/RemoteTransactionContext.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/RemoteTransactionContext.java index d0bef0000e..29783a6e7d 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/RemoteTransactionContext.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/RemoteTransactionContext.java @@ -10,6 +10,7 @@ package org.opendaylight.controller.cluster.datastore; import akka.actor.ActorSelection; import akka.dispatch.OnComplete; +import akka.util.Timeout; import com.google.common.base.Preconditions; import com.google.common.util.concurrent.SettableFuture; import org.opendaylight.controller.cluster.datastore.identifiers.TransactionIdentifier; @@ -36,7 +37,6 @@ public class RemoteTransactionContext extends AbstractTransactionContext { private final ActorContext actorContext; private final ActorSelection actor; - private final short remoteTransactionVersion; private final OperationLimiter limiter; private BatchedModifications batchedModifications; @@ -44,11 +44,10 @@ public class RemoteTransactionContext extends AbstractTransactionContext { protected RemoteTransactionContext(TransactionIdentifier identifier, ActorSelection actor, ActorContext actorContext, short remoteTransactionVersion, OperationLimiter limiter) { - super(identifier); + super(identifier, remoteTransactionVersion); this.limiter = Preconditions.checkNotNull(limiter); this.actor = actor; this.actorContext = actorContext; - this.remoteTransactionVersion = remoteTransactionVersion; } private Future completeOperation(Future operationFuture){ @@ -64,12 +63,8 @@ public class RemoteTransactionContext extends AbstractTransactionContext { return actorContext; } - protected short getRemoteTransactionVersion() { - return remoteTransactionVersion; - } - - protected Future executeOperationAsync(SerializableMessage msg) { - return completeOperation(actorContext.executeOperationAsync(getActor(), msg.toSerializable())); + protected Future executeOperationAsync(SerializableMessage msg, Timeout timeout) { + return completeOperation(actorContext.executeOperationAsync(getActor(), msg.toSerializable(), timeout)); } @Override @@ -77,12 +72,7 @@ public class RemoteTransactionContext extends AbstractTransactionContext { LOG.debug("Tx {} closeTransaction called", getIdentifier()); TransactionContextCleanup.untrack(this); - actorContext.sendOperationAsync(getActor(), new CloseTransaction(remoteTransactionVersion).toSerializable()); - } - - @Override - public boolean supportsDirectCommit() { - return true; + actorContext.sendOperationAsync(getActor(), new CloseTransaction(getTransactionVersion()).toSerializable()); } @Override @@ -115,7 +105,8 @@ public class RemoteTransactionContext extends AbstractTransactionContext { } private BatchedModifications newBatchedModifications() { - return new BatchedModifications(getIdentifier().toString(), remoteTransactionVersion, getIdentifier().getChainId()); + return new BatchedModifications(getIdentifier().toString(), getTransactionVersion(), + getIdentifier().getChainId()); } private void batchModification(Modification modification) { @@ -151,7 +142,7 @@ public class RemoteTransactionContext extends AbstractTransactionContext { batchedModifications.setReady(ready); batchedModifications.setDoCommitOnReady(doCommitOnReady); batchedModifications.setTotalMessagesSent(++totalBatchedModificationsSent); - sent = executeOperationAsync(batchedModifications); + sent = executeOperationAsync(batchedModifications, actorContext.getTransactionCommitOperationTimeout()); if(ready) { batchedModifications = null; @@ -206,7 +197,8 @@ public class RemoteTransactionContext extends AbstractTransactionContext { } }; - Future future = executeOperationAsync(readCmd.asVersion(remoteTransactionVersion)); + Future future = executeOperationAsync(readCmd.asVersion(getTransactionVersion()), + actorContext.getOperationTimeout()); future.onComplete(onComplete, actorContext.getClientDispatcher()); }