Changeset 231 in code for trunk/upstream.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/upstream.go (modified) (1 diff)

trunk/upstream.go

@@ -1368 +1368 @@
 
         uc.forEachDownstream(func(dc *downstreamConn) {
-                dc.sendFromUpstream(dc.ringConsumers[uc.network].Consume(), uc)
+                dc.sendFromUpstream(msg, uc)
         })
 }