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 "Elide front-end 3PC for single-shard Tx"
[controller.git]
/
opendaylight
/
md-sal
/
sal-distributed-datastore
/
src
/
test
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
datastore
/
compat
/
PreLithiumShardTest.java
diff --git
a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/compat/PreLithiumShardTest.java
b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/compat/PreLithiumShardTest.java
index cc860eafc7cf46a7aebc374f3351ba1eed5e1f6a..caabb32d71e174ad03a785056b2cd84d06ab453b 100644
(file)
--- a/
opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/compat/PreLithiumShardTest.java
+++ b/
opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/compat/PreLithiumShardTest.java
@@
-11,7
+11,7
@@
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.mockito.Mockito.inOrder;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.mockito.Mockito.inOrder;
-import static org.opendaylight.controller.cluster.datastore.DataStoreVersions.
CURRENT
_VERSION;
+import static org.opendaylight.controller.cluster.datastore.DataStoreVersions.
HELIUM_2
_VERSION;
import akka.actor.ActorRef;
import akka.actor.PoisonPill;
import akka.dispatch.Dispatchers;
import akka.actor.ActorRef;
import akka.actor.PoisonPill;
import akka.dispatch.Dispatchers;
@@
-246,8
+246,8
@@
public class PreLithiumShardTest extends AbstractShardTest {
// Simulate the ForwardedReadyTransaction message for the first Tx that would be sent
// by the ShardTransaction.
// Simulate the ForwardedReadyTransaction message for the first Tx that would be sent
// by the ShardTransaction.
- shard.tell(new ForwardedReadyTransaction(transactionID1,
CURRENT
_VERSION,
- cohort1, modification1, true), getRef());
+ shard.tell(new ForwardedReadyTransaction(transactionID1,
HELIUM_2
_VERSION,
+ cohort1, modification1, true
, false
), getRef());
ReadyTransactionReply readyReply = ReadyTransactionReply.fromSerializable(
expectMsgClass(duration, ReadyTransactionReply.SERIALIZABLE_CLASS));
assertEquals("Cohort path", shard.path().toString(), readyReply.getCohortPath());
ReadyTransactionReply readyReply = ReadyTransactionReply.fromSerializable(
expectMsgClass(duration, ReadyTransactionReply.SERIALIZABLE_CLASS));
assertEquals("Cohort path", shard.path().toString(), readyReply.getCohortPath());
@@
-261,12
+261,12
@@
public class PreLithiumShardTest extends AbstractShardTest {
// Send the ForwardedReadyTransaction for the next 2 Tx's.
// Send the ForwardedReadyTransaction for the next 2 Tx's.
- shard.tell(new ForwardedReadyTransaction(transactionID2,
CURRENT
_VERSION,
- cohort2, modification2, true), getRef());
+ shard.tell(new ForwardedReadyTransaction(transactionID2,
HELIUM_2
_VERSION,
+ cohort2, modification2, true
, false
), getRef());
expectMsgClass(duration, ReadyTransactionReply.SERIALIZABLE_CLASS);
expectMsgClass(duration, ReadyTransactionReply.SERIALIZABLE_CLASS);
- shard.tell(new ForwardedReadyTransaction(transactionID3,
CURRENT
_VERSION,
- cohort3, modification3, true), getRef());
+ shard.tell(new ForwardedReadyTransaction(transactionID3,
HELIUM_2
_VERSION,
+ cohort3, modification3, true
, false
), getRef());
expectMsgClass(duration, ReadyTransactionReply.SERIALIZABLE_CLASS);
// Send the CanCommitTransaction message for the next 2 Tx's. These should get queued and
expectMsgClass(duration, ReadyTransactionReply.SERIALIZABLE_CLASS);
// Send the CanCommitTransaction message for the next 2 Tx's. These should get queued and