Do not seek in named pipe

This commit is contained in:
Wim 2015-09-24 21:40:43 +02:00
parent 4b368d1590
commit 52a42ed990
1 changed files with 11 additions and 5 deletions

View File

@ -46,6 +46,7 @@ type Config struct {
ReOpen bool // Reopen recreated files (tail -F)
MustExist bool // Fail early if the file does not exist
Poll bool // Poll for file changes instead of using inotify
Pipe bool // Is a named pipe (mkfifo)
RateLimiter *ratelimiter.LeakyBucket
// Generic IO
@ -217,14 +218,19 @@ func (tail *Tail) tailFileSync() {
tail.openReader()
var offset int64 = 0
var err error
// Read line by line.
for {
// do not seek in named pipes
if !tail.Pipe {
// grab the position in case we need to back up in the event of a half-line
offset, err := tail.Tell()
offset, err = tail.Tell()
if err != nil {
tail.Kill(err)
return
}
}
line, err := tail.readLine()