From 0bbb6900d72ac89af8c0b8c4b4ec92b6eede311d Mon Sep 17 00:00:00 2001 From: gosubpl Date: Fri, 21 Apr 2017 16:18:49 +0200 Subject: [PATCH] fix race condition in ReplicatorDeltaSpec (#22737) --- .../multi-jvm/scala/akka/cluster/ddata/ReplicatorDeltaSpec.scala | 1 + 1 file changed, 1 insertion(+) diff --git 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 index 7b1f70a26f..6e7685e6b3 100644 --- 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