Skip to content

Commit 7b8c50b

Browse files
committed
db: include obsolete blob files for delete pacer
1 parent 3054406 commit 7b8c50b

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

obsolete_files.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -345,8 +345,9 @@ func (d *DB) getDeletionPacerInfo() deletionPacerInfo {
345345
// take 10 microseconds or less.
346346
pacerInfo.freeBytes = d.calculateDiskAvailableBytes()
347347
d.mu.Lock()
348-
pacerInfo.obsoleteBytes = d.mu.versions.metrics.Table.ObsoleteSize
349-
total := d.mu.versions.metrics.Total()
348+
m := &d.mu.versions.metrics
349+
pacerInfo.obsoleteBytes = m.Table.ObsoleteSize + m.BlobFiles.ObsoleteSize
350+
total := m.Total()
350351
d.mu.Unlock()
351352
pacerInfo.liveBytes = uint64(total.AggregateSize())
352353
return pacerInfo

0 commit comments

Comments
 (0)