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%2Fmessages%2FBatchedModifications.java;h=f95473f8a6b3edbdd5ed6cfb5dbe7ad789f55593;hb=9302c5052c431ae2add87d4e14a68570ef7604ec;hp=86f96f57d0f3cb0c284a1a902bd820baaac9e82d;hpb=fe45ad923c8cf83d730cf4d576c310967afabdf3;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/BatchedModifications.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/BatchedModifications.java index 86f96f57d0..f95473f8a6 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/BatchedModifications.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/BatchedModifications.java @@ -22,6 +22,7 @@ public class BatchedModifications extends MutableCompositeModification implement private static final long serialVersionUID = 1L; private boolean ready; + private boolean doCommitOnReady; private int totalMessagesSent; private String transactionID; private String transactionChainID; @@ -43,6 +44,14 @@ public class BatchedModifications extends MutableCompositeModification implement this.ready = ready; } + public boolean isDoCommitOnReady() { + return doCommitOnReady; + } + + public void setDoCommitOnReady(boolean doCommitOnReady) { + this.doCommitOnReady = doCommitOnReady; + } + public int getTotalMessagesSent() { return totalMessagesSent; } @@ -66,6 +75,7 @@ public class BatchedModifications extends MutableCompositeModification implement transactionChainID = in.readUTF(); ready = in.readBoolean(); totalMessagesSent = in.readInt(); + doCommitOnReady = in.readBoolean(); } @Override @@ -75,6 +85,7 @@ public class BatchedModifications extends MutableCompositeModification implement out.writeUTF(transactionChainID); out.writeBoolean(ready); out.writeInt(totalMessagesSent); + out.writeBoolean(doCommitOnReady); } @Override