PostgreSQL Source Code
git master
|
Go to the source code of this file.
Functions | |
void | ApplyLauncherRegister (void) |
void | ApplyLauncherMain (Datum main_arg) |
Size | ApplyLauncherShmemSize (void) |
void | ApplyLauncherShmemInit (void) |
void | ApplyLauncherWakeupAtCommit (void) |
void | AtEOXact_ApplyLauncher (bool isCommit) |
bool | IsLogicalLauncher (void) |
Variables | |
PGDLLIMPORT int | max_logical_replication_workers |
PGDLLIMPORT int | max_sync_workers_per_subscription |
void ApplyLauncherMain | ( | Datum | main_arg | ) |
Definition at line 801 of file launcher.c.
References ALLOCSET_DEFAULT_SIZES, AllocSetContextCreate, Assert(), BackgroundWorkerInitializeConnection(), BackgroundWorkerUnblockSignals(), before_shmem_exit(), CHECK_FOR_INTERRUPTS, ConfigReloadPending, Subscription::dbid, DEBUG1, DEFAULT_NAPTIME_PER_CYCLE, die, Subscription::enabled, ereport, errmsg_internal(), get_subscription_list(), GetCurrentTimestamp(), InvalidOid, LogicalRepCtxStruct::launcher_pid, lfirst, logicalrep_launcher_onexit(), logicalrep_worker_find(), logicalrep_worker_launch(), LogicalRepCtx, LW_SHARED, LWLockAcquire(), LWLockRelease(), MemoryContextDelete(), MemoryContextSwitchTo(), MyLatch, MyProcPid, Subscription::name, now(), Subscription::oid, Subscription::owner, PGC_SIGHUP, pqsignal(), ProcessConfigFile(), ResetLatch(), SIGHUP, SignalHandlerForConfigReload(), TimestampDifferenceExceeds(), TopMemoryContext, WAIT_EVENT_LOGICAL_LAUNCHER_MAIN, WaitLatch(), wal_retrieve_retry_interval, WL_EXIT_ON_PM_DEATH, WL_LATCH_SET, and WL_TIMEOUT.
void ApplyLauncherRegister | ( | void | ) |
Definition at line 706 of file launcher.c.
References BackgroundWorker::bgw_flags, BackgroundWorker::bgw_function_name, BackgroundWorker::bgw_library_name, BackgroundWorker::bgw_main_arg, BGW_MAXLEN, BackgroundWorker::bgw_name, BackgroundWorker::bgw_notify_pid, BackgroundWorker::bgw_restart_time, BackgroundWorker::bgw_start_time, BackgroundWorker::bgw_type, BGWORKER_BACKEND_DATABASE_CONNECTION, BGWORKER_SHMEM_ACCESS, BgWorkerStart_RecoveryFinished, max_logical_replication_workers, RegisterBackgroundWorker(), and snprintf.
Referenced by PostmasterMain().
void ApplyLauncherShmemInit | ( | void | ) |
Definition at line 735 of file launcher.c.
References ApplyLauncherShmemSize(), LogicalRepCtx, max_logical_replication_workers, LogicalRepWorker::relmutex, ShmemInitStruct(), SpinLockInit, and LogicalRepCtxStruct::workers.
Referenced by CreateSharedMemoryAndSemaphores().
Size ApplyLauncherShmemSize | ( | void | ) |
Definition at line 687 of file launcher.c.
References add_size(), max_logical_replication_workers, MAXALIGN, and mul_size().
Referenced by ApplyLauncherShmemInit(), and CalculateShmemSize().
void ApplyLauncherWakeupAtCommit | ( | void | ) |
Definition at line 784 of file launcher.c.
References on_commit_launcher_wakeup.
Referenced by AlterSubscription(), AlterSubscriptionOwner_internal(), and CreateSubscription().
void AtEOXact_ApplyLauncher | ( | bool | isCommit | ) |
Definition at line 765 of file launcher.c.
References ApplyLauncherWakeup(), and on_commit_launcher_wakeup.
Referenced by AbortTransaction(), and CommitTransaction().
bool IsLogicalLauncher | ( | void | ) |
Definition at line 917 of file launcher.c.
References LogicalRepCtxStruct::launcher_pid, LogicalRepCtx, and MyProcPid.
Referenced by ProcessInterrupts().
|
extern |
Definition at line 55 of file launcher.c.
Referenced by ApplyLauncherRegister(), ApplyLauncherShmemInit(), ApplyLauncherShmemSize(), logicalrep_sync_worker_count(), logicalrep_worker_attach(), logicalrep_worker_find(), logicalrep_worker_launch(), logicalrep_workers_find(), and pg_stat_get_subscription().
|
extern |
Definition at line 56 of file launcher.c.
Referenced by logicalrep_worker_launch(), and process_syncing_tables_for_apply().