Method reclaim

modules/livestore/quarantine.go:54–85

reclaim runs fn for entries whose deadline has passed. Entries are dropped after attempt — a stuck deletion is not retried.

()

// reclaim runs fn for entries whose deadline has passed. Entries are dropped
// after attempt — a stuck deletion is not retried.
func (q *quarantine) reclaim() []ReclaimResult {
	q.mtx.Lock()
	now := time.Now()
	// Allocate a fresh keep slice (rather than reslicing q.entries[:0]) so
	// dropped entries don't sit in the backing array's hidden capacity and
	// keep their captured WAL/complete-block objects from GC.
	var keep []quarantineEntry
	var due []quarantineEntry
	for _, e := range q.entries {
		if !now.Before(e.deadline) {
			due = append(due, e)
		} else {
			keep = append(keep, e)
		}
	}
	q.entries = keep
	q.mtx.Unlock()

	if len(due) == 0 {
		return nil
	}
	results := make([]ReclaimResult, 0, len(due))
	for _, e := range due {
		results = append(results, ReclaimResult{
			BlockID:   e.blockID,
			Tenant:    e.tenant,
			BlockType: e.blockType,
			Err:       e.reclaim(),
		})
	}
	return results
}