postgrespro
diff --git a/‎collector.c
Copy file name to clipboardExpand all lines: collector.c
+2-2Lines changed: 2 additions & 2 deletions b/‎collector.c
Copy file name to clipboardExpand all lines: collector.c
+2-2Lines changed: 2 additions & 2 deletions
diff --git a/‎compat.h
Copy file name to clipboardExpand all lines: compat.h
+15Lines changed: 15 additions & 0 deletions b/‎compat.h
Copy file name to clipboardExpand all lines: compat.h
+15Lines changed: 15 additions & 0 deletions
diff --git a/‎pg_wait_sampling.c
Copy file name to clipboardExpand all lines: pg_wait_sampling.c
+1-3Lines changed: 1 addition & 3 deletions b/‎pg_wait_sampling.c
Copy file name to clipboardExpand all lines: pg_wait_sampling.c
+1-3Lines changed: 1 addition & 3 deletions
@@ -470,7 +470,7 @@ pgws_collector_main(Datum main_arg)
 								send_profile(profile_hash, mqh);
 								break;
 							default:
-								AssertState(false);
+								Assert(false);
 						}
 						break;
 					case SHM_MQ_DETACHED:
@@ -480,7 +480,7 @@ pgws_collector_main(Datum main_arg)
 										"detached")));
 						break;
 					default:
-						AssertState(false);
+						Assert(false);
 				}
 				shm_mq_detach_compat(mqh, pgws_collector_mq);
 			}
 
@@ -15,6 +15,7 @@
 #include "access/tupdesc.h"
 #include "miscadmin.h"
 #include "storage/shm_mq.h"
+#include "utils/guc_tables.h"
 
 static inline TupleDesc
 CreateTemplateTupleDescCompat(int nattrs, bool hasoid)
@@ -65,4 +66,18 @@ InitPostgresCompat(const char *in_dbname, Oid dboid,
 #endif
 }
 
+static inline void
+get_guc_variables_compat(struct config_generic ***vars, int *num_vars)
+{
+	Assert(vars != NULL);
+	Assert(num_vars != NULL);
+
+#if PG_VERSION_NUM >= 160000
+	*vars = get_guc_variables(num_vars);
+#else
+	*vars = get_guc_variables();
+	*num_vars = GetNumConfigOptions();
+#endif
+}
+
 #endif
@@ -198,8 +198,7 @@ setup_gucs()
 				profile_pid_found = false,
 				profile_queries_found = false;
 
-	guc_vars = get_guc_variables();
-	numOpts = GetNumConfigOptions();
+	get_guc_variables_compat(&guc_vars, &numOpts);
 
 	for (i = 0; i < numOpts; i++)
 	{
@@ -452,7 +451,6 @@ pg_wait_sampling_get_current(PG_FUNCTION_ARGS)
 	{
 		MemoryContext		oldcontext;
 		TupleDesc			tupdesc;
-		WaitCurrentContext 	*params;
 
 		funcctx = SRF_FIRSTCALL_INIT();
Original file line number	Diff line number	Diff line change
`@@ -470,7 +470,7 @@ pgws_collector_main(Datum main_arg)`
`470`	`470`	`send_profile(profile_hash, mqh);`
`471`	`471`	`break;`
`472`	`472`	`default:`
`473`		`- AssertState(false);`
	`473`	`+ Assert(false);`
`474`	`474`	`}`
`475`	`475`	`break;`
`476`	`476`	`case SHM_MQ_DETACHED:`
`@@ -480,7 +480,7 @@ pgws_collector_main(Datum main_arg)`
`480`	`480`	`"detached")));`
`481`	`481`	`break;`
`482`	`482`	`default:`
`483`		`- AssertState(false);`
	`483`	`+ Assert(false);`
`484`	`484`	`}`
`485`	`485`	`shm_mq_detach_compat(mqh, pgws_collector_mq);`
`486`	`486`	`}`