raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Commented out the cluster tests because it's not possible to exclude them right now

Browse source
This commit is contained in:
Patrik Nordwall 2012-05-25 17:04:21 +02:00
parent f38ad6b000
commit 2abe5308da
4 changed files with 311 additions and 311 deletions
Download patch file Download diff file Expand all files Collapse all files

148
akka-cluster/src/multi-jvm/scala/akka/cluster/NodeStartupSpec.scala
View file

@ -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)
// }
// }
//
//}