Skip to content

Commit

Permalink
revert
Browse files Browse the repository at this point in the history
  • Loading branch information
keakon committed Dec 7, 2018
1 parent 9f419fe commit 8c8a183
Showing 1 changed file with 11 additions and 9 deletions.
20 changes: 11 additions & 9 deletions writer.go
Original file line number Diff line number Diff line change
Expand Up @@ -124,14 +124,15 @@ func (w *BufferedFileWriter) schedule() {
select {
case <-timer.C:
w.locker.Lock()
var err error
if w.writer != nil { // not closed
w.updated = false
err := w.buffer.Flush()
if err != nil {
logError(err)
}
err = w.buffer.Flush()
}
w.locker.Unlock()
if err != nil {
logError(err)
}
case <-w.stopChan:
stopTimer(timer)
return
Expand Down Expand Up @@ -165,8 +166,8 @@ func (w *BufferedFileWriter) Close() error {
}
}
w.writer = nil
close(w.stopChan)
w.locker.Unlock()
close(w.stopChan)
return err
}

Expand Down Expand Up @@ -375,14 +376,15 @@ func (w *TimedRotatingFileWriter) schedule() {
select {
case <-flushTimer.C:
locker.Lock()
var err error
if w.writer != nil { // not closed
w.updated = false
err := w.buffer.Flush()
if err != nil {
logError(err)
}
err = w.buffer.Flush()
}
locker.Unlock()
if err != nil {
logError(err)
}
break flushLoop
case <-rotateTimer.C:
err := w.rotate(rotateTimer)
Expand Down

0 comments on commit 8c8a183

Please sign in to comment.