slow_query: cancel send taskList if ctx is done (#27471)

* slow_query: cancel send taskList if ctx is done Signed-off-by: tison <wander4096@gmail.com>
pingcap · Aug 23, 2021 · 529fc03 · 529fc03
1 parent f36f78f
commit 529fc03
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/executor/slow_query.go b/executor/slow_query.go
@@ -433,7 +433,11 @@ func (e *slowQueryRetriever) parseSlowLog(ctx context.Context, sctx sessionctx.C
 		if err != nil {
 			t := slowLogTask{}
 			t.resultCh = make(chan parsedSlowLog, 1)
-			e.taskList <- t
+			select {
+			case <-ctx.Done():
+				return
+			case e.taskList <- t:
+			}
 			e.sendParsedSlowLogCh(ctx, t, parsedSlowLog{nil, err})
 		}
 		if len(logs) == 0 || len(logs[0]) == 0 {