rdelaage/postgresql
1
0
Fork 0
mirror of https://git.postgresql.org/git/postgresql.git synced 2024-10-01 00:11:19 +02:00
Code Issues Packages Projects Releases Wiki Activity

Remove race conditions between ECPGdebug() and ecpg_log().

Browse Source 
Coverity complains that ECPGdebug is accessing debugstream without
holding debug_mutex, which is a fair complaint: we should take
debug_mutex while changing the settings ecpg_log looks at.

In some branches it also complains about unlocked use of simple_debug.
I think it's intentional and safe to have a quick unlocked check of
simple_debug at the start of ecpg_log, since that early exit will
always be taken in non-debug cases.  But we should recheck
simple_debug after acquiring the mutex.  In the worst case, calling
ECPGdebug concurrently with ecpg_log in another thread could result
in a null-pointer dereference due to debugstream transiently being
NULL while simple_debug isn't 0.

This is largely hypothetical, since it's unlikely anybody uses
ECPGdebug() at all in the field, and our own regression tests
don't seem to be hitting the theoretical race conditions either.
Still, if we're going to the trouble of having mutexes here, we ought
to be using them in a way that's actually safe not just almost safe.
Hence, back-patch to all supported branches.
This commit is contained in:
Tom Lane 2024-05-23 15:52:06 -04:00
parent da32f5c4bc
commit 0162a9bde2
1 changed files with 28 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src/interfaces/ecpg/ecpglib/misc.c
View File

@ -60,7 +60,7 @@ static pthread_once_t sqlca_key_once = PTHREAD_ONCE_INIT;
static pthread_mutex_t debug_mutex = PTHREAD_MUTEX_INITIALIZER; static pthread_mutex_t debug_mutex = PTHREAD_MUTEX_INITIALIZER;
static pthread_mutex_t debug_init_mutex = PTHREAD_MUTEX_INITIALIZER; static pthread_mutex_t debug_init_mutex = PTHREAD_MUTEX_INITIALIZER;
static int simple_debug = 0; static volatile int simple_debug = 0;
static FILE *debugstream = NULL; static FILE *debugstream = NULL;
void void
@ -203,8 +203,12 @@ ECPGtrans(int lineno, const char *connection_name, const char *transaction)
void void
ECPGdebug(int n, FILE *dbgs) ECPGdebug(int n, FILE *dbgs)
{ {
/* Interlock against concurrent executions of ECPGdebug() */
pthread_mutex_lock(&debug_init_mutex); pthread_mutex_lock(&debug_init_mutex);
/* Prevent ecpg_log() from printing while we change settings */
pthread_mutex_lock(&debug_mutex);
if (n > 100) if (n > 100)
{ {
ecpg_internal_regression_mode = true; ecpg_internal_regression_mode = true;
@ -215,6 +219,10 @@ ECPGdebug(int n, FILE *dbgs)
debugstream = dbgs; debugstream = dbgs;
/* We must release debug_mutex before invoking ecpg_log() ... */
pthread_mutex_unlock(&debug_mutex);
/* ... but keep holding debug_init_mutex to avoid racy printout */
ecpg_log("ECPGdebug: set to %d\n", simple_debug); ecpg_log("ECPGdebug: set to %d\n", simple_debug);
pthread_mutex_unlock(&debug_init_mutex); pthread_mutex_unlock(&debug_init_mutex);
@ -229,6 +237,11 @@ ecpg_log(const char *format,...)
int bufsize; int bufsize;
char *fmt; char *fmt;
/*
* For performance reasons, inspect simple_debug without taking the mutex.
* This could be problematic if fetching an int isn't atomic, but we
* assume that it is in many other places too.
*/
if (!simple_debug) if (!simple_debug)
return; return;
@ -251,18 +264,22 @@ ecpg_log(const char *format,...)
pthread_mutex_lock(&debug_mutex); pthread_mutex_lock(&debug_mutex);
va_start(ap, format); /* Now that we hold the mutex, recheck simple_debug */
vfprintf(debugstream, fmt, ap); if (simple_debug)
va_end(ap);
/* dump out internal sqlca variables */
if (ecpg_internal_regression_mode && sqlca != NULL)
{ {
fprintf(debugstream, "[NO_PID]: sqlca: code: %ld, state: %s\n", va_start(ap, format);
sqlca->sqlcode, sqlca->sqlstate); vfprintf(debugstream, fmt, ap);
} va_end(ap);
fflush(debugstream); /* dump out internal sqlca variables */
if (ecpg_internal_regression_mode && sqlca != NULL)
{
fprintf(debugstream, "[NO_PID]: sqlca: code: %ld, state: %s\n",
sqlca->sqlcode, sqlca->sqlstate);
}
fflush(debugstream);
}
pthread_mutex_unlock(&debug_mutex); pthread_mutex_unlock(&debug_mutex);