summaryrefslogtreecommitdiff
path: root/src/supervision/s6-supervise.c
diff options
context:
space:
mode:
authorLaurent Bercot <ska-skaware@skarnet.org>2015-06-17 10:38:04 +0000
committerLaurent Bercot <ska-skaware@skarnet.org>2015-06-17 10:38:04 +0000
commite2f01f98672c501b6ec4b445956b48041267138f (patch)
tree0b9fd74a8511bd5fd73aa0e88a69bcc0b5ae36dc /src/supervision/s6-supervise.c
parentdf194e5564f5b32aaf0e107b97095a1dd5bdbe35 (diff)
downloads6-e2f01f98672c501b6ec4b445956b48041267138f.tar.xz
- Add support for SIGUSR1 for poweroff in s6-svscan
- Optimize respawn delay in s6-supervise
Diffstat (limited to 'src/supervision/s6-supervise.c')
-rw-r--r--src/supervision/s6-supervise.c15
1 files changed, 11 insertions, 4 deletions
diff --git a/src/supervision/s6-supervise.c b/src/supervision/s6-supervise.c
index 13c751e..e422da0 100644
--- a/src/supervision/s6-supervise.c
+++ b/src/supervision/s6-supervise.c
@@ -44,11 +44,19 @@ typedef void action_t (void) ;
typedef action_t *action_t_ref ;
static tain_t deadline ;
+static tain_t dontrespawnbefore = TAIN_EPOCH ;
static s6_svstatus_t status = { .stamp = TAIN_ZERO, .pid = 0, .flagwant = 1, .flagwantup = 1, .flagpaused = 0, .flagfinishing = 0, .wstat = 0 } ;
static state_t state = DOWN ;
static int cont = 1 ;
static int notifyfd = -1 ;
+static inline void down_and_delay (void)
+{
+ state = DOWN ;
+ if (tain_future(&dontrespawnbefore)) deadline = dontrespawnbefore ;
+ else tain_copynow(&deadline) ;
+}
+
static inline void settimeout (int secs)
{
tain_addsec_g(&deadline, secs) ;
@@ -247,6 +255,7 @@ static void trystart (void)
state = UP ;
status.pid = pid ;
tain_copynow(&status.stamp) ;
+ tain_addsec_g(&dontrespawnbefore, 1) ;
announce() ;
ftrigw_notifyb_nosig(S6_SUPERVISE_EVENTDIR, "u", 1) ;
}
@@ -291,8 +300,7 @@ static inline void tryfinish (int islast)
{
strerr_warnwu2sys("fork for ", "./finish") ;
if (islast) bail() ;
- state = DOWN ;
- settimeout(1) ;
+ down_and_delay() ;
return ;
}
else if (!pid)
@@ -385,9 +393,8 @@ static void finish_z (void)
{
status.pid = 0 ;
status.flagfinishing = 0 ;
- state = DOWN ;
+ down_and_delay() ;
announce() ;
- settimeout(1) ;
}
static void finish_u (void)