Method handleExpiredKeys

db.go:1102–1144

handleExpiredKeys processes a batch of expiration events in a single transaction. This batch processing approach significantly reduces transaction overhead compared to processing each expired key individually. It validates timestamps to prevent race conditions where a key is: 1. Set with TTL (times

(events []*ttl.ExpirationEvent)

//
// By comparing timestamps, we ensure only the originally expired key is deleted.
func (db *DB) handleExpiredKeys(events []*ttl.ExpirationEvent) {
	if len(events) == 0 {
		return
	}

	_ = db.Update(func(tx *Tx) error {
		// Group events by bucket to avoid repeated bucket lookups
		bucketEvents := make(map[uint64][]*ttl.ExpirationEvent)
		for _, event := range events {
			bucketEvents[event.BucketId] = append(bucketEvents[event.BucketId], event)
		}

		for bucketId, evs := range bucketEvents {
			bucket, err := db.bucketMgr.GetBucketById(bucketId)
			if err != nil {
				continue
			}

			idx, ok := db.Index.BTree.exist(bucketId)
			if !ok {
				continue
			}

			for _, event := range evs {
				// Use FindForVerification to get the record without triggering callbacks (avoid recursion)
				record, found := idx.FindForVerification(event.Key)
				if !found {
					continue
				}

				// Only delete if timestamp matches (same record that expired)
				// Also verify it's actually expired (in case it was updated)
				if record.Timestamp == event.Timestamp && db.ttlService.IsExpired(record.TTL, record.Timestamp) {
					_ = tx.put(bucket.Name, event.Key, nil, Persistent, DataDeleteFlag, uint64(db.ttlService.NowMillis()), bucket.Ds)
					// Deregister from timing wheel to prevent duplicate expiration events
					db.ttlService.DeregisterKeyFromActiveExpiration(bucketId, event.Key)
				}
			}
		}

		return nil
	})
}

func (db *DB) rebuildBucketManager() error {
	bucketFilePath := db.opt.Dir + "/" + BucketStoreFileName