Skip to content

Commit 75f99c9

Browse files
committed
defer closing the audit file
1 parent 63259b5 commit 75f99c9

File tree

4 files changed

+11
-15
lines changed

4 files changed

+11
-15
lines changed

pkg/minikube/audit/audit.go

+3-4
Original file line numberDiff line numberDiff line change
@@ -76,6 +76,7 @@ func LogCommandEnd(id string) error {
7676
if err := openAuditLog(); err != nil {
7777
return err
7878
}
79+
defer closeAuditLog()
7980
var logs []string
8081
s := bufio.NewScanner(currentLogFile)
8182
for s.Scan() {
@@ -84,9 +85,7 @@ func LogCommandEnd(id string) error {
8485
if err := s.Err(); err != nil {
8586
return fmt.Errorf("failed to read from audit file: %v", err)
8687
}
87-
if err := closeAuditLog(); err != nil {
88-
return err
89-
}
88+
closeAuditLog()
9089
rowSlice, err := logsToRows(logs)
9190
if err != nil {
9291
return fmt.Errorf("failed to convert logs to rows: %v", err)
@@ -118,7 +117,7 @@ func LogCommandEnd(id string) error {
118117
if _, err = currentLogFile.Write([]byte(auditContents)); err != nil {
119118
return fmt.Errorf("failed to write to audit log: %v", err)
120119
}
121-
return closeAuditLog()
120+
return nil
122121
}
123122

124123
// shouldLog returns if the command should be logged.

pkg/minikube/audit/logFile.go

+5-4
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ import (
2020
"fmt"
2121
"os"
2222

23+
"k8s.io/klog/v2"
2324
"k8s.io/minikube/pkg/minikube/localpath"
2425
"k8s.io/minikube/pkg/minikube/out/register"
2526
)
@@ -39,11 +40,10 @@ func openAuditLog() error {
3940
}
4041

4142
// closeAuditLog closes the audit log file
42-
func closeAuditLog() error {
43+
func closeAuditLog() {
4344
if err := currentLogFile.Close(); err != nil {
44-
return fmt.Errorf("failed to close the audit log: %v", err)
45+
klog.Errorf("failed to close the audit log: %v", err)
4546
}
46-
return nil
4747
}
4848

4949
// appendToLog appends the row to the log file.
@@ -56,8 +56,9 @@ func appendToLog(row *row) error {
5656
if err := openAuditLog(); err != nil {
5757
return err
5858
}
59+
defer closeAuditLog()
5960
if _, err := currentLogFile.WriteString(string(bs) + "\n"); err != nil {
6061
return fmt.Errorf("unable to write to audit log: %v", err)
6162
}
62-
return closeAuditLog()
63+
return nil
6364
}

pkg/minikube/audit/logFile_test.go

+2-4
Original file line numberDiff line numberDiff line change
@@ -28,20 +28,18 @@ import (
2828
)
2929

3030
func TestLogFile(t *testing.T) {
31-
t.Run("OpenAndCloseAuditLog", func(t *testing.T) {
31+
t.Run("OpenAuditLog", func(t *testing.T) {
3232
// make sure logs directory exists
3333
if err := os.MkdirAll(filepath.Dir(localpath.AuditLog()), 0755); err != nil {
3434
t.Fatalf("Error creating logs directory: %v", err)
3535
}
3636
if err := openAuditLog(); err != nil {
3737
t.Fatal(err)
3838
}
39-
if err := closeAuditLog(); err != nil {
40-
t.Fatal(err)
41-
}
4239
})
4340

4441
t.Run("AppendToLog", func(t *testing.T) {
42+
defer closeAuditLog()
4543
f, err := os.CreateTemp("", "audit.json")
4644
if err != nil {
4745
t.Fatalf("Error creating temporary file: %v", err)

pkg/minikube/audit/report.go

+1-3
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@ func Report(lastNLines int) (*RawReport, error) {
3535
if err := openAuditLog(); err != nil {
3636
return nil, err
3737
}
38+
defer closeAuditLog()
3839
var logs []string
3940
s := bufio.NewScanner(currentLogFile)
4041
for s.Scan() {
@@ -47,9 +48,6 @@ func Report(lastNLines int) (*RawReport, error) {
4748
if err := s.Err(); err != nil {
4849
return nil, fmt.Errorf("failed to read from audit file: %v", err)
4950
}
50-
if err := closeAuditLog(); err != nil {
51-
return nil, err
52-
}
5351
rows, err := logsToRows(logs)
5452
if err != nil {
5553
return nil, fmt.Errorf("failed to convert logs to rows: %v", err)

0 commit comments

Comments
 (0)