summaryrefslogtreecommitdiff
path: root/src/interfaces/ecpg/ecpglib
diff options
context:
space:
mode:
authorTom Lane <tgl@sss.pgh.pa.us>2022-06-14 18:16:46 -0400
committerTom Lane <tgl@sss.pgh.pa.us>2022-06-14 18:16:46 -0400
commitba412c905af14699a128a7bcd8ce5234adb93ceb (patch)
tree6f86ac7383076693441426ead925605cd98df184 /src/interfaces/ecpg/ecpglib
parentd26ac35d0d7cb42a0453e69e0e9ce6d163b55927 (diff)
downloadpostgresql-ba412c905af14699a128a7bcd8ce5234adb93ceb.tar.gz
Avoid ecpglib core dump with out-of-order operations.
If an application executed operations like EXEC SQL PREPARE without having first established a database connection, it could get a core dump instead of the expected clean failure. This occurred because we did "pthread_getspecific(actual_connection_key)" without ever having initialized the TSD key actual_connection_key. The results of that are probably platform-specific, but at least on Linux it often leads to a crash. To fix, add calls to ecpg_pthreads_init() in the code paths that might use actual_connection_key uninitialized. It's harmless (and hopefully inexpensive) to do that more than once. Per bug #17514 from Okano Naoki. The problem's ancient, so back-patch to all supported branches. Discussion: https://postgr.es/m/17514-edd4fad547c5692c@postgresql.org
Diffstat (limited to 'src/interfaces/ecpg/ecpglib')
-rw-r--r--src/interfaces/ecpg/ecpglib/connect.c10
1 files changed, 6 insertions, 4 deletions
diff --git a/src/interfaces/ecpg/ecpglib/connect.c b/src/interfaces/ecpg/ecpglib/connect.c
index 8dfcabe3b5..90f2ba9701 100644
--- a/src/interfaces/ecpg/ecpglib/connect.c
+++ b/src/interfaces/ecpg/ecpglib/connect.c
@@ -40,6 +40,8 @@ ecpg_get_connection_nr(const char *connection_name)
if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0))
{
#ifdef ENABLE_THREAD_SAFETY
+ ecpg_pthreads_init(); /* ensure actual_connection_key is valid */
+
ret = pthread_getspecific(actual_connection_key);
/*
@@ -47,8 +49,7 @@ ecpg_get_connection_nr(const char *connection_name)
* connection and hope the user knows what they're doing (i.e. using
* their own mutex to protect that connection from concurrent accesses
*/
- /* if !ret then we got the connection from TSD */
- if (NULL == ret)
+ if (ret == NULL)
/* no TSD connection, going for global */
ret = actual_connection;
#else
@@ -78,6 +79,8 @@ ecpg_get_connection(const char *connection_name)
if ((connection_name == NULL) || (strcmp(connection_name, "CURRENT") == 0))
{
#ifdef ENABLE_THREAD_SAFETY
+ ecpg_pthreads_init(); /* ensure actual_connection_key is valid */
+
ret = pthread_getspecific(actual_connection_key);
/*
@@ -85,8 +88,7 @@ ecpg_get_connection(const char *connection_name)
* connection and hope the user knows what they're doing (i.e. using
* their own mutex to protect that connection from concurrent accesses
*/
- /* if !ret then we got the connection from TSD */
- if (NULL == ret)
+ if (ret == NULL)
/* no TSD connection here either, using global */
ret = actual_connection;
#else