Changeset 57 in code for trunk/server.go

Timestamp:

Feb 17, 2020, 2:46:29 PM (5 years ago)

Author:

contact

Message:

Fix issues related to Ring

• RingConsumer is now used directly in the goroutine responsible for writing downstream messages. This allows the ring buffer not to be consumed on write error.
• RingConsumer now has a channel attached. This allows PRIVMSG messages to always use RingConsumer, instead of also directly pushing messages to all downstream connections.
• Multiple clients with the same history name are now supported.
• Ring is now protected by a mutex

File:

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

trunk/server.go

@@ -39 +39 @@
         upstreamConns   []*upstreamConn
         downstreamConns []*downstreamConn
+}
+
+func newUser(srv *Server, username string) *user {
+        return &user{
+                username: username,
+                srv:      srv,
+        }
 }
 
@@ -117 +124 @@
 func (s *Server) Run() {
         // TODO: multi-user
-        u := &user{username: "jounce", srv: s}
+        u := newUser(s, "jounce")
 
         s.lock.Lock()