diff options
Diffstat (limited to 'weed/util/log_buffer/sealed_buffer.go')
| -rw-r--r-- | weed/util/log_buffer/sealed_buffer.go | 19 |
1 files changed, 11 insertions, 8 deletions
diff --git a/weed/util/log_buffer/sealed_buffer.go b/weed/util/log_buffer/sealed_buffer.go index c41b30fcc..397dab1d4 100644 --- a/weed/util/log_buffer/sealed_buffer.go +++ b/weed/util/log_buffer/sealed_buffer.go @@ -6,11 +6,12 @@ import ( ) type MemBuffer struct { - buf []byte - size int - startTime time.Time - stopTime time.Time - batchIndex int64 + buf []byte + size int + startTime time.Time + stopTime time.Time + startOffset int64 // First offset in this buffer + offset int64 // Last offset in this buffer (endOffset) } type SealedBuffers struct { @@ -30,7 +31,7 @@ func newSealedBuffers(size int) *SealedBuffers { return sbs } -func (sbs *SealedBuffers) SealBuffer(startTime, stopTime time.Time, buf []byte, pos int, batchIndex int64) (newBuf []byte) { +func (sbs *SealedBuffers) SealBuffer(startTime, stopTime time.Time, buf []byte, pos int, startOffset int64, endOffset int64) (newBuf []byte) { oldMemBuffer := sbs.buffers[0] size := len(sbs.buffers) for i := 0; i < size-1; i++ { @@ -38,13 +39,15 @@ func (sbs *SealedBuffers) SealBuffer(startTime, stopTime time.Time, buf []byte, sbs.buffers[i].size = sbs.buffers[i+1].size sbs.buffers[i].startTime = sbs.buffers[i+1].startTime sbs.buffers[i].stopTime = sbs.buffers[i+1].stopTime - sbs.buffers[i].batchIndex = sbs.buffers[i+1].batchIndex + sbs.buffers[i].startOffset = sbs.buffers[i+1].startOffset + sbs.buffers[i].offset = sbs.buffers[i+1].offset } sbs.buffers[size-1].buf = buf sbs.buffers[size-1].size = pos sbs.buffers[size-1].startTime = startTime sbs.buffers[size-1].stopTime = stopTime - sbs.buffers[size-1].batchIndex = batchIndex + sbs.buffers[size-1].startOffset = startOffset + sbs.buffers[size-1].offset = endOffset return oldMemBuffer.buf } |