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

trunk/ring.go

@@ -35 +35 @@
         r.buffer[i] = msg
         r.cur++
+}
+
+func (r *Ring) Cur() uint64 {
+        return r.cur
 }