2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-17 13:13:18 +00:00

Fix erroneous data injection to log replay

When a rollover event was detected, the offset
of the rollover event itself was being read
from the rolled file erroneously.  Skip to
next loop iteration so that the metadata about
the rollover event is properly ignored in building
the text data buffer.
This commit is contained in:
Jarrod Johnson 2015-09-30 13:48:04 -04:00
parent f78a4d6074
commit 1f8bc635a8

View File

@ -633,6 +633,9 @@ class Logger(object):
flock(binfile, LOCK_SH)
binfile.seek(0, 2)
binidx = binfile.tell()
# things have been set up for next iteration to dig to
# previous log file, go to next iteration
continue
elif ltype != 2:
continue
if tstamp > recenttimestamp: