rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-14 08:52:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Replace MaxBackends with MAX)_BACKENDS in array size estimation

Browse Source
This commit is contained in:
Kosntantin Knizhnik
2025-07-16 09:30:22 +03:00
parent 6e2af7ac3f
commit 855b6ea6aa
4 changed files with 19 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pgxn/neon/communicator.c
View File

@@ -65,6 +65,7 @@
#include "miscadmin.h"
#include "port/pg_iovec.h"
#include "postmaster/interrupt.h"
#include "postmaster/postmaster.h"
#include "replication/walsender.h"
#include "storage/ipc.h"
#include "utils/timeout.h"
@@ -328,7 +329,7 @@ pg_init_communicator(void)
static Size
CommunicatorShmemSize(void)
{
return (MaxBackends + NUM_AUXILIARY_PROCS + max_prepared_xacts) * sizeof(XLogRecPtr);
return (MAX_BACKENDS + NUM_AUXILIARY_PROCS + max_prepared_xacts) * sizeof(XLogRecPtr);
}
void
@@ -2686,7 +2687,7 @@ communicator_processinterrupts(void)
XLogRecPtr communicator_get_min_prefetch_lsn(void)
{
XLogRecPtr min_lsn = InvalidXLogRecPtr;
XLogRecPtr min_lsn = GetXLogReplayRecPtr(NULL);
size_t n_procs = ProcGlobal->allProcCount;
for (size_t i = 0; i < n_procs; i++)
{

3
pgxn/neon/file_cache.c
View File

@@ -625,9 +625,6 @@ lfc_init(void)
NULL,
NULL,
NULL);
if (lfc_max_size == 0)
return;
}
FileCacheState*

20
pgxn/neon/neon.c
View File

@@ -457,15 +457,6 @@ _PG_init(void)
load_file("$libdir/neon_rmgr", false);
#endif
#if PG_VERSION_NUM >= 150000
prev_shmem_request_hook = shmem_request_hook;
shmem_request_hook = neon_shmem_request_hook;
#else
neon_shmem_request_hook();
#endif
prev_shmem_startup_hook = shmem_startup_hook;
shmem_startup_hook = neon_shmem_startup_hook;
/* dummy call to a Rust function in the communicator library, to check that it works */
(void) communicator_dummy(123);
@@ -564,6 +555,16 @@ _PG_init(void)
ReportSearchPath();
#if PG_VERSION_NUM >= 150000
prev_shmem_request_hook = shmem_request_hook;
shmem_request_hook = neon_shmem_request_hook;
#else
neon_shmem_request_hook();
#endif
prev_shmem_startup_hook = shmem_startup_hook;
shmem_startup_hook = neon_shmem_startup_hook;
prev_ExecutorStart = ExecutorStart_hook;
ExecutorStart_hook = neon_ExecutorStart;
prev_ExecutorEnd = ExecutorEnd_hook;
@@ -656,6 +657,7 @@ neon_shmem_request_hook(void)
if (prev_shmem_request_hook)
prev_shmem_request_hook();
#endif
LfcShmemRequest();
NeonPerfCountersShmemRequest();
PagestoreShmemRequest();

10
pgxn/neon/relsize_cache.c
View File

@@ -50,17 +50,17 @@ typedef struct
* algorithm */
} RelSizeHashControl;
static HTAB *relsize_hash;
static LWLockId relsize_lock;
static int relsize_hash_size;
static RelSizeHashControl* relsize_ctl;
/*
* Size of a cache entry is 36 bytes. So this default will take about 2.3 MB,
* which seems reasonable.
*/
#define DEFAULT_RELSIZE_HASH_SIZE (64 * 1024)
static HTAB *relsize_hash;
static LWLockId relsize_lock;
static int relsize_hash_size = DEFAULT_RELSIZE_HASH_SIZE;
static RelSizeHashControl* relsize_ctl;
void
RelsizeCacheShmemInit(void)
{