Revert "Commented out the cluster tests because it's not possible to exclude them right now"
This reverts commit 2abe5308da.
This commit is contained in:
Patrik Nordwall
parent
fcaa4751b3
commit
6993064cde
4 changed files with 311 additions and 311 deletions
|
|
@ -1,90 +1,90 @@
|
|||
///**
|
||||
// * Copyright (C) 2009-2012 Typesafe Inc. <http://www.typesafe.com>
|
||||
// */
|
||||
//
|
||||
//package akka.cluster
|
||||
//
|
||||
//import org.scalatest.BeforeAndAfter
|
||||
//import com.typesafe.config.ConfigFactory
|
||||
//import akka.remote.testkit.MultiNodeConfig
|
||||
//import akka.remote.testkit.MultiNodeSpec
|
||||
//import akka.testkit._
|
||||
//
|
||||
//object JoinTwoClustersMultiJvmSpec extends MultiNodeConfig {
|
||||
// val a1 = role("a1")
|
||||
// val a2 = role("a2")
|
||||
// val b1 = role("b1")
|
||||
// val b2 = role("b2")
|
||||
// val c1 = role("c1")
|
||||
// val c2 = role("c2")
|
||||
//
|
||||
// commonConfig(debugConfig(on = false).withFallback(MultiNodeClusterSpec.clusterConfig))
|
||||
//
|
||||
//}
|
||||
//
|
||||
//class JoinTwoClustersMultiJvmNode1 extends JoinTwoClustersSpec
|
||||
//class JoinTwoClustersMultiJvmNode2 extends JoinTwoClustersSpec
|
||||
//class JoinTwoClustersMultiJvmNode3 extends JoinTwoClustersSpec
|
||||
//class JoinTwoClustersMultiJvmNode4 extends JoinTwoClustersSpec
|
||||
//class JoinTwoClustersMultiJvmNode5 extends JoinTwoClustersSpec
|
||||
//class JoinTwoClustersMultiJvmNode6 extends JoinTwoClustersSpec
|
||||
//
|
||||
//abstract class JoinTwoClustersSpec extends MultiNodeSpec(JoinTwoClustersMultiJvmSpec) with MultiNodeClusterSpec with ImplicitSender with BeforeAndAfter {
|
||||
// import JoinTwoClustersMultiJvmSpec._
|
||||
//
|
||||
// override def initialParticipants = 6
|
||||
//
|
||||
// after {
|
||||
// testConductor.enter("after")
|
||||
// }
|
||||
//
|
||||
// val a1Address = node(a1).address
|
||||
// val b1Address = node(b1).address
|
||||
// val c1Address = node(c1).address
|
||||
//
|
||||
// "Three different clusters (A, B and C)" must {
|
||||
//
|
||||
// "be able to 'elect' a single leader after joining (A -> B)" taggedAs LongRunningTest in {
|
||||
//
|
||||
// runOn(a1, a2) {
|
||||
// cluster.join(a1Address)
|
||||
// }
|
||||
// runOn(b1, b2) {
|
||||
// cluster.join(b1Address)
|
||||
// }
|
||||
// runOn(c1, c2) {
|
||||
// cluster.join(c1Address)
|
||||
// }
|
||||
//
|
||||
// awaitUpConvergence(numberOfMembers = 2)
|
||||
//
|
||||
// assertLeader(a1, a2)
|
||||
// assertLeader(b1, b2)
|
||||
// assertLeader(c1, c2)
|
||||
//
|
||||
// runOn(b2) {
|
||||
// cluster.join(a1Address)
|
||||
// }
|
||||
//
|
||||
// runOn(a1, a2, b1, b2) {
|
||||
// awaitUpConvergence(numberOfMembers = 4)
|
||||
// }
|
||||
//
|
||||
// assertLeader(a1, a2, b1, b2)
|
||||
// assertLeader(c1, c2)
|
||||
//
|
||||
// }
|
||||
//
|
||||
// "be able to 'elect' a single leader after joining (C -> A + B)" taggedAs LongRunningTest in {
|
||||
//
|
||||
// runOn(b2) {
|
||||
// cluster.join(c1Address)
|
||||
// }
|
||||
//
|
||||
// awaitUpConvergence(numberOfMembers = 6)
|
||||
//
|
||||
// assertLeader(a1, a2, b1, b2, c1, c2)
|
||||
// }
|
||||
// }
|
||||
//
|
||||
//}
|
||||
/**
|
||||
* Copyright (C) 2009-2012 Typesafe Inc. <http://www.typesafe.com>
|
||||
*/
|
||||
|
||||
package akka.cluster
|
||||
|
||||
import org.scalatest.BeforeAndAfter
|
||||
import com.typesafe.config.ConfigFactory
|
||||
import akka.remote.testkit.MultiNodeConfig
|
||||
import akka.remote.testkit.MultiNodeSpec
|
||||
import akka.testkit._
|
||||
|
||||
object JoinTwoClustersMultiJvmSpec extends MultiNodeConfig {
|
||||
val a1 = role("a1")
|
||||
val a2 = role("a2")
|
||||
val b1 = role("b1")
|
||||
val b2 = role("b2")
|
||||
val c1 = role("c1")
|
||||
val c2 = role("c2")
|
||||
|
||||
commonConfig(debugConfig(on = false).withFallback(MultiNodeClusterSpec.clusterConfig))
|
||||
|
||||
}
|
||||
|
||||
class JoinTwoClustersMultiJvmNode1 extends JoinTwoClustersSpec
|
||||
class JoinTwoClustersMultiJvmNode2 extends JoinTwoClustersSpec
|
||||
class JoinTwoClustersMultiJvmNode3 extends JoinTwoClustersSpec
|
||||
class JoinTwoClustersMultiJvmNode4 extends JoinTwoClustersSpec
|
||||
class JoinTwoClustersMultiJvmNode5 extends JoinTwoClustersSpec
|
||||
class JoinTwoClustersMultiJvmNode6 extends JoinTwoClustersSpec
|
||||
|
||||
abstract class JoinTwoClustersSpec extends MultiNodeSpec(JoinTwoClustersMultiJvmSpec) with MultiNodeClusterSpec with ImplicitSender with BeforeAndAfter {
|
||||
import JoinTwoClustersMultiJvmSpec._
|
||||
|
||||
override def initialParticipants = 6
|
||||
|
||||
after {
|
||||
testConductor.enter("after")
|
||||
}
|
||||
|
||||
val a1Address = node(a1).address
|
||||
val b1Address = node(b1).address
|
||||
val c1Address = node(c1).address
|
||||
|
||||
"Three different clusters (A, B and C)" must {
|
||||
|
||||
"be able to 'elect' a single leader after joining (A -> B)" taggedAs LongRunningTest in {
|
||||
|
||||
runOn(a1, a2) {
|
||||
cluster.join(a1Address)
|
||||
}
|
||||
runOn(b1, b2) {
|
||||
cluster.join(b1Address)
|
||||
}
|
||||
runOn(c1, c2) {
|
||||
cluster.join(c1Address)
|
||||
}
|
||||
|
||||
awaitUpConvergence(numberOfMembers = 2)
|
||||
|
||||
assertLeader(a1, a2)
|
||||
assertLeader(b1, b2)
|
||||
assertLeader(c1, c2)
|
||||
|
||||
runOn(b2) {
|
||||
cluster.join(a1Address)
|
||||
}
|
||||
|
||||
runOn(a1, a2, b1, b2) {
|
||||
awaitUpConvergence(numberOfMembers = 4)
|
||||
}
|
||||
|
||||
assertLeader(a1, a2, b1, b2)
|
||||
assertLeader(c1, c2)
|
||||
|
||||
}
|
||||
|
||||
"be able to 'elect' a single leader after joining (C -> A + B)" taggedAs LongRunningTest in {
|
||||
|
||||
runOn(b2) {
|
||||
cluster.join(c1Address)
|
||||
}
|
||||
|
||||
awaitUpConvergence(numberOfMembers = 6)
|
||||
|
||||
assertLeader(a1, a2, b1, b2, c1, c2)
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,77 +1,77 @@
|
|||
///**
|
||||
// * Copyright (C) 2009-2012 Typesafe Inc. <http://www.typesafe.com>
|
||||
// */
|
||||
//package akka.cluster
|
||||
//
|
||||
//import scala.collection.immutable.SortedSet
|
||||
//import org.scalatest.BeforeAndAfter
|
||||
//import com.typesafe.config.ConfigFactory
|
||||
//import akka.remote.testkit.MultiNodeConfig
|
||||
//import akka.remote.testkit.MultiNodeSpec
|
||||
//import akka.testkit._
|
||||
//
|
||||
//object MembershipChangeListenerMultiJvmSpec extends MultiNodeConfig {
|
||||
// val first = role("first")
|
||||
// val second = role("second")
|
||||
// val third = role("third")
|
||||
//
|
||||
// commonConfig(debugConfig(on = false).withFallback(MultiNodeClusterSpec.clusterConfig))
|
||||
//
|
||||
//}
|
||||
//
|
||||
//class MembershipChangeListenerMultiJvmNode1 extends MembershipChangeListenerSpec
|
||||
//class MembershipChangeListenerMultiJvmNode2 extends MembershipChangeListenerSpec
|
||||
//class MembershipChangeListenerMultiJvmNode3 extends MembershipChangeListenerSpec
|
||||
//
|
||||
//abstract class MembershipChangeListenerSpec extends MultiNodeSpec(MembershipChangeListenerMultiJvmSpec)
|
||||
// with MultiNodeClusterSpec with ImplicitSender with BeforeAndAfter {
|
||||
// import MembershipChangeListenerMultiJvmSpec._
|
||||
//
|
||||
// override def initialParticipants = 3
|
||||
//
|
||||
// after {
|
||||
// testConductor.enter("after")
|
||||
// }
|
||||
//
|
||||
// "A set of connected cluster systems" must {
|
||||
//
|
||||
// val firstAddress = node(first).address
|
||||
// val secondAddress = node(second).address
|
||||
//
|
||||
// "(when two systems) after cluster convergence updates the membership table then all MembershipChangeListeners should be triggered" taggedAs LongRunningTest in {
|
||||
//
|
||||
// runOn(first, second) {
|
||||
// cluster.join(firstAddress)
|
||||
// val latch = TestLatch()
|
||||
// cluster.registerListener(new MembershipChangeListener {
|
||||
// def notify(members: SortedSet[Member]) {
|
||||
// if (members.size == 2 && members.forall(_.status == MemberStatus.Up))
|
||||
// latch.countDown()
|
||||
// }
|
||||
// })
|
||||
// latch.await
|
||||
// cluster.convergence.isDefined must be(true)
|
||||
// }
|
||||
//
|
||||
// }
|
||||
//
|
||||
// "(when three systems) after cluster convergence updates the membership table then all MembershipChangeListeners should be triggered" taggedAs LongRunningTest in {
|
||||
//
|
||||
// runOn(third) {
|
||||
// cluster.join(firstAddress)
|
||||
// }
|
||||
//
|
||||
// val latch = TestLatch()
|
||||
// cluster.registerListener(new MembershipChangeListener {
|
||||
// def notify(members: SortedSet[Member]) {
|
||||
// if (members.size == 3 && members.forall(_.status == MemberStatus.Up))
|
||||
// latch.countDown()
|
||||
// }
|
||||
// })
|
||||
// latch.await
|
||||
// cluster.convergence.isDefined must be(true)
|
||||
//
|
||||
// }
|
||||
// }
|
||||
//
|
||||
//}
|
||||
/**
|
||||
* Copyright (C) 2009-2012 Typesafe Inc. <http://www.typesafe.com>
|
||||
*/
|
||||
package akka.cluster
|
||||
|
||||
import scala.collection.immutable.SortedSet
|
||||
import org.scalatest.BeforeAndAfter
|
||||
import com.typesafe.config.ConfigFactory
|
||||
import akka.remote.testkit.MultiNodeConfig
|
||||
import akka.remote.testkit.MultiNodeSpec
|
||||
import akka.testkit._
|
||||
|
||||
object MembershipChangeListenerMultiJvmSpec extends MultiNodeConfig {
|
||||
val first = role("first")
|
||||
val second = role("second")
|
||||
val third = role("third")
|
||||
|
||||
commonConfig(debugConfig(on = false).withFallback(MultiNodeClusterSpec.clusterConfig))
|
||||
|
||||
}
|
||||
|
||||
class MembershipChangeListenerMultiJvmNode1 extends MembershipChangeListenerSpec
|
||||
class MembershipChangeListenerMultiJvmNode2 extends MembershipChangeListenerSpec
|
||||
class MembershipChangeListenerMultiJvmNode3 extends MembershipChangeListenerSpec
|
||||
|
||||
abstract class MembershipChangeListenerSpec extends MultiNodeSpec(MembershipChangeListenerMultiJvmSpec)
|
||||
with MultiNodeClusterSpec with ImplicitSender with BeforeAndAfter {
|
||||
import MembershipChangeListenerMultiJvmSpec._
|
||||
|
||||
override def initialParticipants = 3
|
||||
|
||||
after {
|
||||
testConductor.enter("after")
|
||||
}
|
||||
|
||||
"A set of connected cluster systems" must {
|
||||
|
||||
val firstAddress = node(first).address
|
||||
val secondAddress = node(second).address
|
||||
|
||||
"(when two systems) after cluster convergence updates the membership table then all MembershipChangeListeners should be triggered" taggedAs LongRunningTest in {
|
||||
|
||||
runOn(first, second) {
|
||||
cluster.join(firstAddress)
|
||||
val latch = TestLatch()
|
||||
cluster.registerListener(new MembershipChangeListener {
|
||||
def notify(members: SortedSet[Member]) {
|
||||
if (members.size == 2 && members.forall(_.status == MemberStatus.Up))
|
||||
latch.countDown()
|
||||
}
|
||||
})
|
||||
latch.await
|
||||
cluster.convergence.isDefined must be(true)
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
"(when three systems) after cluster convergence updates the membership table then all MembershipChangeListeners should be triggered" taggedAs LongRunningTest in {
|
||||
|
||||
runOn(third) {
|
||||
cluster.join(firstAddress)
|
||||
}
|
||||
|
||||
val latch = TestLatch()
|
||||
cluster.registerListener(new MembershipChangeListener {
|
||||
def notify(members: SortedSet[Member]) {
|
||||
if (members.size == 3 && members.forall(_.status == MemberStatus.Up))
|
||||
latch.countDown()
|
||||
}
|
||||
})
|
||||
latch.await
|
||||
cluster.convergence.isDefined must be(true)
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,70 +1,70 @@
|
|||
///**
|
||||
// * Copyright (C) 2009-2012 Typesafe Inc. <http://www.typesafe.com>
|
||||
// */
|
||||
//package akka.cluster
|
||||
//
|
||||
//import com.typesafe.config.ConfigFactory
|
||||
//import org.scalatest.BeforeAndAfter
|
||||
//import akka.remote.testkit.MultiNodeConfig
|
||||
//import akka.remote.testkit.MultiNodeSpec
|
||||
//import akka.testkit._
|
||||
//
|
||||
//object NodeMembershipMultiJvmSpec extends MultiNodeConfig {
|
||||
// val first = role("first")
|
||||
// val second = role("second")
|
||||
// val third = role("third")
|
||||
//
|
||||
// commonConfig(debugConfig(on = false).withFallback(MultiNodeClusterSpec.clusterConfig))
|
||||
//
|
||||
//}
|
||||
//
|
||||
//class NodeMembershipMultiJvmNode1 extends NodeMembershipSpec
|
||||
//class NodeMembershipMultiJvmNode2 extends NodeMembershipSpec
|
||||
//class NodeMembershipMultiJvmNode3 extends NodeMembershipSpec
|
||||
//
|
||||
//abstract class NodeMembershipSpec extends MultiNodeSpec(NodeMembershipMultiJvmSpec) with MultiNodeClusterSpec with ImplicitSender with BeforeAndAfter {
|
||||
// import NodeMembershipMultiJvmSpec._
|
||||
//
|
||||
// override def initialParticipants = 3
|
||||
//
|
||||
// after {
|
||||
// testConductor.enter("after")
|
||||
// }
|
||||
//
|
||||
// val firstAddress = node(first).address
|
||||
// val secondAddress = node(second).address
|
||||
// val thirdAddress = node(third).address
|
||||
//
|
||||
// "A set of connected cluster systems" must {
|
||||
//
|
||||
// "(when two systems) start gossiping to each other so that both systems gets the same gossip info" taggedAs LongRunningTest in {
|
||||
//
|
||||
// runOn(first, second) {
|
||||
// cluster.join(firstAddress)
|
||||
// awaitCond(cluster.latestGossip.members.size == 2)
|
||||
// assertMembers(cluster.latestGossip.members, firstAddress, secondAddress)
|
||||
// awaitCond {
|
||||
// cluster.latestGossip.members.forall(_.status == MemberStatus.Up)
|
||||
// }
|
||||
// awaitCond(cluster.convergence.isDefined)
|
||||
// }
|
||||
//
|
||||
// }
|
||||
//
|
||||
// "(when three systems) start gossiping to each other so that both systems gets the same gossip info" taggedAs LongRunningTest in {
|
||||
//
|
||||
// runOn(third) {
|
||||
// cluster.join(firstAddress)
|
||||
// }
|
||||
//
|
||||
// awaitCond(cluster.latestGossip.members.size == 3)
|
||||
// assertMembers(cluster.latestGossip.members, firstAddress, secondAddress, thirdAddress)
|
||||
// awaitCond {
|
||||
// cluster.latestGossip.members.forall(_.status == MemberStatus.Up)
|
||||
// }
|
||||
// awaitCond(cluster.convergence.isDefined)
|
||||
//
|
||||
// }
|
||||
// }
|
||||
//
|
||||
//}
|
||||
/**
|
||||
* Copyright (C) 2009-2012 Typesafe Inc. <http://www.typesafe.com>
|
||||
*/
|
||||
package akka.cluster
|
||||
|
||||
import com.typesafe.config.ConfigFactory
|
||||
import org.scalatest.BeforeAndAfter
|
||||
import akka.remote.testkit.MultiNodeConfig
|
||||
import akka.remote.testkit.MultiNodeSpec
|
||||
import akka.testkit._
|
||||
|
||||
object NodeMembershipMultiJvmSpec extends MultiNodeConfig {
|
||||
val first = role("first")
|
||||
val second = role("second")
|
||||
val third = role("third")
|
||||
|
||||
commonConfig(debugConfig(on = false).withFallback(MultiNodeClusterSpec.clusterConfig))
|
||||
|
||||
}
|
||||
|
||||
class NodeMembershipMultiJvmNode1 extends NodeMembershipSpec
|
||||
class NodeMembershipMultiJvmNode2 extends NodeMembershipSpec
|
||||
class NodeMembershipMultiJvmNode3 extends NodeMembershipSpec
|
||||
|
||||
abstract class NodeMembershipSpec extends MultiNodeSpec(NodeMembershipMultiJvmSpec) with MultiNodeClusterSpec with ImplicitSender with BeforeAndAfter {
|
||||
import NodeMembershipMultiJvmSpec._
|
||||
|
||||
override def initialParticipants = 3
|
||||
|
||||
after {
|
||||
testConductor.enter("after")
|
||||
}
|
||||
|
||||
val firstAddress = node(first).address
|
||||
val secondAddress = node(second).address
|
||||
val thirdAddress = node(third).address
|
||||
|
||||
"A set of connected cluster systems" must {
|
||||
|
||||
"(when two systems) start gossiping to each other so that both systems gets the same gossip info" taggedAs LongRunningTest in {
|
||||
|
||||
runOn(first, second) {
|
||||
cluster.join(firstAddress)
|
||||
awaitCond(cluster.latestGossip.members.size == 2)
|
||||
assertMembers(cluster.latestGossip.members, firstAddress, secondAddress)
|
||||
awaitCond {
|
||||
cluster.latestGossip.members.forall(_.status == MemberStatus.Up)
|
||||
}
|
||||
awaitCond(cluster.convergence.isDefined)
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
"(when three systems) start gossiping to each other so that both systems gets the same gossip info" taggedAs LongRunningTest in {
|
||||
|
||||
runOn(third) {
|
||||
cluster.join(firstAddress)
|
||||
}
|
||||
|
||||
awaitCond(cluster.latestGossip.members.size == 3)
|
||||
assertMembers(cluster.latestGossip.members, firstAddress, secondAddress, thirdAddress)
|
||||
awaitCond {
|
||||
cluster.latestGossip.members.forall(_.status == MemberStatus.Up)
|
||||
}
|
||||
awaitCond(cluster.convergence.isDefined)
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,74 +1,74 @@
|
|||
///**
|
||||
// * Copyright (C) 2009-2012 Typesafe Inc. <http://www.typesafe.com>
|
||||
// */
|
||||
//package akka.cluster
|
||||
//
|
||||
//import com.typesafe.config.ConfigFactory
|
||||
//import org.scalatest.BeforeAndAfter
|
||||
//import akka.remote.testkit.MultiNodeConfig
|
||||
//import akka.remote.testkit.MultiNodeSpec
|
||||
//import akka.testkit._
|
||||
//
|
||||
//object NodeStartupMultiJvmSpec extends MultiNodeConfig {
|
||||
// val first = role("first")
|
||||
// val second = role("second")
|
||||
//
|
||||
// commonConfig(debugConfig(on = false).withFallback(MultiNodeClusterSpec.clusterConfig))
|
||||
//
|
||||
//}
|
||||
//
|
||||
//class NodeStartupMultiJvmNode1 extends NodeStartupSpec
|
||||
//class NodeStartupMultiJvmNode2 extends NodeStartupSpec
|
||||
//
|
||||
//abstract class NodeStartupSpec extends MultiNodeSpec(NodeStartupMultiJvmSpec) with MultiNodeClusterSpec with ImplicitSender with BeforeAndAfter {
|
||||
// import NodeStartupMultiJvmSpec._
|
||||
//
|
||||
// override def initialParticipants = 2
|
||||
//
|
||||
// after {
|
||||
// testConductor.enter("after")
|
||||
// }
|
||||
//
|
||||
// val firstAddress = node(first).address
|
||||
// val secondAddress = node(second).address
|
||||
//
|
||||
// "A first cluster node with a 'node-to-join' config set to empty string (singleton cluster)" must {
|
||||
//
|
||||
// "be a singleton cluster when started up" taggedAs LongRunningTest in {
|
||||
// runOn(first) {
|
||||
// awaitCond(cluster.isSingletonCluster)
|
||||
// // FIXME #2117 singletonCluster should reach convergence
|
||||
// //awaitCond(cluster.convergence.isDefined)
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// "be in 'Joining' phase when started up" taggedAs LongRunningTest in {
|
||||
// runOn(first) {
|
||||
// val members = cluster.latestGossip.members
|
||||
// members.size must be(1)
|
||||
//
|
||||
// val joiningMember = members find (_.address == firstAddress)
|
||||
// joiningMember must not be (None)
|
||||
// joiningMember.get.status must be(MemberStatus.Joining)
|
||||
// }
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// "A second cluster node" must {
|
||||
// "join the other node cluster when sending a Join command" taggedAs LongRunningTest in {
|
||||
//
|
||||
// runOn(second) {
|
||||
// cluster.join(firstAddress)
|
||||
// }
|
||||
//
|
||||
// awaitCond {
|
||||
// cluster.latestGossip.members.exists { member ⇒
|
||||
// member.address == secondAddress && member.status == MemberStatus.Up
|
||||
// }
|
||||
// }
|
||||
// cluster.latestGossip.members.size must be(2)
|
||||
// awaitCond(cluster.convergence.isDefined)
|
||||
// }
|
||||
// }
|
||||
//
|
||||
//}
|
||||
/**
|
||||
* Copyright (C) 2009-2012 Typesafe Inc. <http://www.typesafe.com>
|
||||
*/
|
||||
package akka.cluster
|
||||
|
||||
import com.typesafe.config.ConfigFactory
|
||||
import org.scalatest.BeforeAndAfter
|
||||
import akka.remote.testkit.MultiNodeConfig
|
||||
import akka.remote.testkit.MultiNodeSpec
|
||||
import akka.testkit._
|
||||
|
||||
object NodeStartupMultiJvmSpec extends MultiNodeConfig {
|
||||
val first = role("first")
|
||||
val second = role("second")
|
||||
|
||||
commonConfig(debugConfig(on = false).withFallback(MultiNodeClusterSpec.clusterConfig))
|
||||
|
||||
}
|
||||
|
||||
class NodeStartupMultiJvmNode1 extends NodeStartupSpec
|
||||
class NodeStartupMultiJvmNode2 extends NodeStartupSpec
|
||||
|
||||
abstract class NodeStartupSpec extends MultiNodeSpec(NodeStartupMultiJvmSpec) with MultiNodeClusterSpec with ImplicitSender with BeforeAndAfter {
|
||||
import NodeStartupMultiJvmSpec._
|
||||
|
||||
override def initialParticipants = 2
|
||||
|
||||
after {
|
||||
testConductor.enter("after")
|
||||
}
|
||||
|
||||
val firstAddress = node(first).address
|
||||
val secondAddress = node(second).address
|
||||
|
||||
"A first cluster node with a 'node-to-join' config set to empty string (singleton cluster)" must {
|
||||
|
||||
"be a singleton cluster when started up" taggedAs LongRunningTest in {
|
||||
runOn(first) {
|
||||
awaitCond(cluster.isSingletonCluster)
|
||||
// FIXME #2117 singletonCluster should reach convergence
|
||||
//awaitCond(cluster.convergence.isDefined)
|
||||
}
|
||||
}
|
||||
|
||||
"be in 'Joining' phase when started up" taggedAs LongRunningTest in {
|
||||
runOn(first) {
|
||||
val members = cluster.latestGossip.members
|
||||
members.size must be(1)
|
||||
|
||||
val joiningMember = members find (_.address == firstAddress)
|
||||
joiningMember must not be (None)
|
||||
joiningMember.get.status must be(MemberStatus.Joining)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
"A second cluster node" must {
|
||||
"join the other node cluster when sending a Join command" taggedAs LongRunningTest in {
|
||||
|
||||
runOn(second) {
|
||||
cluster.join(firstAddress)
|
||||
}
|
||||
|
||||
awaitCond {
|
||||
cluster.latestGossip.members.exists { member ⇒
|
||||
member.address == secondAddress && member.status == MemberStatus.Up
|
||||
}
|
||||
}
|
||||
cluster.latestGossip.members.size must be(2)
|
||||
awaitCond(cluster.convergence.isDefined)
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue