From 1491a74bc3886476ef3c61b2354392d2c9601fcc Mon Sep 17 00:00:00 2001
From: Alexander Kukushkin <cyberdemn@gmail.com>
Date: Fri, 8 May 2026 11:45:58 +0200
Subject: [PATCH] Support PostgreSQL 19

- include storage/fd.h, it declares `max_files_per_process`
- `server_message_level_options` is now public, use it instead of
  `cron_message_level_options`
- `pqsignal()` changed signature and we need to pass `PG_SIG_IGN`
  instead of `SIG_IGN`
- `error_severity()` is public since 15
- changed `-std=c99` compile flag to `-std=gnu11`, otherwise new
  `StaticAssert*()` macro are failing
---
 Makefile      |  4 ++--
 src/pg_cron.c | 45 ++++++++++++++++++++++++++++++++++-----------
 2 files changed, 36 insertions(+), 13 deletions(-)

diff --git a/Makefile b/Makefile
index c139cac..9839881 100644
--- a/Makefile
+++ b/Makefile
@@ -12,9 +12,9 @@ REGRESS = pg_cron-test
 MODULE_big = $(EXTENSION)
 OBJS = $(patsubst %.c,%.o,$(wildcard src/*.c))
 ifeq ($(CC),gcc)
-    PG_CPPFLAGS = -std=c99 -Wall -Wextra -Werror -Wno-unused-parameter -Wno-uninitialized -Wno-implicit-fallthrough -Iinclude -I$(libpq_srcdir)
+    PG_CPPFLAGS = -std=gnu11 -Wall -Wextra -Werror -Wno-unused-parameter -Wno-uninitialized -Wno-implicit-fallthrough -Iinclude -I$(libpq_srcdir)
 else
-    PG_CPPFLAGS = -std=c99 -Wall -Wextra -Werror -Wno-unused-parameter -Wno-implicit-fallthrough -Iinclude -I$(libpq_srcdir)
+    PG_CPPFLAGS = -std=gnu11 -Wall -Wextra -Werror -Wno-unused-parameter -Wno-implicit-fallthrough -Iinclude -I$(libpq_srcdir)
 endif
 ifeq ($(shell uname -s),SunOS)
     PG_CPPFLAGS += -Wno-sign-compare -D__EXTENSIONS__
diff --git a/src/pg_cron.c b/src/pg_cron.c
index 3cdfc2b..493c92d 100644
--- a/src/pg_cron.c
+++ b/src/pg_cron.c
@@ -31,6 +31,7 @@
 /* these are always necessary for a bgworker */
 #include "miscadmin.h"
 #include "postmaster/bgworker.h"
+#include "storage/fd.h"
 #include "storage/ipc.h"
 #include "storage/latch.h"
 #include "storage/lwlock.h"
@@ -182,7 +183,10 @@ static bool UseBackgroundWorkers = false;
 
 static char  *cron_timezone = NULL;
 
-static const struct config_enum_entry cron_message_level_options[] = {
+#if PG_VERSION_NUM < 190000
+#define PG_SIG_IGN SIG_IGN
+
+static const struct config_enum_entry server_message_level_options[] = {
 	{"debug5", DEBUG5, false},
 	{"debug4", DEBUG4, false},
 	{"debug3", DEBUG3, false},
@@ -198,6 +202,7 @@ static const struct config_enum_entry cron_message_level_options[] = {
 	{"panic", PANIC, false},
 	{NULL, 0, false}
 };
+#endif
 
 static const char *cron_error_severity(int elevel);
 
@@ -207,7 +212,7 @@ static const char *cron_error_severity(int elevel);
 void
 _PG_init(void)
 {
-	BackgroundWorker worker;
+	BackgroundWorker worker = {0,};
 
 	if (IsBinaryUpgrade)
 	{
@@ -325,7 +330,7 @@ _PG_init(void)
 		NULL,
 		&CronLogMinMessages,
 		WARNING,
-		cron_message_level_options,
+		server_message_level_options,
 		PGC_SIGHUP,
 		GUC_SUPERUSER_ONLY,
 		NULL, NULL, NULL);
@@ -481,17 +486,18 @@ cron_error_severity(int elevel)
 	return elevel_char;
 }
 
+#if PG_VERSION_NUM < 150000
 /*
- * bgw_generate_returned_message -
- *      generates the message to be inserted into the job_run_details table
- *      first part is comming from error_severity (elog.c)
+ * error_severity --- get string representing elevel
+ *
+ * copied from elog.c
  */
-static void
-bgw_generate_returned_message(StringInfoData *display_msg, ErrorData edata)
+static const char *
+error_severity(int elevel)
 {
 	const char *prefix;
 
-	switch (edata.elevel)
+	switch (elevel)
 	{
 		case DEBUG1:
 		case DEBUG2:
@@ -501,7 +507,7 @@ bgw_generate_returned_message(StringInfoData *display_msg, ErrorData edata)
 			prefix = gettext_noop("DEBUG");
 			break;
 		case LOG:
-#if (PG_VERSION_NUM >= 100000)
+#if PG_VERSION_NUM >= 100000
 		case LOG_SERVER_ONLY:
 #endif
 			prefix = gettext_noop("LOG");
@@ -513,6 +519,9 @@ bgw_generate_returned_message(StringInfoData *display_msg, ErrorData edata)
 			prefix = gettext_noop("NOTICE");
 			break;
 		case WARNING:
+#if PG_VERSION_NUM >= 140000
+		case WARNING_CLIENT_ONLY:
+#endif
 			prefix = gettext_noop("WARNING");
 			break;
 		case ERROR:
@@ -529,6 +538,20 @@ bgw_generate_returned_message(StringInfoData *display_msg, ErrorData edata)
 			break;
 	}
 
+	return prefix;
+}
+#endif
+
+/*
+ * bgw_generate_returned_message -
+ *      generates the message to be inserted into the job_run_details table
+ *      first part is comming from error_severity (elog.c)
+ */
+static void
+bgw_generate_returned_message(StringInfoData *display_msg, ErrorData edata)
+{
+	const char *prefix = error_severity(edata.elevel);
+
 	appendStringInfo(display_msg, "%s: %s", prefix, edata.message);
 	if (edata.detail != NULL)
 		appendStringInfo(display_msg, "\nDETAIL: %s", edata.detail);
@@ -553,7 +576,7 @@ PgCronLauncherMain(Datum arg)
 
 	/* Establish signal handlers before unblocking signals. */
 	pqsignal(SIGHUP, SignalHandlerForConfigReload);
-	pqsignal(SIGINT, SIG_IGN);
+	pqsignal(SIGINT, PG_SIG_IGN);
 	pqsignal(SIGTERM, die);
 
 	/* We're now ready to receive signals */