Method Close

db.go:767–820

Close flushes outstanding WAL writes to replicas, releases the read lock, and closes the database. If Done is set, closing it interrupts the shutdown sync retry loop and cancels any in-flight sync attempt.

(ctx context.Context)

// and closes the database. If Done is set, closing it interrupts the shutdown
// sync retry loop and cancels any in-flight sync attempt.
func (db *DB) Close(ctx context.Context) (err error) {
	db.cancel()
	db.wg.Wait()

	db.execMu.Lock()
	defer db.execMu.Unlock()

	// Perform a final db sync, if initialized.
	if db.db != nil {
		if e := db.syncLocked(ctx); e != nil {
			err = e
		}
	}

	// Ensure replicas perform a final sync and stop replicating.
	if db.Replica != nil {
		if db.db != nil {
			if e := db.syncReplicaWithRetry(ctx); e != nil && err == nil {
				err = e
			}
		}
		db.Replica.Stop(true)
	}

	// Release the read lock to allow other applications to handle checkpointing.
	if db.rtx != nil {
		if e := db.releaseReadLock(); e != nil && err == nil {
			err = e
		}
	}

	db.mu.Lock()
	sqlDB := db.db
	f := db.f
	db.db = nil
	db.f = nil
	db.opened = false
	db.rtx = nil
	db.mu.Unlock()

	if sqlDB != nil {
		if e := sqlDB.Close(); e != nil && err == nil {
			err = e
		}
	}

	if f != nil {
		if e := f.Close(); e != nil && err == nil {
			err = e
		}
	}

	return err
}

// syncReplicaWithRetry attempts to sync the replica with retry logic for shutdown.
// It retries until success, timeout, or context cancellation. If db.Done is non-nil,