Removed old LeaderDowningSpec

akka-cluster/src/test/scala/akka/cluster/LeaderDowningSpec.scala

@@ -1,144 +0,0 @@
-/**
- *  Copyright (C) 2009-2012 Typesafe Inc. <http://www.typesafe.com>
- */
-
-package akka.cluster
-
-import akka.testkit._
-import akka.dispatch._
-import akka.actor._
-import akka.remote._
-import akka.util.duration._
-
-import com.typesafe.config._
-
-import java.net.InetSocketAddress
-
-class LeaderDowningSpec extends ClusterSpec with ImplicitSender {
-  val portPrefix = 4
-
-  var node1: Cluster = _
-  var node2: Cluster = _
-  var node3: Cluster = _
-  var node4: Cluster = _
-
-  var system1: ActorSystemImpl = _
-  var system2: ActorSystemImpl = _
-  var system3: ActorSystemImpl = _
-  var system4: ActorSystemImpl = _
-
-  try {
-    "The Leader in a 4 node cluster" must {
-
-      // ======= NODE 1 ========
-      system1 = ActorSystem("system1", ConfigFactory
-        .parseString("""
-          akka {
-            actor.provider = "akka.remote.RemoteActorRefProvider"
-            remote.netty.port = %d550
-          }""".format(portPrefix))
-        .withFallback(system.settings.config))
-        .asInstanceOf[ActorSystemImpl]
-      val remote1 = system1.provider.asInstanceOf[RemoteActorRefProvider]
-      node1 = Cluster(system1)
-      val fd1 = node1.failureDetector
-      val address1 = node1.remoteAddress
-
-      // ======= NODE 2 ========
-      system2 = ActorSystem("system2", ConfigFactory
-        .parseString("""
-          akka {
-            actor.provider = "akka.remote.RemoteActorRefProvider"
-            remote.netty.port = %d551
-            cluster.node-to-join = "akka://system1@localhost:%d550"
-          }""".format(portPrefix, portPrefix))
-        .withFallback(system.settings.config))
-        .asInstanceOf[ActorSystemImpl]
-      val remote2 = system2.provider.asInstanceOf[RemoteActorRefProvider]
-      node2 = Cluster(system2)
-      val fd2 = node2.failureDetector
-      val address2 = node2.remoteAddress
-
-      // ======= NODE 3 ========
-      system3 = ActorSystem("system3", ConfigFactory
-        .parseString("""
-          akka {
-            actor.provider = "akka.remote.RemoteActorRefProvider"
-            remote.netty.port = %d552
-            cluster.node-to-join = "akka://system1@localhost:%d550"
-          }""".format(portPrefix, portPrefix))
-        .withFallback(system.settings.config))
-        .asInstanceOf[ActorSystemImpl]
-      val remote3 = system3.provider.asInstanceOf[RemoteActorRefProvider]
-      node3 = Cluster(system3)
-      val fd3 = node3.failureDetector
-      val address3 = node3.remoteAddress
-
-      // ======= NODE 4 ========
-      system4 = ActorSystem("system4", ConfigFactory
-        .parseString("""
-          akka {
-            actor.provider = "akka.remote.RemoteActorRefProvider"
-            remote.netty.port = %d553
-            cluster.node-to-join = "akka://system1@localhost:%d550"
-          }""".format(portPrefix, portPrefix))
-        .withFallback(system.settings.config))
-        .asInstanceOf[ActorSystemImpl]
-      val remote4 = system4.provider.asInstanceOf[RemoteActorRefProvider]
-      node4 = Cluster(system4)
-      val fd4 = node4.failureDetector
-      val address4 = node4.remoteAddress
-
-      "be able to DOWN a (last) node that is UNREACHABLE" taggedAs LongRunningTest in {
-
-        println("Give the system time to converge...")
-        awaitConvergence(node1 :: node2 :: node3 :: node4 :: Nil)
-
-        // shut down system4
-        node4.shutdown()
-        system4.shutdown()
-
-        // wait for convergence - e.g. the leader to auto-down the failed node
-        println("Give the system time to converge...")
-        Thread.sleep(30.seconds.dilated.toMillis)
-        awaitConvergence(node1 :: node2 :: node3 :: Nil)
-
-        node1.latestGossip.members.size must be(3)
-        node1.latestGossip.members.exists(_.address == address4) must be(false)
-      }
-
-      "be able to DOWN a (middle) node that is UNREACHABLE" taggedAs LongRunningTest in {
-        // shut down system4
-        node2.shutdown()
-        system2.shutdown()
-
-        // wait for convergence - e.g. the leader to auto-down the failed node
-        println("Give the system time to converge...")
-        Thread.sleep(30.seconds.dilated.toMillis)
-        awaitConvergence(node1 :: node3 :: Nil)
-
-        node1.latestGossip.members.size must be(2)
-        node1.latestGossip.members.exists(_.address == address4) must be(false)
-        node1.latestGossip.members.exists(_.address == address2) must be(false)
-      }
-    }
-  } catch {
-    case e: Exception ⇒
-      e.printStackTrace
-      fail(e.toString)
-  }
-
-  override def atTermination() {
-    if (node1 ne null) node1.shutdown()
-    if (system1 ne null) system1.shutdown()
-
-    if (node2 ne null) node2.shutdown()
-    if (system2 ne null) system2.shutdown()
-
-    if (node3 ne null) node3.shutdown()
-    if (system3 ne null) system3.shutdown()
-
-    if (node4 ne null) node4.shutdown()
-    if (system4 ne null) system4.shutdown()
-  }
-}