mirror of
https://github.com/postgres/postgres.git
synced 2026-04-21 14:19:26 -04:00
924bcf4f16
This does four basic things. First, it provides convenience routines to coordinate the startup and shutdown of parallel workers. Second, it synchronizes various pieces of state (e.g. GUCs, combo CID mappings, transaction snapshot) from the parallel group leader to the worker processes. Third, it prohibits various operations that would result in unsafe changes to that state while parallelism is active. Finally, it propagates events that would result in an ErrorResponse, NoticeResponse, or NotifyResponse message being sent to the client from the parallel workers back to the master, from which they can then be sent on to the client. Robert Haas, Amit Kapila, Noah Misch, Rushabh Lathia, Jeevan Chalke. Suggestions and review from Andres Freund, Heikki Linnakangas, Noah Misch, Simon Riggs, Euler Taveira, and Jim Nasby.
60 lines
1.9 KiB
C
60 lines
1.9 KiB
C
/*-------------------------------------------------------------------------
|
|
*
|
|
* procsignal.h
|
|
* Routines for interprocess signalling
|
|
*
|
|
*
|
|
* Portions Copyright (c) 1996-2015, PostgreSQL Global Development Group
|
|
* Portions Copyright (c) 1994, Regents of the University of California
|
|
*
|
|
* src/include/storage/procsignal.h
|
|
*
|
|
*-------------------------------------------------------------------------
|
|
*/
|
|
#ifndef PROCSIGNAL_H
|
|
#define PROCSIGNAL_H
|
|
|
|
#include "storage/backendid.h"
|
|
|
|
|
|
/*
|
|
* Reasons for signalling a Postgres child process (a backend or an auxiliary
|
|
* process, like checkpointer). We can cope with concurrent signals for different
|
|
* reasons. However, if the same reason is signaled multiple times in quick
|
|
* succession, the process is likely to observe only one notification of it.
|
|
* This is okay for the present uses.
|
|
*
|
|
* Also, because of race conditions, it's important that all the signals be
|
|
* defined so that no harm is done if a process mistakenly receives one.
|
|
*/
|
|
typedef enum
|
|
{
|
|
PROCSIG_CATCHUP_INTERRUPT, /* sinval catchup interrupt */
|
|
PROCSIG_NOTIFY_INTERRUPT, /* listen/notify interrupt */
|
|
PROCSIG_PARALLEL_MESSAGE, /* message from cooperating parallel backend */
|
|
|
|
/* Recovery conflict reasons */
|
|
PROCSIG_RECOVERY_CONFLICT_DATABASE,
|
|
PROCSIG_RECOVERY_CONFLICT_TABLESPACE,
|
|
PROCSIG_RECOVERY_CONFLICT_LOCK,
|
|
PROCSIG_RECOVERY_CONFLICT_SNAPSHOT,
|
|
PROCSIG_RECOVERY_CONFLICT_BUFFERPIN,
|
|
PROCSIG_RECOVERY_CONFLICT_STARTUP_DEADLOCK,
|
|
|
|
NUM_PROCSIGNALS /* Must be last! */
|
|
} ProcSignalReason;
|
|
|
|
/*
|
|
* prototypes for functions in procsignal.c
|
|
*/
|
|
extern Size ProcSignalShmemSize(void);
|
|
extern void ProcSignalShmemInit(void);
|
|
|
|
extern void ProcSignalInit(int pss_idx);
|
|
extern int SendProcSignal(pid_t pid, ProcSignalReason reason,
|
|
BackendId backendId);
|
|
|
|
extern void procsignal_sigusr1_handler(SIGNAL_ARGS);
|
|
extern PGDLLIMPORT bool set_latch_on_sigusr1;
|
|
|
|
#endif /* PROCSIGNAL_H */
|