83 lines
2.3 KiB
Scala
83 lines
2.3 KiB
Scala
/**
|
|
* 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(ConfigFactory.parseString("""
|
|
akka.cluster {
|
|
gossip-frequency = 200 ms
|
|
leader-actions-frequency = 200 ms
|
|
periodic-tasks-initial-delay = 300 ms
|
|
}
|
|
""")))
|
|
|
|
}
|
|
|
|
class NodeStartupMultiJvmNode1 extends NodeStartupSpec
|
|
class NodeStartupMultiJvmNode2 extends NodeStartupSpec
|
|
|
|
abstract class NodeStartupSpec extends MultiNodeSpec(NodeStartupMultiJvmSpec) with ImplicitSender with BeforeAndAfter {
|
|
import NodeStartupMultiJvmSpec._
|
|
|
|
override def initialParticipants = 2
|
|
|
|
def node() = Cluster(system)
|
|
|
|
after {
|
|
testConductor.enter("after")
|
|
}
|
|
|
|
val firstAddress = testConductor.getAddressFor(first).await
|
|
|
|
"A first cluster node with a 'node-to-join' config set to empty string (singleton cluster)" must {
|
|
|
|
"be a singleton cluster when started up" in {
|
|
runOn(first) {
|
|
awaitCond(node().isSingletonCluster)
|
|
// FIXME #2117 singletonCluster should reach convergence
|
|
//awaitCond(node().convergence.isDefined)
|
|
}
|
|
}
|
|
|
|
"be in 'Joining' phase when started up" in {
|
|
runOn(first) {
|
|
val members = node().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" in {
|
|
|
|
runOn(second) {
|
|
node().join(firstAddress)
|
|
}
|
|
|
|
// runOn all
|
|
val secondAddress = testConductor.getAddressFor(second).await
|
|
awaitCond {
|
|
node.latestGossip.members.exists { member ⇒
|
|
member.address == secondAddress && member.status == MemberStatus.Up
|
|
}
|
|
}
|
|
node().latestGossip.members.size must be(2)
|
|
awaitCond(node().convergence.isDefined)
|
|
}
|
|
}
|
|
|
|
}
|