Merge pull request #666 from postgrespro/merge-ce

Merge ce

Author: Ogurezzz

Makefile

@@ -87,3 +87,4 @@ endif
 include packaging/Makefile.pkg
 include packaging/Makefile.repo
 include packaging/Makefile.test
+

README.md

@@ -6,7 +6,7 @@
 `pg_probackup` is a utility to manage backup and recovery of PostgreSQL database clusters. It is designed to perform periodic backups of the PostgreSQL instance that enable you to restore the server in case of a failure.
 
 The utility is compatible with:
-* PostgreSQL 13, 14, 15, 16, 17
+* PostgreSQL 13, 14, 15, 16, 17, 18
 
 As compared to other backup solutions, `pg_probackup` offers the following benefits that can help you implement different backup strategies and deal with large amounts of data:
 * Incremental backup: page-level incremental backup allows you to save disk space, speed up backup and restore. With three different incremental modes, you can plan the backup strategy in accordance with your data flow.
@@ -79,7 +79,7 @@ For users of Postgres Pro products, commercial editions of pg_probackup are avai
 ## Building from source
 ### Linux
 
-To compile `pg_probackup`, you must have a PostgreSQL installation and raw source tree. Execute this in the module's directory:
+To compile `pg_probackup`, you must have a PostgreSQL installation and raw source tree. For versions under 18 execute this in the module's directory:
 
 ```shell
 make USE_PGXS=1 PG_CONFIG=<path_to_pg_config> top_srcdir=<path_to_PostgreSQL_source_tree>
@@ -91,6 +91,8 @@ The alternative way, without using the PGXS infrastructure, is to place `pg_prob
 cd <path_to_PostgreSQL_source_tree> && git clone https://github.com/postgrespro/pg_probackup contrib/pg_probackup && cd contrib/pg_probackup && make
 ```
 
+For version 18 you have to apply PostgreSQL core patch (patches/REL_18_STABLE_pg_probackup.patch) first and recompile and reinstall PostgreSQL
+
 ### Windows
 
 Currently pg_probackup can be build using only MSVC 2013.

patches/REL_18_STABLE_pg_probackup.patch

@@ -0,0 +1,29 @@
+From 5809673569d3d95c7bce75ea0aa6f9723e303c7d Mon Sep 17 00:00:00 2001
+From: Daria <d.lepikhova@postgrespro.ru>
+Date: Mon, 17 Nov 2025 02:57:38 +0100
+Subject: [PATCH] REL_18_STABLE_pg_probackup
+
+---
+ src/backend/utils/hash/pg_crc.c | 2 ++
+ 1 file changed, 2 insertions(+)
+
+diff --git a/src/backend/utils/hash/pg_crc.c b/src/backend/utils/hash/pg_crc.c
+index e67a74ef852..6a474e804b5 100644
+--- a/src/backend/utils/hash/pg_crc.c
++++ b/src/backend/utils/hash/pg_crc.c
+@@ -99,6 +99,7 @@ const uint32 pg_crc32_table[256] = {
+ 	0xB40BBE37, 0xC30C8EA1, 0x5A05DF1B, 0x2D02EF8D
+ };
+ 
++#ifndef FRONTEND
+ /*
+  * SQL-callable functions
+  */
+@@ -128,3 +129,4 @@ crc32c_bytea(PG_FUNCTION_ARGS)
+ 
+ 	PG_RETURN_INT64(crc);
+ }
++#endif
+-- 
+2.39.5 (Apple Git-154)
+

src/backup.c

@@ -66,6 +66,7 @@ static bool pgpro_support(PGconn *conn);
 static bool pg_is_checksum_enabled(PGconn *conn);
 static bool pg_is_in_recovery(PGconn *conn);
 static bool pg_is_superuser(PGconn *conn);
+static void check_server_version(PGconn *conn, PGNodeInfo *nodeInfo);
 static void confirm_block_size(PGconn *conn, const char *name, int blcksz);
 static void rewind_and_mark_cfs_datafiles(parray *files, const char *root, char *relative, size_t i);
 static bool remove_excluded_files_criterion(void *value, void *exclude_args);
@@ -946,7 +947,7 @@ do_backup(InstanceState *instanceState, pgSetBackupParams *set_backup_params,
 /*
  * Confirm that this server version is supported
  */
-void
+static void
 check_server_version(PGconn *conn, PGNodeInfo *nodeInfo)
 {
 	PGresult   *res = NULL;
@@ -2517,11 +2518,16 @@ process_block_change(ForkNumber forknum, RelFileNode rnode, BlockNumber blkno)
 	int			segno;
 	pgFile	  **file_item;
 	pgFile		f;
+#if PG_VERSION_NUM >= 180000
+		RelPathStr rel_path_str = relpathperm(rnode, forknum);
+		rel_path = rel_path_str.str;
+#else
+		rel_path = relpathperm(rnode, forknum);
+#endif
 
 	segno = blkno / RELSEG_SIZE;
 	blkno_inseg = blkno % RELSEG_SIZE;
 
-	rel_path = relpathperm(rnode, forknum);
 	if (segno > 0)
 		f.rel_path = psprintf("%s.%u", rel_path, segno);
 	else
@@ -2553,7 +2559,9 @@ process_block_change(ForkNumber forknum, RelFileNode rnode, BlockNumber blkno)
 
 	if (segno > 0)
 		pg_free(f.rel_path);
+#if PG_VERSION_NUM < 180000
 	pg_free(rel_path);
+#endif
 
 }
 

src/data.c

@@ -1531,7 +1531,7 @@ validate_one_page(Page page, BlockNumber absolute_blkno,
 	/* Verify checksum */
 	page_st->checksum = pg_checksum_page(page, absolute_blkno);
 
-	if (checksum_version)
+	if (checksum_version && !skip_block_validation)
 	{
 		/* Checksums are enabled, so check them. */
 		if (page_st->checksum != ((PageHeader) page)->pd_checksum)

src/pg_probackup.c

@@ -687,7 +687,7 @@ main(int argc, char *argv[])
 	if (instance_config.pgdata != NULL &&
 	    (backup_subcmd != ARCHIVE_GET_CMD && backup_subcmd != CATCHUP_CMD) &&
 		!is_absolute_path(instance_config.pgdata))
-		elog(ERROR, "-D, --pgdata must be an absolute path");
+		elog(ERROR, "-D, --pgdata must be an absolute path: %s", instance_config.pgdata);
 
 #if PG_VERSION_NUM >= 110000
 	/* Check xlog-seg-size option */
@@ -980,13 +980,7 @@ main(int argc, char *argv[])
 						   wal_file_path, wal_file_name, batch_size, !no_validate_wal);
 			break;
 		case ADD_INSTANCE_CMD:
-			{
-				PGNodeInfo nodeInfo;
-				pgNodeInit(&nodeInfo);
-				instanceState->conn = pgut_connect(dbhost, dbport, dbname, dbuser);
-				check_server_version(instanceState->conn, &nodeInfo);
-				return do_add_instance(instanceState, &instance_config);
-			}
+			return do_add_instance(instanceState, &instance_config);
 		case DELETE_INSTANCE_CMD:
 			return do_delete_instance(instanceState);
 		case INIT_CMD:

src/pg_probackup.h

@@ -1245,7 +1245,6 @@ extern const char *base36enc_to(long unsigned int value, char buf[ARG_SIZE_HINT
 extern long unsigned int base36dec(const char *text);
 extern uint32 parse_server_version(const char *server_version_str);
 extern uint32 parse_program_version(const char *program_version);
-void check_server_version(PGconn *conn, PGNodeInfo *nodeInfo);
 extern bool   parse_page(Page page, XLogRecPtr *lsn);
 extern int32  do_compress(void* dst, size_t dst_size, void const* src, size_t src_size,
 						  CompressAlg alg, int level, const char **errormsg);

src/stream.c

@@ -188,7 +188,11 @@ CreateReplicationSlot_compat(PGconn *conn, const char *slot_name, const char *pl
                                           bool is_temporary, bool is_physical,
                                           bool slot_exists_ok)
 {
-#if PG_VERSION_NUM >= 150000
+#if PG_VERSION_NUM >= 180000
+       return CreateReplicationSlot(conn, slot_name, plugin, is_temporary, is_physical,
+               /* reserve_wal = */ true, slot_exists_ok, /* two_phase = */ false, /* failover = */ false);
+#elif PG_VERSION_NUM >= 150000
+
 	return CreateReplicationSlot(conn, slot_name, plugin, is_temporary, is_physical,
 		/* reserve_wal = */ true, slot_exists_ok, /* two_phase = */ false);
 #elif PG_VERSION_NUM >= 110000

src/util.c

@@ -93,8 +93,13 @@ digestControlFile(ControlFileData *ControlFile, char *src, size_t size)
 #endif
 
 	if (size != ControlFileSize)
+	{
+		if (size == 16384)
+			elog(ERROR, "Unexpected control file size %d, expected %d. Probably you trying to connect Postgres Pro using %s built with PostgreSQL. ",
+				(int) size, ControlFileSize, PROGRAM_NAME);
 		elog(ERROR, "Unexpected control file size %d, expected %d",
 			 (int) size, ControlFileSize);
+	}
 
 	memcpy(ControlFile, src, sizeof(ControlFileData));
 

src/utils/pgut.c

@@ -1062,7 +1062,23 @@ handle_interrupt(SIGNAL_ARGS)
 static void
 init_cancel_handler(void)
 {
+#if PG_VERSION_NUM < 180000
 	oldhandler = pqsignal(SIGINT, handle_interrupt);
+#else
+	{
+		struct sigaction act, oldact;
+
+		act.sa_handler = handle_interrupt;
+		sigemptyset(&act.sa_mask);
+		act.sa_flags = SA_RESTART;
+
+		/* Get the previous handler and set the new one */
+		if (sigaction(SIGINT, &act, &oldact) < 0)
+		elog(ERROR, "sigaction(SIGINT) failed: %m");
+
+		oldhandler = oldact.sa_handler;
+	}
+#endif
 	pqsignal(SIGQUIT, handle_interrupt);
 	pqsignal(SIGTERM, handle_interrupt);
 	pqsignal(SIGPIPE, handle_interrupt);