Changeset 23 in code for trunk/server.go

Timestamp:

Feb 6, 2020, 8:20:22 PM (5 years ago)

Author:

contact

Message:

Allow Server to have access to upstreamConn

File:

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

trunk/server.go

@@ -55 +55 @@
                 // TODO: retry connecting
                 go func() {
-                        if err := connect(s, upstream); err != nil {
-                                s.Logger.Printf("Failed to connect to upstream server %q: %v", upstream.Addr, err)
+                        conn, err := connectToUpstream(s, upstream)
+                        if err != nil {
+                                s.Logger.Printf("failed to connect to upstream server %q: %v", upstream.Addr, err)
+                                return
+                        }
+                        if err := conn.readMessages(); err != nil {
+                                conn.logger.Printf("failed to handle messages: %v", err)
                         }
                 }()
@@ -73 +78 @@
                 go func() {
                         if err := conn.readMessages(); err != nil {
-                                conn.logger.Printf("Error handling messages: %v", err)
+                                conn.logger.Printf("failed to handle messages: %v", err)
                         }
                 }()