Method loadHintFile

db.go:653–752

loadHintFile loads a single hint file and rebuilds indexes

(fid int64)

// loadHintFile loads a single hint file and rebuilds indexes
func (db *DB) loadHintFile(fid int64) (bool, error) {
	hintPath := getHintPath(fid, db.opt.Dir)

	// Check if hint file exists
	if _, err := os.Stat(hintPath); os.IsNotExist(err) {
		return false, nil // Hint file doesn't exist, need to scan data file
	}

	reader := &HintFileReader{}
	if err := reader.Open(hintPath); err != nil {
		return false, nil
	}
	defer func() {
		if err := reader.Close(); err != nil {
			// Log error but don't fail the operation
			utils.GetLogger().Printf("Warning: failed to close hint file reader: %v", err)
		}
	}()

	// Read all hint entries and build indexes
	for {
		hintEntry, err := reader.Read()
		if err != nil {
			if err == io.EOF {
				break // End of file
			}
			return false, nil
		}

		if hintEntry == nil {
			continue
		}

		// Check if bucket exists
		bucketId := hintEntry.BucketId
		if _, err := db.bucketMgr.GetBucketById(bucketId); errors.Is(err, ErrBucketNotExist) {
			continue // Skip if bucket doesn't exist
		}

		// Create a record from hint entry
		record := core.NewRecord()
		record.WithKey(hintEntry.Key).
			WithFileId(hintEntry.FileID).
			WithDataPos(hintEntry.DataPos).
			WithValueSize(hintEntry.ValueSize).
			WithTimestamp(hintEntry.Timestamp).
			WithTTL(hintEntry.TTL).
			WithTxID(0) // TxID is not stored in hint file

		// Create an entry from hint entry
		entry := core.NewEntry()
		entry.WithKey(hintEntry.Key)

		// Create metadata
		meta := core.NewMetaData()
		meta.WithBucketId(hintEntry.BucketId).
			WithKeySize(hintEntry.KeySize).
			WithValueSize(hintEntry.ValueSize).