mirror/freebsd
1
0
Fork 0
mirror of https://git.FreeBSD.org/src.git synced 2024-12-30 12:04:07 +00:00
Code Issues Releases Activity

PR: bin/5572

Browse Source 
Prevent cron from going crazy if the time steps.  For example, if you
    have a system with hundreds of users and lots of different crontabs
    and your time steps back an hour, the old cron would then attempt to
    run an hours worth of cron jobs in a few seconds.
This commit is contained in:
Matthew Dillon 1998-12-13 06:07:38 +00:00
parent 7015208878
commit 4ef875d707
Notes: svn2git 2020-12-20 02:59:44 +00:00 
svn path=/head/; revision=41723
1 changed files with 28 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
usr.sbin/cron/cron/cron.c
View File

@ -17,7 +17,7 @@
#if !defined(lint) && !defined(LINT)
static const char rcsid[] =
"$Id: cron.c,v 1.6 1997/09/15 06:39:04 charnier Exp $";
"$Id: cron.c,v 1.7 1998/07/06 20:28:04 bde Exp $";
#endif
#define MAIN_PROGRAM
@ -227,28 +227,40 @@ cron_sync() {
static void
cron_sleep() {
register int seconds_to_wait;
int seconds_to_wait = 0;
do {
/*
* Loop until we reach the top of the next minute, sleep when possible.
*/
for (;;) {
seconds_to_wait = (int) (TargetTime - time((time_t*)0));
/*
* If the seconds_to_wait value is insane, jump the cron
*/
if (seconds_to_wait < -600 || seconds_to_wait > 600) {
cron_sync();
continue;
}
Debug(DSCH, ("[%d] TargetTime=%ld, sec-to-wait=%d\n",
getpid(), (long)TargetTime, seconds_to_wait))
/* if we intend to sleep, this means that it's finally
* time to empty the job queue (execute it).
*
* if we run any jobs, we'll probably screw up our timing,
* so go recompute.
*
* note that we depend here on the left-to-right nature
* of &&, and the short-circuiting.
/*
* If we've run out of wait time or there are no jobs left
* to run, break
*/
} while (seconds_to_wait > 0 && job_runqueue());
while (seconds_to_wait > 0) {
Debug(DSCH, ("[%d] sleeping for %d seconds\n",
getpid(), seconds_to_wait))
seconds_to_wait = (int) sleep((unsigned int) seconds_to_wait);
if (seconds_to_wait <= 0)
break;
if (job_runqueue() == 0) {
Debug(DSCH, ("[%d] sleeping for %d seconds\n",
getpid(), seconds_to_wait))
sleep(seconds_to_wait);
}
}
}