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

=cdd #16799 Add another test for changed events

Browse source
This commit is contained in:
Christopher Hunt 2015-06-18 16:53:55 +02:00 • committed by Patrik Nordwall
parent 7041c76ba9
commit 62f621d9ed
1 changed files with 27 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

28
akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/ReplicatorSpec.scala
View file

@ -57,6 +57,7 @@ class ReplicatorSpec extends MultiNodeSpec(ReplicatorSpec) with STMultiNodeSpec
val KeyE2 = GCounterKey("E2") val KeyE2 = GCounterKey("E2")
val KeyF = GCounterKey("F") val KeyF = GCounterKey("F")
val KeyG = ORSetKey[String]("G") val KeyG = ORSetKey[String]("G")
val KeyH = ORMapKey[Flag]("H")
val KeyX = GCounterKey("X") val KeyX = GCounterKey("X")
val KeyY = GCounterKey("Y") val KeyY = GCounterKey("Y")
val KeyZ = GCounterKey("Z") val KeyZ = GCounterKey("Z")
@ -295,7 +296,6 @@ class ReplicatorSpec extends MultiNodeSpec(ReplicatorSpec) with STMultiNodeSpec
val c31 = expectMsgPF() { case g @ GetSuccess(KeyC, _) ⇒ g.get(KeyC) } val c31 = expectMsgPF() { case g @ GetSuccess(KeyC, _) ⇒ g.get(KeyC) }
c31.value should be(31) c31.value should be(31)
val c32 = c31 + 1
replicator ! Update(KeyC, GCounter(), WriteLocal)(_ + 1) replicator ! Update(KeyC, GCounter(), WriteLocal)(_ + 1)
expectMsg(UpdateSuccess(KeyC, None)) expectMsg(UpdateSuccess(KeyC, None))
@ -499,5 +499,31 @@ class ReplicatorSpec extends MultiNodeSpec(ReplicatorSpec) with STMultiNodeSpec
enterBarrier("after-8") enterBarrier("after-8")
} }
"check that a remote update and a local update both cause a change event to emit with the merged data" in {
val changedProbe = TestProbe()
runOn(second) {
replicator ! Subscribe(KeyH, changedProbe.ref)
replicator ! Update(KeyH, ORMap.empty[Flag], writeTwo)(_ + ("a" -> Flag(enabled = false)))
changedProbe.expectMsgPF() { case c @ Changed(KeyH) ⇒ c.get(KeyH).entries } should be(Map("a" -> Flag(enabled = false)))
}
enterBarrier("update-h1")
runOn(first) {
replicator ! Update(KeyH, ORMap.empty[Flag], writeTwo)(_ + ("a" -> Flag(enabled = true)))
}
runOn(second) {
changedProbe.expectMsgPF() { case c @ Changed(KeyH) ⇒ c.get(KeyH).entries } should be(Map("a" -> Flag(enabled = true)))
replicator ! Update(KeyH, ORMap.empty[Flag], writeTwo)(_ + ("b" -> Flag(enabled = true)))
changedProbe.expectMsgPF() { case c @ Changed(KeyH) ⇒ c.get(KeyH).entries } should be(
Map("a" -> Flag(enabled = true), "b" -> Flag(enabled = true)))
}
enterBarrier("after-9")
}
} }