Skip to content

Commit c840deb

Browse files
committed
Use buffered signal for calling os.Notify
1 parent c26915c commit c840deb

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

pkg/managed-kubernetes-auditing-toolkit/eks/imds/imds_tester.go

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,16 +5,17 @@ import (
55
"context"
66
"fmt"
77
"io"
8-
v1 "k8s.io/api/core/v1"
9-
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
10-
"k8s.io/apimachinery/pkg/util/wait"
11-
"k8s.io/client-go/kubernetes"
12-
typedv1 "k8s.io/client-go/kubernetes/typed/core/v1"
138
"os"
149
"os/signal"
1510
"strings"
1611
"syscall"
1712
"time"
13+
14+
v1 "k8s.io/api/core/v1"
15+
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
16+
"k8s.io/apimachinery/pkg/util/wait"
17+
"k8s.io/client-go/kubernetes"
18+
typedv1 "k8s.io/client-go/kubernetes/typed/core/v1"
1819
)
1920

2021
type ImdsTester struct {
@@ -131,7 +132,7 @@ func (m *ImdsTester) runCommandInPodAndGetLogs(podName string, command []string)
131132

132133
func (m *ImdsTester) handleCtrlC() {
133134
// If the user interactively cancels the test, clean up the pod
134-
c := make(chan os.Signal)
135+
c := make(chan os.Signal, 1)
135136
signal.Notify(c, os.Interrupt, syscall.SIGTERM)
136137
go func() {
137138
<-c

0 commit comments

Comments
 (0)