Changeset 51 in code for trunk/downstream.go

Timestamp:

Feb 7, 2020, 4:35:57 PM (5 years ago)

Author:

contact

Message:

Add names to consumers

File:

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

trunk/downstream.go

@@ -129 +129 @@
                 }
                 u.lock.Unlock()
+
+                // TODO: figure out a better way to advance the ring buffer consumer cursor
+                u.forEachUpstream(func(uc *upstreamConn) {
+                        // TODO: let clients specify the ring buffer name in their username
+                        uc.ring.Consumer("").Reset()
+                })
         }
 
@@ -233 +239 @@
                 }
 
-                consumer := uc.ring.Consumer()
+                // TODO: let clients specify the ring buffer name in their username
+                consumer := uc.ring.Consumer("")
                 for {
+                        // TODO: these messages will get lost if the connection is closed
                         msg := consumer.Consume()
                         if msg == nil {