From 4b31ac1c034006f8c563d01ffb4d2ad1e543d2f9 Mon Sep 17 00:00:00 2001 From: Eugene Vigdorchik Date: Wed, 21 Dec 2011 19:06:51 +0400 Subject: [PATCH] Minor corrections according to Viktor's review. --- .../scala/akka/remote/AbstractRemoteActorMultiJvmSpec.scala | 6 +++--- akka-remote/src/multi-jvm/scala/akka/remote/ZKClient.scala | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/akka-remote/src/multi-jvm/scala/akka/remote/AbstractRemoteActorMultiJvmSpec.scala b/akka-remote/src/multi-jvm/scala/akka/remote/AbstractRemoteActorMultiJvmSpec.scala index 8fdb6f62e3..65a1335670 100755 --- a/akka-remote/src/multi-jvm/scala/akka/remote/AbstractRemoteActorMultiJvmSpec.scala +++ b/akka-remote/src/multi-jvm/scala/akka/remote/AbstractRemoteActorMultiJvmSpec.scala @@ -6,9 +6,9 @@ trait AbstractRemoteActorMultiJvmSpec { def NrOfNodes: Int def commonConfig: Config - def remotes: List[String] = { - val listOpt = Option(System.getProperty("test.hosts")).map(_.split(",").toList) - listOpt getOrElse List.fill(NrOfNodes)("localhost") + def remotes: Array[String] = { + val arrayOpt = Option(System.getProperty("test.hosts")).map(_ split ",") + arrayOpt getOrElse Array.fill(NrOfNodes)("localhost") } def specString(count: Int): String = { diff --git a/akka-remote/src/multi-jvm/scala/akka/remote/ZKClient.scala b/akka-remote/src/multi-jvm/scala/akka/remote/ZKClient.scala index 44a50448ce..faf13c87d7 100755 --- a/akka-remote/src/multi-jvm/scala/akka/remote/ZKClient.scala +++ b/akka-remote/src/multi-jvm/scala/akka/remote/ZKClient.scala @@ -44,7 +44,7 @@ class ZKClient(config: Config) extends Watcher { zk.delete(root + "/" + name, -1) while (true) { ZKClient.this.synchronized { - if (zk.getChildren(root, true).size > 0) { + if (!zk.getChildren(root, true).isEmpty) { ZKClient.this.wait() } }