Changeset 485 in code for trunk/upstream.go

Timestamp:

Mar 29, 2021, 3:49:50 PM (4 years ago)

Author:

contact

Message:

Introduce deliveredStore

This hides the double-map complexity behind a dedicated type.

File:

• trunk/upstream.go (modified) (2 diffs)

trunk/upstream.go

@@ -1741 +1741 @@
         }
 
-        delivered := uc.network.delivered.Value(entity)
         entityCM := uc.network.casemap(entity)
-        if delivered == nil {
+
+        if !uc.network.delivered.HasTarget(entity) {
                 // This is the first message we receive from this target. Save the last
                 // message ID in delivery receipts, so that we can send the new message
@@ -1753 +1753 @@
                 }
 
-                delivered = make(deliveredClientMap)
-                uc.network.delivered.SetValue(entity, delivered)
-
                 for clientName, _ := range uc.user.clients {
-                        delivered[clientName] = lastID
+                        uc.network.delivered.StoreID(entity, clientName, lastID)
                 }
         }