From 1fc1b4206e5f927145d653f7fa835b8230a825db Mon Sep 17 00:00:00 2001 From: Henry Oswald Date: Thu, 7 Feb 2019 13:57:38 +0000 Subject: [PATCH] add shutDownInProgress check into sig listening --- services/real-time/app.coffee | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/services/real-time/app.coffee b/services/real-time/app.coffee index 1035f83b68..ab0ac3627a 100644 --- a/services/real-time/app.coffee +++ b/services/real-time/app.coffee @@ -103,11 +103,17 @@ forceDrain = -> DrainManager.startDrain(io, 4) , Settings.forceDrainMsDelay +shutDownInProgress = false if Settings.forceDrainMsDelay? Settings.forceDrainMsDelay = parseInt(Settings.forceDrainMsDelay, 10) logger.log forceDrainMsDelay: Settings.forceDrainMsDelay,"forceDrainMsDelay enabled" for signal in ['SIGINT', 'SIGHUP', 'SIGQUIT', 'SIGUSR1', 'SIGUSR2', 'SIGTERM', 'SIGABRT'] process.on signal, -> - logger.log signal: signal, "received interrupt, cleaning up" - shutdownCleanly(signal) - forceDrain() + if shutDownInProgress + logger.log signal: signal, "shutdown already in progress, ignoring signal" + return + else + shutDownInProgress = true + logger.log signal: signal, "received interrupt, cleaning up" + shutdownCleanly(signal) + forceDrain()