PostgreSQL Source Code git master
All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
ipci.c File Reference
Include dependency graph for ipci.c:

Go to the source code of this file.

Functions

static void CreateOrAttachShmemStructs (void)
 
void RequestAddinShmemSpace (Size size)
 
Size CalculateShmemSize (int *num_semaphores)
 
void CreateSharedMemoryAndSemaphores (void)
 
void InitializeShmemGUCs (void)
 

Variables

int shared_memory_type = DEFAULT_SHARED_MEMORY_TYPE
 
shmem_startup_hook_type shmem_startup_hook = NULL
 
static Size total_addin_request = 0
 

Function Documentation

◆ CalculateShmemSize()

Size CalculateShmemSize ( int *  num_semaphores)

Definition at line 89 of file ipci.c.

90{
91 Size size;
92 int numSemas;
93
94 /* Compute number of semaphores we'll need */
95 numSemas = ProcGlobalSemas();
96
97 /* Return the number of semaphores if requested by the caller */
98 if (num_semaphores)
99 *num_semaphores = numSemas;
100
101 /*
102 * Size of the Postgres shared-memory block is estimated via moderately-
103 * accurate estimates for the big hogs, plus 100K for the stuff that's too
104 * small to bother with estimating.
105 *
106 * We take some care to ensure that the total size request doesn't
107 * overflow size_t. If this gets through, we don't need to be so careful
108 * during the actual allocation phase.
109 */
110 size = 100000;
111 size = add_size(size, PGSemaphoreShmemSize(numSemas));
113 sizeof(ShmemIndexEnt)));
114 size = add_size(size, dsm_estimate_size());
115 size = add_size(size, DSMRegistryShmemSize());
116 size = add_size(size, BufferManagerShmemSize());
117 size = add_size(size, LockManagerShmemSize());
118 size = add_size(size, PredicateLockShmemSize());
119 size = add_size(size, ProcGlobalShmemSize());
120 size = add_size(size, XLogPrefetchShmemSize());
121 size = add_size(size, VarsupShmemSize());
122 size = add_size(size, XLOGShmemSize());
123 size = add_size(size, XLogRecoveryShmemSize());
124 size = add_size(size, CLOGShmemSize());
125 size = add_size(size, CommitTsShmemSize());
126 size = add_size(size, SUBTRANSShmemSize());
127 size = add_size(size, TwoPhaseShmemSize());
128 size = add_size(size, BackgroundWorkerShmemSize());
129 size = add_size(size, MultiXactShmemSize());
130 size = add_size(size, LWLockShmemSize());
131 size = add_size(size, ProcArrayShmemSize());
132 size = add_size(size, BackendStatusShmemSize());
133 size = add_size(size, SharedInvalShmemSize());
134 size = add_size(size, PMSignalShmemSize());
135 size = add_size(size, ProcSignalShmemSize());
136 size = add_size(size, CheckpointerShmemSize());
137 size = add_size(size, AutoVacuumShmemSize());
138 size = add_size(size, ReplicationSlotsShmemSize());
139 size = add_size(size, ReplicationOriginShmemSize());
140 size = add_size(size, WalSndShmemSize());
141 size = add_size(size, WalRcvShmemSize());
142 size = add_size(size, WalSummarizerShmemSize());
143 size = add_size(size, PgArchShmemSize());
144 size = add_size(size, ApplyLauncherShmemSize());
145 size = add_size(size, BTreeShmemSize());
146 size = add_size(size, SyncScanShmemSize());
147 size = add_size(size, AsyncShmemSize());
148 size = add_size(size, StatsShmemSize());
149 size = add_size(size, WaitEventCustomShmemSize());
150 size = add_size(size, InjectionPointShmemSize());
151 size = add_size(size, SlotSyncShmemSize());
152 size = add_size(size, AioShmemSize());
153
154 /* include additional requested shmem from preload libraries */
155 size = add_size(size, total_addin_request);
156
157 /* might as well round it off to a multiple of a typical page size */
158 size = add_size(size, 8192 - (size % 8192));
159
160 return size;
161}
Size AioShmemSize(void)
Definition: aio_init.c:117
Size AsyncShmemSize(void)
Definition: async.c:485
Size AutoVacuumShmemSize(void)
Definition: autovacuum.c:3349
Size BackendStatusShmemSize(void)
Size BackgroundWorkerShmemSize(void)
Definition: bgworker.c:146
Size BufferManagerShmemSize(void)
Definition: buf_init.c:162
size_t Size
Definition: c.h:576
Size CheckpointerShmemSize(void)
Definition: checkpointer.c:935
Size CLOGShmemSize(void)
Definition: clog.c:781
Size CommitTsShmemSize(void)
Definition: commit_ts.c:519
size_t dsm_estimate_size(void)
Definition: dsm.c:470
Size DSMRegistryShmemSize(void)
Definition: dsm_registry.c:63
Size hash_estimate_size(long num_entries, Size entrysize)
Definition: dynahash.c:784
Size InjectionPointShmemSize(void)
static Size total_addin_request
Definition: ipci.c:60
Size ApplyLauncherShmemSize(void)
Definition: launcher.c:896
Size LockManagerShmemSize(void)
Definition: lock.c:3726
Size LWLockShmemSize(void)
Definition: lwlock.c:432
Size MultiXactShmemSize(void)
Definition: multixact.c:1947
Size BTreeShmemSize(void)
Definition: nbtutils.c:3702
Size ReplicationOriginShmemSize(void)
Definition: origin.c:534
Size PgArchShmemSize(void)
Definition: pgarch.c:156
Size StatsShmemSize(void)
Definition: pgstat_shmem.c:127
Size PMSignalShmemSize(void)
Definition: pmsignal.c:130
Size PGSemaphoreShmemSize(int maxSemas)
Definition: posix_sema.c:165
Size PredicateLockShmemSize(void)
Definition: predicate.c:1357
Size ProcArrayShmemSize(void)
Definition: procarray.c:376
Size ProcSignalShmemSize(void)
Definition: procsignal.c:117
Size add_size(Size s1, Size s2)
Definition: shmem.c:493
#define SHMEM_INDEX_SIZE
Definition: shmem.h:53
Size SharedInvalShmemSize(void)
Definition: sinvaladt.c:218
Size ReplicationSlotsShmemSize(void)
Definition: slot.c:186
Size SlotSyncShmemSize(void)
Definition: slotsync.c:1677
Size ProcGlobalShmemSize(void)
Definition: proc.c:139
int ProcGlobalSemas(void)
Definition: proc.c:157
Size SUBTRANSShmemSize(void)
Definition: subtrans.c:214
Size SyncScanShmemSize(void)
Definition: syncscan.c:126
Size TwoPhaseShmemSize(void)
Definition: twophase.c:237
Size VarsupShmemSize(void)
Definition: varsup.c:41
Size WaitEventCustomShmemSize(void)
Definition: wait_event.c:103
Size WalRcvShmemSize(void)
Size WalSndShmemSize(void)
Definition: walsender.c:3638
Size WalSummarizerShmemSize(void)
Size XLOGShmemSize(void)
Definition: xlog.c:5049
size_t XLogPrefetchShmemSize(void)
Size XLogRecoveryShmemSize(void)
Definition: xlogrecovery.c:453

References add_size(), AioShmemSize(), ApplyLauncherShmemSize(), AsyncShmemSize(), AutoVacuumShmemSize(), BackendStatusShmemSize(), BackgroundWorkerShmemSize(), BTreeShmemSize(), BufferManagerShmemSize(), CheckpointerShmemSize(), CLOGShmemSize(), CommitTsShmemSize(), dsm_estimate_size(), DSMRegistryShmemSize(), hash_estimate_size(), InjectionPointShmemSize(), LockManagerShmemSize(), LWLockShmemSize(), MultiXactShmemSize(), PgArchShmemSize(), PGSemaphoreShmemSize(), PMSignalShmemSize(), PredicateLockShmemSize(), ProcArrayShmemSize(), ProcGlobalSemas(), ProcGlobalShmemSize(), ProcSignalShmemSize(), ReplicationOriginShmemSize(), ReplicationSlotsShmemSize(), SharedInvalShmemSize(), SHMEM_INDEX_SIZE, SlotSyncShmemSize(), StatsShmemSize(), SUBTRANSShmemSize(), SyncScanShmemSize(), total_addin_request, TwoPhaseShmemSize(), VarsupShmemSize(), WaitEventCustomShmemSize(), WalRcvShmemSize(), WalSndShmemSize(), WalSummarizerShmemSize(), XLogPrefetchShmemSize(), XLogRecoveryShmemSize(), and XLOGShmemSize().

Referenced by CreateSharedMemoryAndSemaphores(), and InitializeShmemGUCs().

◆ CreateOrAttachShmemStructs()

static void CreateOrAttachShmemStructs ( void  )
static

Definition at line 266 of file ipci.c.

267{
268 /*
269 * Now initialize LWLocks, which do shared memory allocation and are
270 * needed for InitShmemIndex.
271 */
273
274 /*
275 * Set up shmem.c index hashtable
276 */
278
281
282 /*
283 * Set up xlog, clog, and buffers
284 */
294
295 /*
296 * Set up lock manager
297 */
299
300 /*
301 * Set up predicate lock manager
302 */
304
305 /*
306 * Set up process table
307 */
314
315 /*
316 * Set up shared-inval messaging
317 */
319
320 /*
321 * Set up interprocess signaling mechanisms
322 */
335
336 /*
337 * Set up other modules that need some shared memory space
338 */
345 AioShmemInit();
346}
void AioShmemInit(void)
Definition: aio_init.c:153
void AsyncShmemInit(void)
Definition: async.c:502
void AutoVacuumShmemInit(void)
Definition: autovacuum.c:3368
void BackendStatusShmemInit(void)
void BackgroundWorkerShmemInit(void)
Definition: bgworker.c:162
void BufferManagerShmemInit(void)
Definition: buf_init.c:68
void CheckpointerShmemInit(void)
Definition: checkpointer.c:954
void CLOGShmemInit(void)
Definition: clog.c:787
void CommitTsShmemInit(void)
Definition: commit_ts.c:530
void dsm_shmem_init(void)
Definition: dsm.c:479
void DSMRegistryShmemInit(void)
Definition: dsm_registry.c:69
bool IsUnderPostmaster
Definition: globals.c:120
void InjectionPointShmemInit(void)
void ApplyLauncherShmemInit(void)
Definition: launcher.c:951
void LockManagerShmemInit(void)
Definition: lock.c:443
void CreateLWLocks(void)
Definition: lwlock.c:462
void MultiXactShmemInit(void)
Definition: multixact.c:1964
void BTreeShmemInit(void)
Definition: nbtutils.c:3715
void ReplicationOriginShmemInit(void)
Definition: origin.c:549
void PgArchShmemInit(void)
Definition: pgarch.c:167
void StatsShmemInit(void)
Definition: pgstat_shmem.c:156
void PMSignalShmemInit(void)
Definition: pmsignal.c:145
void PredicateLockShmemInit(void)
Definition: predicate.c:1145
void ProcArrayShmemInit(void)
Definition: procarray.c:418
void ProcSignalShmemInit(void)
Definition: procsignal.c:131
void InitShmemIndex(void)
Definition: shmem.c:283
void SharedInvalShmemInit(void)
Definition: sinvaladt.c:234
void ReplicationSlotsShmemInit(void)
Definition: slot.c:204
void SlotSyncShmemInit(void)
Definition: slotsync.c:1686
void InitProcGlobal(void)
Definition: proc.c:192
void SUBTRANSShmemInit(void)
Definition: subtrans.c:220
void SyncScanShmemInit(void)
Definition: syncscan.c:135
void TwoPhaseShmemInit(void)
Definition: twophase.c:253
void VarsupShmemInit(void)
Definition: varsup.c:47
void WaitEventCustomShmemInit(void)
Definition: wait_event.c:119
void WalRcvShmemInit(void)
void WalSndShmemInit(void)
Definition: walsender.c:3650
void WalSummarizerShmemInit(void)
void XLOGShmemInit(void)
Definition: xlog.c:5099
void XLogPrefetchShmemInit(void)
void XLogRecoveryShmemInit(void)
Definition: xlogrecovery.c:464

References AioShmemInit(), ApplyLauncherShmemInit(), AsyncShmemInit(), AutoVacuumShmemInit(), BackendStatusShmemInit(), BackgroundWorkerShmemInit(), BTreeShmemInit(), BufferManagerShmemInit(), CheckpointerShmemInit(), CLOGShmemInit(), CommitTsShmemInit(), CreateLWLocks(), dsm_shmem_init(), DSMRegistryShmemInit(), InitProcGlobal(), InitShmemIndex(), InjectionPointShmemInit(), IsUnderPostmaster, LockManagerShmemInit(), MultiXactShmemInit(), PgArchShmemInit(), PMSignalShmemInit(), PredicateLockShmemInit(), ProcArrayShmemInit(), ProcSignalShmemInit(), ReplicationOriginShmemInit(), ReplicationSlotsShmemInit(), SharedInvalShmemInit(), SlotSyncShmemInit(), StatsShmemInit(), SUBTRANSShmemInit(), SyncScanShmemInit(), TwoPhaseShmemInit(), VarsupShmemInit(), WaitEventCustomShmemInit(), WalRcvShmemInit(), WalSndShmemInit(), WalSummarizerShmemInit(), XLogPrefetchShmemInit(), XLogRecoveryShmemInit(), and XLOGShmemInit().

Referenced by CreateSharedMemoryAndSemaphores().

◆ CreateSharedMemoryAndSemaphores()

void CreateSharedMemoryAndSemaphores ( void  )

Definition at line 200 of file ipci.c.

201{
202 PGShmemHeader *shim;
203 PGShmemHeader *seghdr;
204 Size size;
205 int numSemas;
206
208
209 /* Compute the size of the shared-memory block */
210 size = CalculateShmemSize(&numSemas);
211 elog(DEBUG3, "invoking IpcMemoryCreate(size=%zu)", size);
212
213 /*
214 * Create the shmem segment
215 */
216 seghdr = PGSharedMemoryCreate(size, &shim);
217
218 /*
219 * Make sure that huge pages are never reported as "unknown" while the
220 * server is running.
221 */
222 Assert(strcmp("unknown",
223 GetConfigOption("huge_pages_status", false, false)) != 0);
224
225 InitShmemAccess(seghdr);
226
227 /*
228 * Create semaphores
229 */
230 PGReserveSemaphores(numSemas);
231
232 /*
233 * Set up shared memory allocation mechanism
234 */
236
237 /* Initialize subsystems */
239
240 /* Initialize dynamic shared memory facilities. */
242
243 /*
244 * Now give loadable modules a chance to set up their shmem allocations
245 */
248}
void dsm_postmaster_startup(PGShmemHeader *shim)
Definition: dsm.c:177
#define DEBUG3
Definition: elog.h:28
#define elog(elevel,...)
Definition: elog.h:225
const char * GetConfigOption(const char *name, bool missing_ok, bool restrict_privileged)
Definition: guc.c:4355
Assert(PointerIsAligned(start, uint64))
shmem_startup_hook_type shmem_startup_hook
Definition: ipci.c:58
Size CalculateShmemSize(int *num_semaphores)
Definition: ipci.c:89
static void CreateOrAttachShmemStructs(void)
Definition: ipci.c:266
void PGReserveSemaphores(int maxSemas)
Definition: posix_sema.c:196
void InitShmemAccess(PGShmemHeader *seghdr)
Definition: shmem.c:102
void InitShmemAllocation(void)
Definition: shmem.c:115
PGShmemHeader * PGSharedMemoryCreate(Size size, PGShmemHeader **shim)
Definition: sysv_shmem.c:700

References Assert(), CalculateShmemSize(), CreateOrAttachShmemStructs(), DEBUG3, dsm_postmaster_startup(), elog, GetConfigOption(), InitShmemAccess(), InitShmemAllocation(), IsUnderPostmaster, PGReserveSemaphores(), PGSharedMemoryCreate(), and shmem_startup_hook.

Referenced by BootstrapModeMain(), PostgresSingleUserMain(), PostmasterMain(), and PostmasterStateMachine().

◆ InitializeShmemGUCs()

void InitializeShmemGUCs ( void  )

Definition at line 355 of file ipci.c.

356{
357 char buf[64];
358 Size size_b;
359 Size size_mb;
360 Size hp_size;
361 int num_semas;
362
363 /*
364 * Calculate the shared memory size and round up to the nearest megabyte.
365 */
366 size_b = CalculateShmemSize(&num_semas);
367 size_mb = add_size(size_b, (1024 * 1024) - 1) / (1024 * 1024);
368 sprintf(buf, "%zu", size_mb);
369 SetConfigOption("shared_memory_size", buf,
371
372 /*
373 * Calculate the number of huge pages required.
374 */
375 GetHugePageSize(&hp_size, NULL);
376 if (hp_size != 0)
377 {
378 Size hp_required;
379
380 hp_required = add_size(size_b / hp_size, 1);
381 sprintf(buf, "%zu", hp_required);
382 SetConfigOption("shared_memory_size_in_huge_pages", buf,
384 }
385
386 sprintf(buf, "%d", num_semas);
388}
void SetConfigOption(const char *name, const char *value, GucContext context, GucSource source)
Definition: guc.c:4332
@ PGC_S_DYNAMIC_DEFAULT
Definition: guc.h:114
@ PGC_INTERNAL
Definition: guc.h:73
static char * buf
Definition: pg_test_fsync.c:72
#define sprintf
Definition: port.h:241
void GetHugePageSize(Size *hugepagesize, int *mmap_flags)
Definition: sysv_shmem.c:479

References add_size(), buf, CalculateShmemSize(), GetHugePageSize(), PGC_INTERNAL, PGC_S_DYNAMIC_DEFAULT, SetConfigOption(), and sprintf.

Referenced by PostgresSingleUserMain(), and PostmasterMain().

◆ RequestAddinShmemSpace()

void RequestAddinShmemSpace ( Size  size)

Definition at line 74 of file ipci.c.

75{
77 elog(FATAL, "cannot request additional shared memory outside shmem_request_hook");
79}
#define FATAL
Definition: elog.h:41
bool process_shmem_requests_in_progress
Definition: miscinit.c:1841

References add_size(), elog, FATAL, process_shmem_requests_in_progress, and total_addin_request.

Referenced by injection_shmem_request(), pgss_shmem_request(), test_aio_shmem_request(), and test_slru_shmem_request().

Variable Documentation

◆ shared_memory_type

int shared_memory_type = DEFAULT_SHARED_MEMORY_TYPE

Definition at line 56 of file ipci.c.

Referenced by PGSharedMemoryCreate().

◆ shmem_startup_hook

shmem_startup_hook_type shmem_startup_hook = NULL

Definition at line 58 of file ipci.c.

Referenced by _PG_init(), and CreateSharedMemoryAndSemaphores().

◆ total_addin_request

Size total_addin_request = 0
static

Definition at line 60 of file ipci.c.

Referenced by CalculateShmemSize(), and RequestAddinShmemSpace().