Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
BUG-8402: correctly propagate read-only bit
[controller.git]
/
opendaylight
/
md-sal
/
cds-access-api
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
access
/
commands
/
IncrementTransactionSequenceRequest.java
diff --git
a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceRequest.java
b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceRequest.java
index 59faae42ccb82dd3042c1b6b6653a8923369168b..ffc0a68b8912481bfeca882545ff3626469025e0 100644
(file)
--- a/
opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceRequest.java
+++ b/
opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceRequest.java
@@
-19,18
+19,28
@@
import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier
*
* @author Robert Varga
*/
*
* @author Robert Varga
*/
-public final class IncrementTransactionSequenceRequest extends TransactionRequest<IncrementTransactionSequenceRequest> {
+public final class IncrementTransactionSequenceRequest extends
+ AbstractReadTransactionRequest<IncrementTransactionSequenceRequest> {
private static final long serialVersionUID = 1L;
private final long increment;
public IncrementTransactionSequenceRequest(final TransactionIdentifier identifier, final long sequence,
private static final long serialVersionUID = 1L;
private final long increment;
public IncrementTransactionSequenceRequest(final TransactionIdentifier identifier, final long sequence,
- final ActorRef replyTo, final long increment) {
- super(identifier, sequence, replyTo);
+ final ActorRef replyTo, final
boolean snapshotOnly, final
long increment) {
+ super(identifier, sequence, replyTo
, snapshotOnly
);
Preconditions.checkArgument(increment >= 0);
this.increment = increment;
}
Preconditions.checkArgument(increment >= 0);
this.increment = increment;
}
+ /**
+ * Return the sequence increment beyond this request's sequence.
+ *
+ * @return Sequence increment, guaranteed to be non-negative.
+ */
+ public long getIncrement() {
+ return increment;
+ }
+
@Override
protected IncrementTransactionSequenceRequestProxyV1 externalizableProxy(final ABIVersion version) {
return new IncrementTransactionSequenceRequestProxyV1(this);
@Override
protected IncrementTransactionSequenceRequestProxyV1 externalizableProxy(final ABIVersion version) {
return new IncrementTransactionSequenceRequestProxyV1(this);
@@
-40,13
+50,4
@@
public final class IncrementTransactionSequenceRequest extends TransactionReques
protected IncrementTransactionSequenceRequest cloneAsVersion(final ABIVersion targetVersion) {
return this;
}
protected IncrementTransactionSequenceRequest cloneAsVersion(final ABIVersion targetVersion) {
return this;
}
-
- /**
- * Return the sequence increment beyond this request's sequence.
- *
- * @return Sequence increment, guaranteed to be non-negative.
- */
- public long getIncrement() {
- return increment;
- }
}
}