Changeset 22 in code for trunk/server.go

Timestamp:

Feb 6, 2020, 8:11:35 PM (5 years ago)

Author:

contact

Message:

Maintain a list of downstream connections

File:

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

trunk/server.go

@@ -42 +42 @@
         Logger    Logger
         Upstreams []Upstream // TODO: per-user
+
+        downstreamConns []*downstreamConn
 }
 
@@ -62 +64 @@
 func (s *Server) Serve(ln net.Listener) error {
         for {
-                c, err := ln.Accept()
+                netConn, err := ln.Accept()
                 if err != nil {
                         return fmt.Errorf("failed to accept connection: %v", err)
                 }
 
+                conn := newDownstreamConn(s, netConn)
+                s.downstreamConns = append(s.downstreamConns, conn)
                 go func() {
-                        if err := handleConn(s, c); err != nil {
-                                s.Logger.Printf("Error handling connection: %v", err)
+                        if err := conn.readMessages(); err != nil {
+                                conn.logger.Printf("Error handling messages: %v", err)
                         }
                 }()