|
@ -57,7 +57,7 @@ func (logBuffer *LogBuffer) LoopProcessLogData(readerName string, startPosition |
|
|
if bytesBuf != nil { |
|
|
if bytesBuf != nil { |
|
|
readSize = bytesBuf.Len() |
|
|
readSize = bytesBuf.Len() |
|
|
} |
|
|
} |
|
|
glog.V(0).Infof("%s ReadFromBuffer at %v batch %d. Read bytes %v batch %d", readerName, lastReadPosition, lastReadPosition.BatchIndex, readSize, batchIndex) |
|
|
|
|
|
|
|
|
glog.V(4).Infof("%s ReadFromBuffer at %v batch %d. Read bytes %v batch %d", readerName, lastReadPosition, lastReadPosition.BatchIndex, readSize, batchIndex) |
|
|
if bytesBuf == nil { |
|
|
if bytesBuf == nil { |
|
|
if batchIndex >= 0 { |
|
|
if batchIndex >= 0 { |
|
|
lastReadPosition = NewMessagePosition(lastReadPosition.UnixNano(), batchIndex) |
|
|
lastReadPosition = NewMessagePosition(lastReadPosition.UnixNano(), batchIndex) |
|
|