Merge pull request #9282 from benbjohnson/fix-series-segment-replay
Fix series segment replay.pull/9283/head
commit
6b4a21cdb2
|
@ -232,7 +232,7 @@ func (s *SeriesSegment) MaxSeriesID() uint64 {
|
|||
|
||||
// ForEachEntry executes fn for every entry in the segment.
|
||||
func (s *SeriesSegment) ForEachEntry(fn func(flag uint8, id uint64, offset int64, key []byte) error) error {
|
||||
for pos := uint32(SeriesSegmentHeaderSize); pos < s.size; {
|
||||
for pos := uint32(SeriesSegmentHeaderSize); pos < uint32(len(s.data)); {
|
||||
flag, id, key, sz := ReadSeriesEntry(s.data[pos:])
|
||||
if flag == 0 {
|
||||
break
|
||||
|
|
Loading…
Reference in New Issue