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=ba64e29d7542ec2027c4d6f1cbabd11d54bd5af0;hb=1ddc826aa07a84f94b318499b862cafb9ae1b3c8;hp=6334bdcd0731e8e2d833cef4af0a7463c524062b;hpb=925cb4a228d0fda99c7bfeb432eb25285a223887;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 6334bdcd07..ba64e29d75 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 @@ -139,13 +139,15 @@ public class RemoteTransactionContext extends AbstractTransactionContext { batchedModifications.setReady(ready); batchedModifications.setDoCommitOnReady(doCommitOnReady); batchedModifications.setTotalMessagesSent(++totalBatchedModificationsSent); - sent = executeOperationAsync(batchedModifications, actorContext.getTransactionCommitOperationTimeout()); + final BatchedModifications toSend = batchedModifications; if (ready) { batchedModifications = null; } else { batchedModifications = newBatchedModifications(); } + + sent = executeOperationAsync(toSend, actorContext.getTransactionCommitOperationTimeout()); } return sent;