Skip to content

Add WaitEventExtensionNew calls for Pg17+ #203

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
pramsey merged 2 commits into from
Feb 19, 2026
Merged

Add WaitEventExtensionNew calls for Pg17+ #203

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
b3874e6
Add WaitEventExtensionNew calls for Pg17+, to make the use of the ext…
pramsey Feb 19, 2026
fe34bea
Drop pg13 test
pramsey Feb 19, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 0 additions & 1 deletion .github/workflows/ci.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ jobs:
fail-fast: true
matrix:
ci:
- { PGVER: 13 }
- { PGVER: 14 }
- { PGVER: 15 }
- { PGVER: 16 }
Expand Down
24 changes: 23 additions & 1 deletion http.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,10 @@
#include <utils/fmgroids.h>
#include <utils/guc.h>

#if PG_VERSION_NUM >= 170000
#include <utils/wait_event.h>
#endif

#if PG_VERSION_NUM >= 90300
# include <access/htup_details.h>
#endif
Expand Down Expand Up @@ -217,6 +221,10 @@ static size_t http_readback(void *buffer, size_t size, size_t nitems, void *inst
/* Global variables */
static CURL * g_http_handle = NULL;

#if PG_VERSION_NUM >= 170000
static uint32 wait_event_transfer = 0;
#endif

/*
* Interrupt support is dependent on CURLOPT_XFERINFOFUNCTION which
* is only available from 7.39.0 and up
Expand Down Expand Up @@ -421,6 +429,10 @@ void _PG_init(void)
*/
http_guc_init();

#if PG_VERSION_NUM >= 170000
wait_event_transfer = WaitEventExtensionNew("HttpTransfer");
#endif

#ifdef HTTP_MEM_CALLBACKS
/*
* Use PgSQL memory management in Curl
Expand Down Expand Up @@ -872,7 +884,7 @@ http_check_curl_version(const curl_version_info_data *version_info)

if ( version_info->version_num < CURL_MIN_VERSION )
{
elog(ERROR, "pgsql-http requires Curl version 0.7.20 or higher");
elog(ERROR, "pgsql-http requires Curl version 7.20.0 or higher");
}
}

Expand Down Expand Up @@ -1363,10 +1375,20 @@ Datum http_request(PG_FUNCTION_ARGS)
/* Set the headers */
CURL_SETOPT(g_http_handle, CURLOPT_HTTPHEADER, headers);

#if PG_VERSION_NUM >= 170000
/* Set up wait event tracking */
pgstat_report_wait_start(wait_event_transfer);
#endif

/*************************************************************************
* PERFORM THE REQUEST!
**************************************************************************/
http_return = curl_easy_perform(g_http_handle);

#if PG_VERSION_NUM >= 170000
pgstat_report_wait_end();
#endif

elog(DEBUG2, "pgsql-http: queried '%s'", uri);
elog(DEBUG2, "pgsql-http: http_return '%d'", http_return);

Expand Down