mirror of
https://github.com/postgres/postgres.git
synced 2026-03-17 08:03:01 -04:00
aafc05de1b
Introduce new postmaster_child_launch() function that deals with the differences in EXEC_BACKEND mode. Refactor the mechanism of passing information from the parent to child process. Instead of using different command-line arguments when launching the child process in EXEC_BACKEND mode, pass a variable-length blob of startup data along with all the global variables. The contents of that blob depend on the kind of child process being launched. In !EXEC_BACKEND mode, we use the same blob, but it's simply inherited from the parent to child process. Reviewed-by: Tristan Partin, Andres Freund Discussion: https://www.postgresql.org/message-id/7a59b073-5b5b-151e-7ed3-8b01ff7ce9ef@iki.fi
60 lines
2.1 KiB
C
60 lines
2.1 KiB
C
/*--------------------------------------------------------------------
|
|
* bgworker_internals.h
|
|
* POSTGRES pluggable background workers internals
|
|
*
|
|
* Portions Copyright (c) 1996-2024, PostgreSQL Global Development Group
|
|
* Portions Copyright (c) 1994, Regents of the University of California
|
|
*
|
|
* IDENTIFICATION
|
|
* src/include/postmaster/bgworker_internals.h
|
|
*--------------------------------------------------------------------
|
|
*/
|
|
#ifndef BGWORKER_INTERNALS_H
|
|
#define BGWORKER_INTERNALS_H
|
|
|
|
#include "datatype/timestamp.h"
|
|
#include "lib/ilist.h"
|
|
#include "postmaster/bgworker.h"
|
|
|
|
/* GUC options */
|
|
|
|
/*
|
|
* Maximum possible value of parallel workers.
|
|
*/
|
|
#define MAX_PARALLEL_WORKER_LIMIT 1024
|
|
|
|
/*
|
|
* List of background workers, private to postmaster.
|
|
*
|
|
* A worker that requests a database connection during registration will have
|
|
* rw_backend set, and will be present in BackendList. Note: do not rely on
|
|
* rw_backend being non-NULL for shmem-connected workers!
|
|
*/
|
|
typedef struct RegisteredBgWorker
|
|
{
|
|
BackgroundWorker rw_worker; /* its registry entry */
|
|
struct bkend *rw_backend; /* its BackendList entry, or NULL */
|
|
pid_t rw_pid; /* 0 if not running */
|
|
int rw_child_slot;
|
|
TimestampTz rw_crashed_at; /* if not 0, time it last crashed */
|
|
int rw_shmem_slot;
|
|
bool rw_terminate;
|
|
slist_node rw_lnode; /* list link */
|
|
} RegisteredBgWorker;
|
|
|
|
extern PGDLLIMPORT slist_head BackgroundWorkerList;
|
|
|
|
extern Size BackgroundWorkerShmemSize(void);
|
|
extern void BackgroundWorkerShmemInit(void);
|
|
extern void BackgroundWorkerStateChange(bool allow_new_workers);
|
|
extern void ForgetBackgroundWorker(slist_mutable_iter *cur);
|
|
extern void ReportBackgroundWorkerPID(RegisteredBgWorker *);
|
|
extern void ReportBackgroundWorkerExit(slist_mutable_iter *cur);
|
|
extern void BackgroundWorkerStopNotifications(pid_t pid);
|
|
extern void ForgetUnstartedBackgroundWorkers(void);
|
|
extern void ResetBackgroundWorkerCrashTimes(void);
|
|
|
|
/* Entry point for background worker processes */
|
|
extern void BackgroundWorkerMain(char *startup_data, size_t startup_data_len) pg_attribute_noreturn();
|
|
|
|
#endif /* BGWORKER_INTERNALS_H */
|