Changeset 50 in code for trunk/upstream.go

Timestamp:

Feb 7, 2020, 3:43:54 PM (5 years ago)

Author:

contact

Message:

Add an in-memory ring buffer

References: ​https://todo.sr.ht/~emersion/jounce/2

File:

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

trunk/upstream.go

@@ -33 +33 @@
         user     *user
         messages chan<- *irc.Message
+        ring     *Ring
 
         serverName            string
@@ -64 +65 @@
                 user:     u,
                 messages: msgs,
+                ring:     NewRing(u.srv.RingCap),
                 channels: make(map[string]*upstreamChannel),
         }
@@ -303 +305 @@
                 })
         case "PRIVMSG":
+                c.ring.Produce(msg)
                 c.user.forEachDownstream(func(dc *downstreamConn) {
                         dc.messages <- msg