aboutsummaryrefslogtreecommitdiff
path: root/src/include/commands/waitlsn.h
diff options
context:
space:
mode:
authorAlexander Korotkov <akorotkov@postgresql.org>2024-04-11 16:30:32 +0300
committerAlexander Korotkov <akorotkov@postgresql.org>2024-04-11 17:28:15 +0300
commit772faafca1b288c4dd66b7150a7831c27b768003 (patch)
tree53ccb481bb8e8ca93feff18555734b706aa4ad7c /src/include/commands/waitlsn.h
parent922c4c461d213a422ee7eb6c38e399607539210a (diff)
downloadpostgresql-772faafca1b288c4dd66b7150a7831c27b768003.tar.gz
postgresql-772faafca1b288c4dd66b7150a7831c27b768003.zip
Revert: Implement pg_wal_replay_wait() stored procedure
This commit reverts 06c418e163, e37662f221, bf1e650806, 25f42429e2, ee79928441, and 74eaf66f98 per review by Heikki Linnakangas. Discussion: https://postgr.es/m/b155606b-e744-4218-bda5-29379779da1a%40iki.fi
Diffstat (limited to 'src/include/commands/waitlsn.h')
-rw-r--r--src/include/commands/waitlsn.h77
1 files changed, 0 insertions, 77 deletions
diff --git a/src/include/commands/waitlsn.h b/src/include/commands/waitlsn.h
deleted file mode 100644
index da17b8be6f9..00000000000
--- a/src/include/commands/waitlsn.h
+++ /dev/null
@@ -1,77 +0,0 @@
-/*-------------------------------------------------------------------------
- *
- * waitlsn.h
- * Declarations for LSN replay waiting routines.
- *
- * Copyright (c) 2024, PostgreSQL Global Development Group
- *
- * src/include/commands/waitlsn.h
- *
- *-------------------------------------------------------------------------
- */
-#ifndef WAIT_LSN_H
-#define WAIT_LSN_H
-
-#include "lib/pairingheap.h"
-#include "postgres.h"
-#include "port/atomics.h"
-#include "storage/spin.h"
-#include "tcop/dest.h"
-
-/*
- * WaitLSNProcInfo – the shared memory structure representing information
- * about the single process, which may wait for LSN replay. An item of
- * waitLSN->procInfos array.
- */
-typedef struct WaitLSNProcInfo
-{
- /*
- * A process number, same as the index of this item in waitLSN->procInfos.
- * Stored for convenience.
- */
- int procnum;
-
- /* LSN, which this process is waiting for */
- XLogRecPtr waitLSN;
-
- /* A pairing heap node for participation in waitLSN->waitersHeap */
- pairingheap_node phNode;
-
- /* A flag indicating that this item is added to waitLSN->waitersHeap */
- bool inHeap;
-} WaitLSNProcInfo;
-
-/*
- * WaitLSNState - the shared memory state for the replay LSN waiting facility.
- */
-typedef struct WaitLSNState
-{
- /*
- * The minimum LSN value some process is waiting for. Used for the
- * fast-path checking if we need to wake up any waiters after replaying a
- * WAL record. Could be read lock-less. Update protected by WaitLSNLock.
- */
- pg_atomic_uint64 minWaitedLSN;
-
- /*
- * A pairing heap of waiting processes order by LSN values (least LSN is
- * on top). Protected by WaitLSNLock.
- */
- pairingheap waitersHeap;
-
- /*
- * An array with per-process information, indexed by the process number.
- * Protected by WaitLSNLock.
- */
- WaitLSNProcInfo procInfos[FLEXIBLE_ARRAY_MEMBER];
-} WaitLSNState;
-
-extern PGDLLIMPORT struct WaitLSNState *waitLSN;
-
-extern void WaitForLSN(XLogRecPtr targetLSN, int64 timeout);
-extern Size WaitLSNShmemSize(void);
-extern void WaitLSNShmemInit(void);
-extern void WaitLSNSetLatches(XLogRecPtr currentLSN);
-extern void WaitLSNCleanup(void);
-
-#endif /* WAIT_LSN_H */