Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Merge "BUG 3057 - notify added event source by topics created before"
[controller.git]
/
opendaylight
/
md-sal
/
sal-distributed-datastore
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
datastore
/
messages
/
ForwardedReadyTransaction.java
diff --git
a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ForwardedReadyTransaction.java
b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ForwardedReadyTransaction.java
index 4f8ea51f784ea2e0352eb6aedd8d1dc35469f0ef..2f48ab9d1be137562f170d354e7580b74e6b7da6 100644
(file)
--- a/
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ForwardedReadyTransaction.java
+++ b/
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ForwardedReadyTransaction.java
@@
-7,8
+7,8
@@
*/
package org.opendaylight.controller.cluster.datastore.messages;
*/
package org.opendaylight.controller.cluster.datastore.messages;
+import org.opendaylight.controller.cluster.datastore.ShardDataTreeCohort;
import org.opendaylight.controller.cluster.datastore.modification.Modification;
import org.opendaylight.controller.cluster.datastore.modification.Modification;
-import org.opendaylight.controller.sal.core.spi.data.DOMStoreThreePhaseCommitCohort;
/**
* Transaction ReadyTransaction message that is forwarded to the local Shard from the ShardTransaction.
/**
* Transaction ReadyTransaction message that is forwarded to the local Shard from the ShardTransaction.
@@
-17,25
+17,44
@@
import org.opendaylight.controller.sal.core.spi.data.DOMStoreThreePhaseCommitCoh
*/
public class ForwardedReadyTransaction {
private final String transactionID;
*/
public class ForwardedReadyTransaction {
private final String transactionID;
- private final
DOMStoreThreePhaseCommit
Cohort cohort;
+ private final
ShardDataTree
Cohort cohort;
private final Modification modification;
private final Modification modification;
+ private final boolean returnSerialized;
+ private final boolean doImmediateCommit;
+ private final short txnClientVersion;
- public ForwardedReadyTransaction(String transactionID, DOMStoreThreePhaseCommitCohort cohort,
- Modification modification) {
+ public ForwardedReadyTransaction(String transactionID, short txnClientVersion,
+ ShardDataTreeCohort cohort, Modification modification,
+ boolean returnSerialized, boolean doImmediateCommit) {
this.transactionID = transactionID;
this.cohort = cohort;
this.modification = modification;
this.transactionID = transactionID;
this.cohort = cohort;
this.modification = modification;
+ this.returnSerialized = returnSerialized;
+ this.txnClientVersion = txnClientVersion;
+ this.doImmediateCommit = doImmediateCommit;
}
public String getTransactionID() {
return transactionID;
}
}
public String getTransactionID() {
return transactionID;
}
- public
DOMStoreThreePhaseCommit
Cohort getCohort() {
+ public
ShardDataTree
Cohort getCohort() {
return cohort;
}
public Modification getModification() {
return modification;
}
return cohort;
}
public Modification getModification() {
return modification;
}
+
+ public boolean isReturnSerialized() {
+ return returnSerialized;
+ }
+
+ public short getTxnClientVersion() {
+ return txnClientVersion;
+ }
+
+ public boolean isDoImmediateCommit() {
+ return doImmediateCommit;
+ }
}
}