github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-15 14:53:44 +00:00
Code Issues Projects Releases Wiki Activity

adds return context in RunPortForward()

Browse Source
This commit is contained in:
Sean Sullivan 2024-03-01 21:10:32 -08:00
parent 8b447d8c97
commit 9e15462843
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
staging/src/k8s.io/kubectl/pkg/cmd/portforward/portforward.go
View File

@ -420,10 +420,13 @@ func (o PortForwardOptions) RunPortForwardContext(ctx context.Context) error {
signal.Notify(signals, os.Interrupt) signal.Notify(signals, os.Interrupt)
defer signal.Stop(signals) defer signal.Stop(signals)
returnCtx, returnCtxCancel := context.WithCancel(ctx)
defer returnCtxCancel()
go func() { go func() {
select { select {
case <-signals: case <-signals:
case <-ctx.Done(): case <-returnCtx.Done():
} }
if o.StopChannel != nil { if o.StopChannel != nil {
close(o.StopChannel) close(o.StopChannel)