external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3601 from citusdata/maintenanced-dont-proc-exit-from-term-handler 

maintenanced: Don't call proc_exit in SIGTERM handler
pull/3584/head
Philip Dubé 2020-03-10 13:50:48 +00:00 committed by GitHub
parent 877687cc64 2b4ea33a2b
commit d0d51bb8c3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/backend/distributed/utils/maintenanced.c
View File

@ -102,6 +102,7 @@ static MaintenanceDaemonControlData *MaintenanceDaemonControl = NULL;
static HTAB *MaintenanceDaemonDBHash;
static volatile sig_atomic_t got_SIGHUP = false;
static volatile sig_atomic_t got_SIGTERM = false;
static void MaintenanceDaemonSigTermHandler(SIGNAL_ARGS);
static void MaintenanceDaemonSigHupHandler(SIGNAL_ARGS);
@ -145,8 +146,7 @@ InitializeMaintenanceDaemonBackend(void)
MaintenanceDaemonDBData *dbData = (MaintenanceDaemonDBData *) hash_search(
MaintenanceDaemonDBHash,
&
MyDatabaseId,
&MyDatabaseId,
HASH_ENTER_NULL,
&found);
@ -253,7 +253,7 @@ CitusMaintenanceDaemonMain(Datum main_arg)
/*
* Look up this worker's configuration.
*/
LWLockAcquire(&MaintenanceDaemonControl->lock, LW_SHARED);
LWLockAcquire(&MaintenanceDaemonControl->lock, LW_EXCLUSIVE);
MaintenanceDaemonDBData *myDbData = (MaintenanceDaemonDBData *)
hash_search(MaintenanceDaemonDBHash, &databaseOid,
@ -305,7 +305,7 @@ CitusMaintenanceDaemonMain(Datum main_arg)
pgstat_report_appname("Citus Maintenance Daemon");
/* enter main loop */
for (;;)
while (!got_SIGTERM)
{
int rc;
int latchFlags = WL_LATCH_SET | WL_TIMEOUT | WL_POSTMASTER_DEATH;
@ -651,7 +651,15 @@ MaintenanceDaemonShmemInit(void)
static void
MaintenanceDaemonSigTermHandler(SIGNAL_ARGS)
{
proc_exit(0);
int save_errno = errno;
got_SIGTERM = true;
if (MyProc != NULL)
{
SetLatch(&MyProc->procLatch);
}
errno = save_errno;
}