Skip to content

Commit

Permalink
fix log rotate
Browse files Browse the repository at this point in the history
  • Loading branch information
fatedier committed Mar 18, 2024
1 parent 0a40bf8 commit d1ede5a
Showing 1 changed file with 8 additions and 8 deletions.
16 changes: 8 additions & 8 deletions log/output_rotatefile.go
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ func (fw *RotateFileWriter) Rotate() error {
}

func (fw *RotateFileWriter) rotate() error {
if err := fw.close(); err != nil {
if err := fw.closeFile(); err != nil {
return err
}
if err := fw.openNew(); err != nil {
Expand Down Expand Up @@ -191,7 +191,7 @@ func (fw *RotateFileWriter) dailyRotate() {
}

// Rotate the log file at 0 hour of the day.
if fw.clock.Now().Hour() == 0 {
if nextHour.Hour() == 0 {
fw.Rotate()
// Ensure it's executed only once, even if the waiting period crosses midnight.
time.Sleep(time.Minute)
Expand Down Expand Up @@ -263,17 +263,17 @@ func (fw *RotateFileWriter) clearFiles() error {
func (fw *RotateFileWriter) Close() error {
fw.mu.Lock()
defer fw.mu.Unlock()
return fw.close()
if fw.done != nil {
close(fw.done)
fw.done = nil
}
return fw.closeFile()
}

func (fw *RotateFileWriter) close() error {
func (fw *RotateFileWriter) closeFile() error {
if fw.file == nil {
return nil
}
if fw.done != nil {
close(fw.done)
fw.done = nil
}
err := fw.file.Close()
fw.file = nil
return err
Expand Down

0 comments on commit d1ede5a

Please sign in to comment.