Method syncLocked

db.go:1174–1235

(ctx context.Context)

}

func (db *DB) syncLocked(ctx context.Context) (err error) {
	// Track total sync metrics.
	t := time.Now()
	defer func() {
		db.syncNCounter.Inc()
		if err != nil {
			db.syncErrorNCounter.Inc()
		}
		db.syncSecondsCounter.Add(float64(time.Since(t).Seconds()))
	}()

	exec, err := db.newSyncExecutor(ctx)
	if err != nil {
		return err
	} else if exec == nil {
		db.Logger.Debug("sync: no database found")
		return nil
	}
	defer db.applySyncExecutor(exec, true)

	// Ensure WAL has at least one frame in it.
	db.setSyncDiagPhase(diagPhaseEnsureWAL, func(s *diagState) {
		s.lastSyncedWALOffset = exec.state.lastSyncedWALOffset
	})
	if err := db.ensureWALExists(ctx); err != nil {
		return fmt.Errorf("ensure wal exists: %w", err)
	}

	db.setSyncDiagPhase(diagPhaseVerifyAndSync)
	result, err := db.verifyAndSyncWithExecutor(ctx, false, exec)
	if err != nil {
		return err
	}
	exec.applySyncResult(result)

	// Track that data was synced for time-based checkpoint decisions.
	if result.synced {
		exec.state.syncedSinceCheckpoint = true
	}

	db.setSyncDiagPhase(diagPhaseCheckpointIfNeeded, func(s *diagState) {
		s.lastSyncedWALOffset = exec.state.lastSyncedWALOffset
	})
	if err := db.checkpointIfNeeded(ctx, exec, result.origWALSize, result.newWALSize); err != nil {
		return fmt.Errorf("checkpoint: %w", err)
	}

	db.setSyncDiagPhase(diagPhaseUpdateMetrics, func(s *diagState) {
		s.lastSyncedWALOffset = exec.state.lastSyncedWALOffset
	})

	// Compute current index and total shadow WAL size.
	db.txIDGauge.Set(float64(exec.pos.TXID))

	// Update file size metrics.
	if fi, err := os.Stat(db.path); err == nil {
		db.dbSizeGauge.Set(float64(fi.Size()))
	}