dual_selector: don't cancel reference context

IrineSistiana · Feb 26, 2022 · 2287bd5 · 2287bd5
1 parent ea2d0e8
commit 2287bd5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/dispatcher/plugin/executable/dual_selector/dual_selector.go b/dispatcher/plugin/executable/dual_selector/dual_selector.go
@@ -97,11 +97,12 @@ func (s *Selector) Exec(ctx context.Context, qCtx *handler.Context, next handler
 	if !ok {
 		ddl = time.Now().Add(defaultSubRoutineTimout)
 	}
-	ctxRef, cancelRef := context.WithDeadline(context.Background(), ddl)
-	defer cancelRef()
+
 	shouldBlock := make(chan struct{}, 0)
 	shouldPass := make(chan struct{}, 0)
+	ctxRef, cancelRef := context.WithDeadline(context.Background(), ddl)
 	go func() {
+		defer cancelRef()
 		err := handler.ExecChainNode(ctxRef, qCtxRef, next)
 		if err != nil {
 			s.L().Warn("reference query routine err", qCtxRef.InfoField(), zap.Error(err))