Changeset 406 in code for trunk/upstream.go

Timestamp:

Aug 20, 2020, 3:38:57 PM (5 years ago)

Author:

contact

Message:

Replace networkHistory.offlineClients with clients

Keep the ring buffer alive even if all clients are connected. Keep the
ID of the latest delivered message even for online clients.

As-is, this is a net downgrade: memory usage increases because ring
buffers aren't free'd anymore. However upcoming commits will replace the
ring buffer with log files. This change makes reading from log files
easier.

File:

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

trunk/upstream.go

@@ -1636 +1636 @@
         }
 
-        // If no client is offline, no need to append the message to the buffer
-        if len(uc.network.offlineClients) == 0 && !detached {
-                return
-        }
-
         history, ok := uc.network.history[entity]
         if !ok {
                 history = &networkHistory{
-                        offlineClients: make(map[string]uint64),
-                        ring:           NewRing(uc.srv.RingCap),
+                        clients: make(map[string]uint64),
+                        ring:    NewRing(uc.srv.RingCap),
                 }
                 uc.network.history[entity] = history
 
                 for clientName, _ := range uc.network.offlineClients {
-                        history.offlineClients[clientName] = 0
+                        history.clients[clientName] = 0
                 }
 
@@ -1657 +1652 @@
                         // clients too
                         uc.forEachDownstream(func(dc *downstreamConn) {
-                                history.offlineClients[dc.clientName] = 0
+                                history.clients[dc.clientName] = 0
                         })
                 }
@@ -1663 +1658 @@
 
         history.ring.Produce(msg)
+
+        if !detached {
+                uc.forEachDownstream(func(dc *downstreamConn) {
+                        history.clients[dc.clientName] = history.ring.Cur()
+                })
+        }
 }