Changeset 231 in code for trunk/user.go

Timestamp:

Apr 6, 2020, 4:31:48 PM (5 years ago)

Author:

contact

Message:

Remove downstreamConn.ringConsumers

We no longer need long-lived ring buffer consumers now that
upstreamConn.produce dispatches messages to downstream connections.

File:

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

trunk/user.go

@@ -304 +304 @@
                         dc := e.dc
 
-                        for net, rc := range dc.ringConsumers {
-                                seq := rc.Close()
+                        dc.forEachNetwork(func(net *network) {
+                                seq := net.ring.Cur()
                                 net.history[dc.clientName] = seq
-                        }
+                        })
 
                         for i := range u.downstreamConns {
@@ -350 +350 @@
         }
 
-        u.forEachDownstream(func(dc *downstreamConn) {
-                if dc.network == nil {
-                        dc.ringConsumers[network] = network.ring.NewConsumer(nil)
-                }
-        })
-
         u.networks = append(u.networks, network)
 
@@ -376 +370 @@
                                 dc.Close()
                         }
-                        delete(dc.ringConsumers, net)
                 })