filter out known payloads … ?

rescala-lang · Nov 9, 2024 · 7d2d170 · 7d2d170
1 parent 4723dfb
commit 7d2d170
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/Modules/Replication/shared/src/main/scala/replication/DataManager.scala b/Modules/Replication/shared/src/main/scala/replication/DataManager.scala
@@ -156,6 +156,7 @@ class DataManager[State](
           biChan.send(Payload(replicaId.uid, msg.context, msg.data)).run(using ())(debugCallbackAndRemoveCon(biChan))
         updateContext(uid, selfContext `merge` knows)
       case Payload(uid, context, data) =>
+        if context <= selfContext then return
         val internalized = ProtocolDots[State](data, context)
         lock.synchronized {
           updateContext(uid, context)