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

FIXME in cluster, see #3192

Browse source
This commit is contained in:
Patrik Nordwall 2013-05-28 09:02:03 +02:00
parent 58756be937
commit 196a141976
5 changed files with 9 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala
View file

@ -697,7 +697,7 @@ private[cluster] final class ClusterCoreDaemon(publisher: ActorRef) extends Acto
val localUnreachableMembers = localOverview.unreachable
val hasPartionHandoffCompletedSuccessfully: Boolean = {
// FIXME implement partion handoff and a check if it is completed - now just returns TRUE - e.g. has completed successfully
// TODO implement partion handoff and a check if it is completed - now just returns TRUE - e.g. has completed successfully
true
}

2
akka-cluster/src/main/scala/akka/cluster/ClusterHeartbeat.scala
View file

@ -246,7 +246,7 @@ private[cluster] case class ClusterHeartbeatSenderState private (
ending: Map[Address, Int] = Map.empty,
heartbeatRequest: Map[Address, Deadline] = Map.empty) {
// FIXME can be disabled as optimization
// TODO can be disabled as optimization
assertInvariants()
private def assertInvariants(): Unit = {

2
akka-cluster/src/main/scala/akka/cluster/Gossip.scala
View file

@ -64,7 +64,7 @@ private[cluster] case class Gossip(
version: VectorClock = VectorClock()) // vector clock version
extends Versioned[Gossip] {
// FIXME can be disabled as optimization
// TODO can be disabled as optimization
assertInvariants()
private def assertInvariants(): Unit = {

7
akka-contrib/src/multi-jvm/scala/akka/contrib/pattern/ClusterSingletonManagerChaosSpec.scala
View file

@ -146,10 +146,9 @@ class ClusterSingletonManagerChaosSpec extends MultiNodeSpec(ClusterSingletonMan
}
"take over when three oldest nodes crash in 6 nodes cluster" in within(90 seconds) {
// FIXME change those to DeadLetterFilter
system.eventStream.publish(Mute(EventFilter.warning(pattern = ".*received dead letter from.*")))
system.eventStream.publish(Mute(EventFilter.error(pattern = ".*Disassociated.*")))
system.eventStream.publish(Mute(EventFilter.error(pattern = ".*Association failed.*")))
// mute logging of deadLetters during shutdown of systems
if (!log.isDebugEnabled)
system.eventStream.publish(Mute(DeadLettersFilter[Any]))
enterBarrier("logs-muted")
crash(first, second, third)

7
akka-contrib/src/multi-jvm/scala/akka/contrib/pattern/ClusterSingletonManagerSpec.scala
View file

@ -345,10 +345,9 @@ class ClusterSingletonManagerSpec extends MultiNodeSpec(ClusterSingletonManagerS
}
"take over when oldest crashes in 5 nodes cluster" in within(60 seconds) {
// FIXME change those to DeadLetterFilter
system.eventStream.publish(Mute(EventFilter.warning(pattern = ".*received dead letter from.*")))
system.eventStream.publish(Mute(EventFilter.error(pattern = ".*Disassociated.*")))
system.eventStream.publish(Mute(EventFilter.error(pattern = ".*Association failed.*")))
// mute logging of deadLetters during shutdown of systems
if (!log.isDebugEnabled)
system.eventStream.publish(Mute(DeadLettersFilter[Any]))
enterBarrier("logs-muted")
crash(second)