Skip to content

Commit 1ade3a1

Browse files
authored
fix: fix temporary files written to '/dev/shm' not cleaned up (#568) (#569)
Signed-off-by: Jonathan West <[email protected]>
1 parent 3de3136 commit 1ade3a1

File tree

3 files changed

+3
-1
lines changed

3 files changed

+3
-1
lines changed

pkg/utils/io/io.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ import (
55
)
66

77
var (
8+
// TempDir is set to '/dev/shm' if exists, otherwise is "", which defaults to os.TempDir() when passed to os.CreateTemp()
89
TempDir string
910
)
1011

pkg/utils/kube/ctl.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -291,6 +291,7 @@ func (k *KubectlCmd) ManageResources(config *rest.Config, openAPISchema openapi.
291291
_ = f.Close()
292292
err = WriteKubeConfig(config, "", f.Name())
293293
if err != nil {
294+
utils.DeleteFile(f.Name())
294295
return nil, nil, fmt.Errorf("failed to write kubeconfig: %v", err)
295296
}
296297
fact := kubeCmdFactory(f.Name(), "", config)

pkg/utils/kube/resource_ops.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,13 +64,13 @@ func (k *kubectlResourceOperations) runResourceCommand(ctx context.Context, obj
6464
if err != nil {
6565
return "", fmt.Errorf("Failed to generate temp file for manifest: %v", err)
6666
}
67+
defer io.DeleteFile(manifestFile.Name())
6768
if _, err = manifestFile.Write(manifestBytes); err != nil {
6869
return "", fmt.Errorf("Failed to write manifest: %v", err)
6970
}
7071
if err = manifestFile.Close(); err != nil {
7172
return "", fmt.Errorf("Failed to close manifest: %v", err)
7273
}
73-
defer io.DeleteFile(manifestFile.Name())
7474

7575
// log manifest
7676
if k.log.V(1).Enabled() {

0 commit comments

Comments
 (0)