Skip to content

Commit ce6296e

Browse files
committed
在dir模式下,文件采集出现 倒序的问题
1 parent eb01537 commit ce6296e

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

reader/dirx/dir_reader.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ func (dr *dirReader) Run() {
126126

127127
if err == nil && dr.halfLineCache[source] != "" {
128128
dr.readLock.Lock()
129-
dr.readcache += dr.halfLineCache[source]
129+
dr.readcache = dr.halfLineCache[source] + dr.readcache
130130
dr.halfLineCache[source] = ""
131131
dr.readLock.Unlock()
132132
}

reader/tailx/tailx.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -342,7 +342,7 @@ func (ar *ActiveReader) Run() {
342342

343343
if err == nil && ar.halfLineCache[source] != "" {
344344
ar.cacheLineMux.Lock()
345-
ar.readcache += ar.halfLineCache[source]
345+
ar.readcache = ar.halfLineCache[source] + ar.readcache
346346
ar.halfLineCache[source] = ""
347347
ar.cacheLineMux.Unlock()
348348
}

0 commit comments

Comments
 (0)