Fix read buffer usage (#4860)

Signed-off-by: Changxin Miao <[email protected]>
juicedata · May 17, 2024 · 5c63ef6 · 5c63ef6
1 parent 66c4c94
commit 5c63ef6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/vfs/reader.go b/pkg/vfs/reader.go
@@ -269,8 +269,8 @@ func (s *sliceReader) delete() {
 	} else {
 		s.file.last = s.prev
 	}
+	atomic.AddInt64(&readBufferUsed, -int64(cap(s.page.Data)))
 	s.page.Release()
-	atomic.AddInt64(&readBufferUsed, -int64(s.block.len))
 }
 
 type session struct {
@@ -327,7 +327,7 @@ func (f *fileReader) newSlice(block *frange) *sliceReader {
 	*(f.last) = s
 	f.last = &(s.next)
 	go s.run()
-	atomic.AddInt64(&readBufferUsed, int64(s.block.len))
+	atomic.AddInt64(&readBufferUsed, int64(cap(s.page.Data)))
 	return s
 }