add error log for open log file
This commit is contained in:
parent
ba33b5a25b
commit
2c1d001857
@ -93,6 +93,7 @@ func (t *Tail) attemptOpen() error {
|
|||||||
defer t.readerLock.Unlock()
|
defer t.readerLock.Unlock()
|
||||||
t.readerErr = nil
|
t.readerErr = nil
|
||||||
attempt := 0
|
attempt := 0
|
||||||
|
var lastErr error
|
||||||
for interval := defaultRetryInterval; ; interval *= 2 {
|
for interval := defaultRetryInterval; ; interval *= 2 {
|
||||||
attempt++
|
attempt++
|
||||||
glog.V(4).Infof("Opening %s (attempt %d)", t.filename, attempt)
|
glog.V(4).Infof("Opening %s (attempt %d)", t.filename, attempt)
|
||||||
@ -104,6 +105,9 @@ func (t *Tail) attemptOpen() error {
|
|||||||
t.reader = bufio.NewReader(t.file)
|
t.reader = bufio.NewReader(t.file)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
lastErr = err
|
||||||
|
glog.V(4).Infof("open log file %s error: %v", t.filename, err)
|
||||||
|
|
||||||
if interval >= maxRetryInterval {
|
if interval >= maxRetryInterval {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
@ -114,7 +118,7 @@ func (t *Tail) attemptOpen() error {
|
|||||||
return fmt.Errorf("watch was cancelled")
|
return fmt.Errorf("watch was cancelled")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
err := fmt.Errorf("can't open log file %s", t.filename)
|
err := fmt.Errorf("can't open log file %s: %v", t.filename, lastErr)
|
||||||
t.readerErr = err
|
t.readerErr = err
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user