github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 19:56:01 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #107050 from sunzhaochang/add-close-profiling

Browse Source 
Add Close() for profile
This commit is contained in:
Kubernetes Prow Robot 2021-12-16 10:01:18 -08:00 committed by GitHub
commit eb43b41cfd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
staging/src/k8s.io/kubectl/pkg/cmd/profiling.go
View File

@ -37,11 +37,15 @@ func addProfilingFlags(flags *pflag.FlagSet) {
} }
func initProfiling() error { func initProfiling() error {
var (
f *os.File
err error
)
switch profileName { switch profileName {
case "none": case "none":
return nil return nil
case "cpu": case "cpu":
f, err := os.Create(profileOutput) f, err = os.Create(profileOutput)
if err != nil { if err != nil {
return err return err
} }
@ -68,6 +72,7 @@ func initProfiling() error {
signal.Notify(c, os.Interrupt) signal.Notify(c, os.Interrupt)
go func() { go func() {
<-c <-c
f.Close()
flushProfiling() flushProfiling()
os.Exit(0) os.Exit(0)
}() }()
@ -93,6 +98,7 @@ func flushProfiling() error {
if err != nil { if err != nil {
return err return err
} }
defer f.Close()
profile.WriteTo(f, 0) profile.WriteTo(f, 0)
} }