Changeset 45 in code for trunk/downstream.go

Timestamp:

Feb 7, 2020, 11:42:24 AM (5 years ago)

Author:

contact

Message:

Close connection from writer goroutine

Connections were being closed from the reader goroutine, causing issues
when sending messages and immediately closing the connection.

File:

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

trunk/downstream.go

@@ -71 +71 @@
                         }
                 }
+                if err := conn.net.Close(); err != nil {
+                        conn.logger.Printf("failed to close connection: %v", err)
+                } else {
+                        conn.logger.Printf("connection closed")
+                }
         }()
 
@@ -86 +91 @@
 func (c *downstreamConn) readMessages() error {
         c.logger.Printf("new connection")
-        defer c.Close()
 
         for {
@@ -109 +113 @@
         }
 
-        return c.Close()
+        return nil
 }
 
@@ -130 +134 @@
         c.closed = true
 
-        return c.net.Close()
+        return nil
 }