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=11e722671c6dc194761471038a4e3ca5f7fd8970;hp=86f96f57d0f3cb0c284a1a902bd820baaac9e82d;hpb=9f1061c46af5220ad95d8d0b94411ba2fd832a50;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