fix race condition in ReplicatorDeltaSpec (#22737)

2017-04-21 16:18:49 +02:00 · 2017-04-21 16:18:49 +02:00 · 0bbb6900d7
commit 0bbb6900d7
parent 082507973a
1 changed files with 1 additions and 0 deletions
--- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorDeltaSpec.scala
+++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorDeltaSpec.scala
@ -241,6 +241,7 @@ class ReplicatorDeltaSpec extends MultiNodeSpec(ReplicatorDeltaSpec) with STMult
      val p = TestProbe()
      deltaReplicator.tell(Get(KeyD, ReadLocal), p.ref)
      p.expectMsgType[GetSuccess[ORSet[String]]].dataValue.elements should ===(Set("a", "A"))
+      enterBarrier("read-1")

      // and also when doing several at the same time (deltas may be reordered) and then we
      // retry with full state to sort it out