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

Verify removal and add of new node incarnation in multi-dc, #23585

Browse source 
* MemberRemoved must be published before MemberUp, e.g. when restarted
  in other DC
* remove from failureDetector when receiving gossip with new member,
  not only new joining member

* increase timeout in MultiDcSingletonManagerSpec
This commit is contained in:
Patrik Nordwall 2017-09-04 13:21:34 +02:00
parent 9df5d80268
commit 5fc6d5a04a
8 changed files with 169 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-cluster-tools/src/multi-jvm/scala/akka/cluster/singleton/MultiDcSingletonManagerSpec.scala
View file

@ -21,7 +21,7 @@ object MultiDcSingletonManagerSpec extends MultiNodeConfig {
val third = role("third")
commonConfig(ConfigFactory.parseString("""
akka.loglevel = INFO
akka.loglevel = DEBUG
akka.actor.provider = "cluster"
akka.actor.serialize-creators = off
akka.remote.log-remote-lifecycle-events = off"""))
@ -94,7 +94,7 @@ abstract class MultiDcSingletonManagerSpec extends MultiNodeSpec(MultiDcSingleto
enterBarrier("managers-started")
proxy ! MultiDcSingleton.Ping
val pong = expectMsgType[MultiDcSingleton.Pong](10.seconds)
val pong = expectMsgType[MultiDcSingleton.Pong](20.seconds)
enterBarrier("pongs-received")