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

Increase within timeouts in cluster sample tests, see #2699

Browse source
This commit is contained in:
Patrik Nordwall 2012-11-15 08:28:35 +01:00
parent b1d96c8794
commit 524bb65e0f
6 changed files with 10 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSingleMasterSpec.scala
View file

@ -67,7 +67,7 @@ abstract class StatsSampleSingleMasterSpec extends MultiNodeSpec(StatsSampleSing
override def afterAll() = multiNodeSpecAfterAll() override def afterAll() = multiNodeSpecAfterAll()
"The stats sample with single master" must { "The stats sample with single master" must {
"illustrate how to startup cluster" in within(10 seconds) { "illustrate how to startup cluster" in within(15 seconds) {
Cluster(system).subscribe(testActor, classOf[MemberUp]) Cluster(system).subscribe(testActor, classOf[MemberUp])
expectMsgClass(classOf[CurrentClusterState]) expectMsgClass(classOf[CurrentClusterState])

6
akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/StatsSampleSpec.scala
View file

@ -76,7 +76,7 @@ abstract class StatsSampleSpec extends MultiNodeSpec(StatsSampleSpecConfig)
"The stats sample" must { "The stats sample" must {
//#startup-cluster //#startup-cluster
"illustrate how to startup cluster" in within(10 seconds) { "illustrate how to startup cluster" in within(15 seconds) {
Cluster(system).subscribe(testActor, classOf[MemberUp]) Cluster(system).subscribe(testActor, classOf[MemberUp])
expectMsgClass(classOf[CurrentClusterState]) expectMsgClass(classOf[CurrentClusterState])
@ -106,7 +106,7 @@ abstract class StatsSampleSpec extends MultiNodeSpec(StatsSampleSpecConfig)
//#test-statsService //#test-statsService
"show usage of the statsService from one node" in within(5 seconds) { "show usage of the statsService from one node" in within(15 seconds) {
runOn(second) { runOn(second) {
val service = system.actorFor(node(third) / "user" / "statsService") val service = system.actorFor(node(third) / "user" / "statsService")
service ! StatsJob("this is the text that will be analyzed") service ! StatsJob("this is the text that will be analyzed")
@ -120,7 +120,7 @@ abstract class StatsSampleSpec extends MultiNodeSpec(StatsSampleSpecConfig)
} }
//#test-statsService //#test-statsService
"show usage of the statsService from all nodes" in within(5 seconds) { "show usage of the statsService from all nodes" in within(15 seconds) {
val service = system.actorFor(node(third) / "user" / "statsService") val service = system.actorFor(node(third) / "user" / "statsService")
service ! StatsJob("this is the text that will be analyzed") service ! StatsJob("this is the text that will be analyzed")
val meanWordLength = expectMsgPF() { val meanWordLength = expectMsgPF() {

6
akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/japi/StatsSampleJapiSpec.scala
View file

@ -65,7 +65,7 @@ abstract class StatsSampleJapiSpec extends MultiNodeSpec(StatsSampleJapiSpecConf
"The japi stats sample" must { "The japi stats sample" must {
"illustrate how to startup cluster" in within(10 seconds) { "illustrate how to startup cluster" in within(15 seconds) {
Cluster(system).subscribe(testActor, classOf[MemberUp]) Cluster(system).subscribe(testActor, classOf[MemberUp])
expectMsgClass(classOf[CurrentClusterState]) expectMsgClass(classOf[CurrentClusterState])
@ -89,7 +89,7 @@ abstract class StatsSampleJapiSpec extends MultiNodeSpec(StatsSampleJapiSpecConf
} }
"show usage of the statsService from one node" in within(5 seconds) { "show usage of the statsService from one node" in within(15 seconds) {
runOn(second) { runOn(second) {
val service = system.actorFor(node(third) / "user" / "statsService") val service = system.actorFor(node(third) / "user" / "statsService")
service ! new StatsJob("this is the text that will be analyzed") service ! new StatsJob("this is the text that will be analyzed")
@ -103,7 +103,7 @@ abstract class StatsSampleJapiSpec extends MultiNodeSpec(StatsSampleJapiSpecConf
} }
//#test-statsService //#test-statsService
"show usage of the statsService from all nodes" in within(5 seconds) { "show usage of the statsService from all nodes" in within(15 seconds) {
val service = system.actorFor(node(third) / "user" / "statsService") val service = system.actorFor(node(third) / "user" / "statsService")
service ! new StatsJob("this is the text that will be analyzed") service ! new StatsJob("this is the text that will be analyzed")
val meanWordLength = expectMsgPF() { val meanWordLength = expectMsgPF() {

2
akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/stats/japi/StatsSampleSingleMasterJapiSpec.scala
View file

@ -66,7 +66,7 @@ abstract class StatsSampleSingleMasterJapiSpec extends MultiNodeSpec(StatsSample
override def afterAll() = multiNodeSpecAfterAll() override def afterAll() = multiNodeSpecAfterAll()
"The japi stats sample with single master" must { "The japi stats sample with single master" must {
"illustrate how to startup cluster" in within(10 seconds) { "illustrate how to startup cluster" in within(15 seconds) {
Cluster(system).subscribe(testActor, classOf[MemberUp]) Cluster(system).subscribe(testActor, classOf[MemberUp])
expectMsgClass(classOf[CurrentClusterState]) expectMsgClass(classOf[CurrentClusterState])

2
akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/transformation/TransformationSampleSpec.scala
View file

@ -52,7 +52,7 @@ abstract class TransformationSampleSpec extends MultiNodeSpec(TransformationSamp
override def afterAll() = multiNodeSpecAfterAll() override def afterAll() = multiNodeSpecAfterAll()
"The transformation sample" must { "The transformation sample" must {
"illustrate how to start first frontend" in { "illustrate how to start first frontend" in within(15 seconds) {
runOn(frontend1) { runOn(frontend1) {
// this will only run on the 'first' node // this will only run on the 'first' node
Cluster(system) join node(frontend1).address Cluster(system) join node(frontend1).address

2
akka-samples/akka-sample-cluster/src/multi-jvm/scala/sample/cluster/transformation/japi/TransformationSampleJapiSpec.scala
View file

@ -53,7 +53,7 @@ abstract class TransformationSampleJapiSpec extends MultiNodeSpec(Transformation
override def afterAll() = multiNodeSpecAfterAll() override def afterAll() = multiNodeSpecAfterAll()
"The japi transformation sample" must { "The japi transformation sample" must {
"illustrate how to start first frontend" in { "illustrate how to start first frontend" in within(15 seconds) {
runOn(frontend1) { runOn(frontend1) {
// this will only run on the 'first' node // this will only run on the 'first' node
Cluster(system) join node(frontend1).address Cluster(system) join node(frontend1).address