From 6d5628b2573a51677d14c8c936befa45c1815063 Mon Sep 17 00:00:00 2001 From: RekGRpth <rekgrpth@gmail.com> Date: Tue, 5 Mar 2024 09:53:43 +0500 Subject: [PATCH] pg17 support commit https://github.com/postgres/postgres/commit/024c521117579a6d356050ad3d78fdc95e44eefa replaces MyBackendId by MyProcNumber and ParallelLeaderBackendId by ParallelLeaderProcNumber --- pg_stat_kcache.c | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/pg_stat_kcache.c b/pg_stat_kcache.c index bd54cb8..bce19ea 100644 --- a/pg_stat_kcache.c +++ b/pg_stat_kcache.c @@ -90,6 +90,11 @@ typedef uint32 pgsk_queryid; #define TIMEVAL_DIFF(start, end) ((double) end.tv_sec + (double) end.tv_usec / 1000000.0) \ - ((double) start.tv_sec + (double) start.tv_usec / 1000000.0) +#if PG_VERSION_NUM < 170000 +#define MyProcNumber MyBackendId +#define ParallelLeaderProcNumber ParallelLeaderBackendId +#endif + #if PG_VERSION_NUM < 140000 #define ParallelLeaderBackendId ParallelMasterBackendId #endif @@ -431,7 +436,7 @@ pgsk_set_queryid(pgsk_queryid queryid) /* Only the leader knows the queryid. */ Assert(!IsParallelWorker()); - pgsk->queryids[MyBackendId] = queryid; + pgsk->queryids[MyProcNumber] = queryid; } #endif @@ -1082,7 +1087,7 @@ pgsk_ExecutorEnd (QueryDesc *queryDesc) #if PG_VERSION_NUM >= 90600 if (IsParallelWorker()) - queryId = pgsk->queryids[ParallelLeaderBackendId]; + queryId = pgsk->queryids[ParallelLeaderProcNumber]; else #endif queryId = queryDesc->plannedstmt->queryId;