From abf3e6e51ddebc65b79f2abe9d1bbde3787ad726 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jonas=20Bone=CC=81r?= Date: Fri, 9 Sep 2011 10:56:38 +0200 Subject: [PATCH] Added FIXME comments to BannagePeriodFailureDetector --- .../src/main/scala/akka/cluster/RemoteFailureDetector.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/akka-cluster/src/main/scala/akka/cluster/RemoteFailureDetector.scala b/akka-cluster/src/main/scala/akka/cluster/RemoteFailureDetector.scala index 634f683c61..6f64b9dce3 100644 --- a/akka-cluster/src/main/scala/akka/cluster/RemoteFailureDetector.scala +++ b/akka-cluster/src/main/scala/akka/cluster/RemoteFailureDetector.scala @@ -224,6 +224,8 @@ class BannagePeriodFailureDetector( timeToBan: Duration) extends RemoteFailureDetectorBase(initialConnections) { + // FIXME considering adding a Scheduler event to notify the BannagePeriodFailureDetector unban the banned connection after the timeToBan have exprired + type T = Map[InetSocketAddress, BannedConnection] case class BannedConnection(bannedSince: Long, connection: ActorRef)