Changeset 703 in code for trunk/downstream.go

Timestamp:

Nov 17, 2021, 12:13:55 PM (4 years ago)

Author:

contact

Message:

Introduce conn.NewContext

This function wraps a parent context, and returns a new context
cancelled when the connection is closed. This will make it so
operations started from downstreamConn.handleMessage will be
cancelled when the connection is closed.

File:

• trunk/downstream.go (modified) (1 diff)

trunk/downstream.go

@@ -616 +616 @@
 
 func (dc *downstreamConn) handleMessage(msg *irc.Message) error {
-        ctx, cancel := context.WithTimeout(context.TODO(), handleDownstreamMessageTimeout)
+        ctx, cancel := dc.conn.NewContext(context.TODO())
+        defer cancel()
+
+        ctx, cancel = context.WithTimeout(ctx, handleDownstreamMessageTimeout)
         defer cancel()