blob: 0df143ae7556f76b7ec10c166dcd521fac898cdb [file] [log] [blame]
Bernhard Reutner-Fischer2c998512006-04-12 18:09:26 +00001/* vi: set sw=4 ts=4: */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +00002/*
3 * crond -d[#] -c <crondir> -f -b
4 *
5 * run as root, but NOT setuid root
6 *
7 * Copyright 1994 Matthew Dillon (dillon@apollo.west.oic.com)
Denis Vlasenkob9c02dd2007-08-18 15:48:00 +00008 * (version 2.3.2)
Mike Frysingerf284c762006-04-16 20:38:26 +00009 * Vladimir Oleynik <dzo@simtreas.ru> (C) 2002
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000010 *
Mike Frysingerf284c762006-04-16 20:38:26 +000011 * Licensed under the GPL v2 or later, see the file LICENSE in this tarball.
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000012 */
13
Denis Vlasenkob9c02dd2007-08-18 15:48:00 +000014#include "libbb.h"
Bernhard Reutner-Fischerf4701962008-01-27 12:50:12 +000015#include <syslog.h>
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000016
17#ifndef CRONTABS
18#define CRONTABS "/var/spool/cron/crontabs"
19#endif
20#ifndef TMPDIR
21#define TMPDIR "/var/spool/cron"
22#endif
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000023#ifndef SENDMAIL
Denis Vlasenkob9c02dd2007-08-18 15:48:00 +000024#define SENDMAIL "sendmail"
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000025#endif
26#ifndef SENDMAIL_ARGS
Eric Andersen35e643b2003-07-28 07:40:39 +000027#define SENDMAIL_ARGS "-ti", "oem"
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000028#endif
29#ifndef CRONUPDATE
30#define CRONUPDATE "cron.update"
31#endif
32#ifndef MAXLINES
Glenn L McGrath9079ad02004-02-22 04:44:21 +000033#define MAXLINES 256 /* max lines in non-root crontabs */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000034#endif
35
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000036typedef struct CronFile {
Glenn L McGrath9079ad02004-02-22 04:44:21 +000037 struct CronFile *cf_Next;
38 struct CronLine *cf_LineBase;
39 char *cf_User; /* username */
40 int cf_Ready; /* bool: one or more jobs ready */
41 int cf_Running; /* bool: one or more jobs running */
42 int cf_Deleted; /* marked for deletion, ignore */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000043} CronFile;
44
45typedef struct CronLine {
Glenn L McGrath9079ad02004-02-22 04:44:21 +000046 struct CronLine *cl_Next;
47 char *cl_Shell; /* shell command */
48 pid_t cl_Pid; /* running pid, 0, or armed (-1) */
49 int cl_MailFlag; /* running pid is for mail */
50 int cl_MailPos; /* 'empty file' size */
51 char cl_Mins[60]; /* 0-59 */
52 char cl_Hrs[24]; /* 0-23 */
53 char cl_Days[32]; /* 1-31 */
54 char cl_Mons[12]; /* 0-11 */
55 char cl_Dow[7]; /* 0-6, beginning sunday */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000056} CronLine;
57
58#define RUN_RANOUT 1
59#define RUN_RUNNING 2
60#define RUN_FAILED 3
61
62#define DaemonUid 0
63
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +000064#if ENABLE_DEBUG_CROND_OPTION
Denis Vlasenko13858992006-10-08 12:49:22 +000065static unsigned DebugOpt;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000066#endif
67
Denis Vlasenko13858992006-10-08 12:49:22 +000068static unsigned LogLevel = 8;
Glenn L McGrath9079ad02004-02-22 04:44:21 +000069static const char *LogFile;
70static const char *CDir = CRONTABS;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000071
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000072static void startlogger(void);
73
74static void CheckUpdates(void);
75static void SynchronizeDir(void);
76static int TestJobs(time_t t1, time_t t2);
77static void RunJobs(void);
78static int CheckJobs(void);
Eric Andersen35e643b2003-07-28 07:40:39 +000079
Glenn L McGrath9079ad02004-02-22 04:44:21 +000080static void RunJob(const char *user, CronLine * line);
81
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +000082#if ENABLE_FEATURE_CROND_CALL_SENDMAIL
Glenn L McGrath9079ad02004-02-22 04:44:21 +000083static void EndJob(const char *user, CronLine * line);
Eric Andersen35e643b2003-07-28 07:40:39 +000084#else
85#define EndJob(user, line) line->cl_Pid = 0
86#endif
Eric Andersenf6f7bfb2002-10-22 12:24:59 +000087
88static void DeleteFile(const char *userName);
89
90static CronFile *FileBase;
91
92
Glenn L McGrath9079ad02004-02-22 04:44:21 +000093static void crondlog(const char *ctl, ...)
Eric Andersen35e643b2003-07-28 07:40:39 +000094{
Glenn L McGrath9079ad02004-02-22 04:44:21 +000095 va_list va;
96 const char *fmt;
97 int level = (int) (ctl[0] & 0xf);
98 int type = level == 20 ?
99 LOG_ERR : ((ctl[0] & 0100) ? LOG_WARNING : LOG_NOTICE);
Eric Andersen35e643b2003-07-28 07:40:39 +0000100
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000101 va_start(va, ctl);
102 fmt = ctl + 1;
103 if (level >= LogLevel) {
Eric Andersen35e643b2003-07-28 07:40:39 +0000104
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000105#if ENABLE_DEBUG_CROND_OPTION
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000106 if (DebugOpt) {
107 vfprintf(stderr, fmt, va);
108 } else
Eric Andersen35e643b2003-07-28 07:40:39 +0000109#endif
Denis Vlasenko314820e2008-01-24 01:33:12 +0000110 if (LogFile == NULL) {
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000111 vsyslog(type, fmt, va);
112 } else {
Denis Vlasenko50f7f442007-04-11 23:20:53 +0000113#if !ENABLE_DEBUG_CROND_OPTION
"Vladimir N. Oleynik"d0c41a82005-09-05 15:50:56 +0000114 int logfd = open(LogFile, O_WRONLY | O_CREAT | O_APPEND, 0600);
Denis Vlasenko50f7f442007-04-11 23:20:53 +0000115#else
116 int logfd = open3_or_warn(LogFile, O_WRONLY | O_CREAT | O_APPEND, 0600);
117#endif
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000118 if (logfd >= 0) {
119 vdprintf(logfd, fmt, va);
120 close(logfd);
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000121 }
Eric Andersen35e643b2003-07-28 07:40:39 +0000122 }
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000123 }
124 va_end(va);
125 if (ctl[0] & 0200) {
126 exit(20);
127 }
Eric Andersen35e643b2003-07-28 07:40:39 +0000128}
129
Denis Vlasenko9b49a5e2007-10-11 10:05:36 +0000130int crond_main(int argc, char **argv) MAIN_EXTERNALLY_VISIBLE;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000131int crond_main(int ac, char **av)
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000132{
Denis Vlasenko67b23e62006-10-03 21:00:06 +0000133 unsigned opt;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000134 char *lopt, *Lopt, *copt;
Denis Vlasenko5a142022007-03-26 13:20:54 +0000135 USE_DEBUG_CROND_OPTION(char *dopt;)
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000136
Denis Vlasenko5a142022007-03-26 13:20:54 +0000137 opt_complementary = "f-b:b-f:S-L:L-S" USE_DEBUG_CROND_OPTION(":d-l");
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000138 opterr = 0; /* disable getopt 'errors' message. */
Denis Vlasenkod37f2222007-08-19 13:42:08 +0000139 opt = getopt32(av, "l:L:fbSc:" USE_DEBUG_CROND_OPTION("d:"),
Denis Vlasenko5a142022007-03-26 13:20:54 +0000140 &lopt, &Lopt, &copt USE_DEBUG_CROND_OPTION(, &dopt));
141 if (opt & 1) /* -l */
Denis Vlasenko13858992006-10-08 12:49:22 +0000142 LogLevel = xatou(lopt);
Denis Vlasenko5a142022007-03-26 13:20:54 +0000143 if (opt & 2) /* -L */
144 if (*Lopt)
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000145 LogFile = Lopt;
Denis Vlasenko5a142022007-03-26 13:20:54 +0000146 if (opt & 32) /* -c */
147 if (*copt)
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000148 CDir = copt;
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000149#if ENABLE_DEBUG_CROND_OPTION
Denis Vlasenko5a142022007-03-26 13:20:54 +0000150 if (opt & 64) { /* -d */
Denis Vlasenko13858992006-10-08 12:49:22 +0000151 DebugOpt = xatou(dopt);
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000152 LogLevel = 0;
153 }
Eric Andersen8876fb22003-06-20 09:01:58 +0000154#endif
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000155
Denis Vlasenko5a142022007-03-26 13:20:54 +0000156 /* close stdin and stdout, stderr.
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000157 * close unused descriptors - don't need.
158 * optional detach from controlling terminal
159 */
Denis Vlasenko5a142022007-03-26 13:20:54 +0000160 if (!(opt & 4))
161 bb_daemonize_or_rexec(DAEMON_CLOSE_EXTRA_FDS, av);
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000162
Denis Vlasenko5a142022007-03-26 13:20:54 +0000163 xchdir(CDir);
164 signal(SIGHUP, SIG_IGN); /* ? original crond dies on HUP... */
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000165
Denis Vlasenko5a142022007-03-26 13:20:54 +0000166 startlogger(); /* need if syslog mode selected */
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000167
168 /*
169 * main loop - synchronize to 1 second after the minute, minimum sleep
170 * of 1 second.
171 */
Denis Vlasenkob9c02dd2007-08-18 15:48:00 +0000172 crondlog("\011%s " BB_VER " started, log level %d\n",
Denis Vlasenko8f8f2682006-10-03 21:00:43 +0000173 applet_name, LogLevel);
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000174
175 SynchronizeDir();
176
177 {
178 time_t t1 = time(NULL);
179 time_t t2;
180 long dt;
"Vladimir N. Oleynik"cd5c15d2006-01-30 13:36:03 +0000181 int rescan = 60;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000182 short sleep_time = 60;
183
Denis Vlasenko10457b92007-03-27 22:01:31 +0000184 write_pidfile("/var/run/crond.pid");
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000185 for (;;) {
186 sleep((sleep_time + 1) - (short) (time(NULL) % sleep_time));
187
188 t2 = time(NULL);
189 dt = t2 - t1;
190
191 /*
192 * The file 'cron.update' is checked to determine new cron
193 * jobs. The directory is rescanned once an hour to deal
194 * with any screwups.
195 *
196 * check for disparity. Disparities over an hour either way
197 * result in resynchronization. A reverse-indexed disparity
198 * less then an hour causes us to effectively sleep until we
199 * match the original time (i.e. no re-execution of jobs that
200 * have just been run). A forward-indexed disparity less then
201 * an hour causes intermediate jobs to be run, but only once
202 * in the worst case.
203 *
204 * when running jobs, the inequality used is greater but not
205 * equal to t1, and less then or equal to t2.
206 */
207
208 if (--rescan == 0) {
209 rescan = 60;
210 SynchronizeDir();
211 }
212 CheckUpdates();
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000213#if ENABLE_DEBUG_CROND_OPTION
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000214 if (DebugOpt)
215 crondlog("\005Wakeup dt=%d\n", dt);
216#endif
217 if (dt < -60 * 60 || dt > 60 * 60) {
218 t1 = t2;
219 crondlog("\111time disparity of %d minutes detected\n", dt / 60);
220 } else if (dt > 0) {
221 TestJobs(t1, t2);
222 RunJobs();
223 sleep(5);
224 if (CheckJobs() > 0) {
225 sleep_time = 10;
226 } else {
227 sleep_time = 60;
228 }
229 t1 = t2;
230 }
231 }
232 }
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000233 return 0; /* not reached */
Glenn L McGrathb89fcd42003-12-23 07:21:33 +0000234}
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000235
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000236static int ChangeUser(const char *user)
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000237{
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000238 struct passwd *pas;
239 const char *err_msg;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000240
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000241 /*
Eric Andersenaff114c2004-04-14 17:51:38 +0000242 * Obtain password entry and change privileges
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000243 */
244 pas = getpwnam(user);
245 if (pas == 0) {
246 crondlog("\011failed to get uid for %s", user);
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000247 return -1;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000248 }
249 setenv("USER", pas->pw_name, 1);
250 setenv("HOME", pas->pw_dir, 1);
251 setenv("SHELL", DEFAULT_SHELL, 1);
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000252
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000253 /*
254 * Change running state to the user in question
255 */
256 err_msg = change_identity_e2str(pas);
257 if (err_msg) {
258 crondlog("\011%s for user %s", err_msg, user);
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000259 return -1;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000260 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000261 if (chdir(pas->pw_dir) < 0) {
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000262 crondlog("\011chdir failed: %s: %m", pas->pw_dir);
263 if (chdir(TMPDIR) < 0) {
264 crondlog("\011chdir failed: %s: %m", TMPDIR);
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000265 return -1;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000266 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000267 }
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000268 return pas->pw_uid;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000269}
270
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000271static void startlogger(void)
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000272{
Denis Vlasenko314820e2008-01-24 01:33:12 +0000273 if (LogFile == NULL) {
Denis Vlasenko8f8f2682006-10-03 21:00:43 +0000274 openlog(applet_name, LOG_CONS | LOG_PID, LOG_CRON);
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000275 }
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000276#if ENABLE_DEBUG_CROND_OPTION
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000277 else { /* test logfile */
278 int logfd;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000279
Denis Vlasenko50f7f442007-04-11 23:20:53 +0000280 logfd = open3_or_warn(LogFile, O_WRONLY | O_CREAT | O_APPEND, 0600);
281 if (logfd >= 0) {
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000282 close(logfd);
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000283 }
284 }
Eric Andersen35e643b2003-07-28 07:40:39 +0000285#endif
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000286}
287
288
Denis Vlasenkof9000c52007-08-19 18:49:21 +0000289static const char DowAry[] ALIGN1 =
290 "sun""mon""tue""wed""thu""fri""sat"
291 /* "Sun""Mon""Tue""Wed""Thu""Fri""Sat" */
292;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000293
Denis Vlasenkof9000c52007-08-19 18:49:21 +0000294static const char MonAry[] ALIGN1 =
295 "jan""feb""mar""apr""may""jun""jul""aug""sep""oct""nov""dec"
296 /* "Jan""Feb""Mar""Apr""May""Jun""Jul""Aug""Sep""Oct""Nov""Dec" */
297;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000298
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000299static char *ParseField(char *user, char *ary, int modvalue, int off,
Denis Vlasenkof9000c52007-08-19 18:49:21 +0000300 const char *names, char *ptr)
301/* 'names' is a pointer to a set of 3-char abbreviations */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000302{
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000303 char *base = ptr;
304 int n1 = -1;
305 int n2 = -1;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000306
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000307 if (base == NULL) {
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000308 return NULL;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000309 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000310
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000311 while (*ptr != ' ' && *ptr != '\t' && *ptr != '\n') {
312 int skip = 0;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000313
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000314 /* Handle numeric digit or symbol or '*' */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000315
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000316 if (*ptr == '*') {
317 n1 = 0; /* everything will be filled */
318 n2 = modvalue - 1;
319 skip = 1;
320 ++ptr;
321 } else if (*ptr >= '0' && *ptr <= '9') {
322 if (n1 < 0) {
323 n1 = strtol(ptr, &ptr, 10) + off;
324 } else {
325 n2 = strtol(ptr, &ptr, 10) + off;
326 }
327 skip = 1;
328 } else if (names) {
329 int i;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000330
Denis Vlasenkof9000c52007-08-19 18:49:21 +0000331 for (i = 0; names[i]; i += 3) {
332 /* was using strncmp before... */
333 if (strncasecmp(ptr, &names[i], 3) == 0) {
334 ptr += 3;
335 if (n1 < 0) {
336 n1 = i / 3;
337 } else {
338 n2 = i / 3;
339 }
340 skip = 1;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000341 break;
342 }
343 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000344 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000345
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000346 /* handle optional range '-' */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000347
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000348 if (skip == 0) {
349 crondlog("\111failed user %s parsing %s\n", user, base);
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000350 return NULL;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000351 }
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000352 if (*ptr == '-' && n2 < 0) {
353 ++ptr;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000354 continue;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000355 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000356
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000357 /*
358 * collapse single-value ranges, handle skipmark, and fill
359 * in the character array appropriately.
360 */
361
362 if (n2 < 0) {
363 n2 = n1;
364 }
365 if (*ptr == '/') {
366 skip = strtol(ptr + 1, &ptr, 10);
367 }
368 /*
369 * fill array, using a failsafe is the easiest way to prevent
370 * an endless loop
371 */
372
373 {
374 int s0 = 1;
375 int failsafe = 1024;
376
377 --n1;
378 do {
379 n1 = (n1 + 1) % modvalue;
380
381 if (--s0 == 0) {
382 ary[n1 % modvalue] = 1;
383 s0 = skip;
384 }
385 }
386 while (n1 != n2 && --failsafe);
387
388 if (failsafe == 0) {
389 crondlog("\111failed user %s parsing %s\n", user, base);
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000390 return NULL;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000391 }
392 }
393 if (*ptr != ',') {
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000394 break;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000395 }
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000396 ++ptr;
397 n1 = -1;
398 n2 = -1;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000399 }
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000400
401 if (*ptr != ' ' && *ptr != '\t' && *ptr != '\n') {
402 crondlog("\111failed user %s parsing %s\n", user, base);
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000403 return NULL;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000404 }
405
406 while (*ptr == ' ' || *ptr == '\t' || *ptr == '\n') {
407 ++ptr;
408 }
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000409#if ENABLE_DEBUG_CROND_OPTION
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000410 if (DebugOpt) {
411 int i;
412
413 for (i = 0; i < modvalue; ++i) {
414 crondlog("\005%d", ary[i]);
415 }
416 crondlog("\005\n");
417 }
418#endif
419
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000420 return ptr;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000421}
422
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000423static void FixDayDow(CronLine * line)
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000424{
"Vladimir N. Oleynik"cd5c15d2006-01-30 13:36:03 +0000425 int i;
426 int weekUsed = 0;
427 int daysUsed = 0;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000428
Denis Vlasenko80b8b392007-06-25 10:55:35 +0000429 for (i = 0; i < (int)(ARRAY_SIZE(line->cl_Dow)); ++i) {
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000430 if (line->cl_Dow[i] == 0) {
431 weekUsed = 1;
432 break;
433 }
434 }
Denis Vlasenko80b8b392007-06-25 10:55:35 +0000435 for (i = 0; i < (int)(ARRAY_SIZE(line->cl_Days)); ++i) {
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000436 if (line->cl_Days[i] == 0) {
437 daysUsed = 1;
438 break;
439 }
440 }
441 if (weekUsed && !daysUsed) {
442 memset(line->cl_Days, 0, sizeof(line->cl_Days));
443 }
444 if (daysUsed && !weekUsed) {
445 memset(line->cl_Dow, 0, sizeof(line->cl_Dow));
446 }
447}
448
449
450
451static void SynchronizeFile(const char *fileName)
452{
453 int maxEntries = MAXLINES;
454 int maxLines;
455 char buf[1024];
456
457 if (strcmp(fileName, "root") == 0) {
458 maxEntries = 65535;
459 }
460 maxLines = maxEntries * 10;
461
462 if (fileName) {
463 FILE *fi;
464
465 DeleteFile(fileName);
466
467 fi = fopen(fileName, "r");
468 if (fi != NULL) {
469 struct stat sbuf;
470
471 if (fstat(fileno(fi), &sbuf) == 0 && sbuf.st_uid == DaemonUid) {
Denis Vlasenko9b1381f2007-01-03 02:56:00 +0000472 CronFile *file = xzalloc(sizeof(CronFile));
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000473 CronLine **pline;
474
475 file->cf_User = strdup(fileName);
476 pline = &file->cf_LineBase;
477
478 while (fgets(buf, sizeof(buf), fi) != NULL && --maxLines) {
479 CronLine line;
480 char *ptr;
481
Rob Landley828548a2005-09-01 10:23:57 +0000482 trim(buf);
483 if (buf[0] == 0 || buf[0] == '#') {
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000484 continue;
485 }
486 if (--maxEntries == 0) {
487 break;
488 }
489 memset(&line, 0, sizeof(line));
490
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000491#if ENABLE_DEBUG_CROND_OPTION
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000492 if (DebugOpt) {
493 crondlog("\111User %s Entry %s\n", fileName, buf);
494 }
495#endif
496
497 /* parse date ranges */
498 ptr = ParseField(file->cf_User, line.cl_Mins, 60, 0, NULL, buf);
499 ptr = ParseField(file->cf_User, line.cl_Hrs, 24, 0, NULL, ptr);
500 ptr = ParseField(file->cf_User, line.cl_Days, 32, 0, NULL, ptr);
501 ptr = ParseField(file->cf_User, line.cl_Mons, 12, -1, MonAry, ptr);
502 ptr = ParseField(file->cf_User, line.cl_Dow, 7, 0, DowAry, ptr);
503
504 /* check failure */
505 if (ptr == NULL) {
506 continue;
507 }
508
509 /*
510 * fix days and dow - if one is not * and the other
511 * is *, the other is set to 0, and vise-versa
512 */
513
514 FixDayDow(&line);
515
Denis Vlasenko9b1381f2007-01-03 02:56:00 +0000516 *pline = xzalloc(sizeof(CronLine));
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000517 **pline = line;
518
519 /* copy command */
520 (*pline)->cl_Shell = strdup(ptr);
521
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000522#if ENABLE_DEBUG_CROND_OPTION
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000523 if (DebugOpt) {
524 crondlog("\111 Command %s\n", ptr);
525 }
526#endif
527
528 pline = &((*pline)->cl_Next);
529 }
530 *pline = NULL;
531
532 file->cf_Next = FileBase;
533 FileBase = file;
534
535 if (maxLines == 0 || maxEntries == 0) {
536 crondlog("\111Maximum number of lines reached for user %s\n", fileName);
537 }
538 }
539 fclose(fi);
540 }
541 }
542}
543
544static void CheckUpdates(void)
545{
546 FILE *fi;
547 char buf[256];
548
549 fi = fopen(CRONUPDATE, "r");
550 if (fi != NULL) {
551 remove(CRONUPDATE);
552 while (fgets(buf, sizeof(buf), fi) != NULL) {
553 SynchronizeFile(strtok(buf, " \t\r\n"));
554 }
555 fclose(fi);
556 }
557}
558
559static void SynchronizeDir(void)
560{
561 /* Attempt to delete the database. */
562
563 for (;;) {
564 CronFile *file;
565
566 for (file = FileBase; file && file->cf_Deleted; file = file->cf_Next);
567 if (file == NULL) {
568 break;
569 }
570 DeleteFile(file->cf_User);
571 }
572
573 /*
574 * Remove cron update file
575 *
576 * Re-chdir, in case directory was renamed & deleted, or otherwise
577 * screwed up.
578 *
579 * scan directory and add associated users
580 */
581
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000582 remove(CRONUPDATE);
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000583 if (chdir(CDir) < 0) {
Denis Vlasenko89f0b342006-11-18 22:04:09 +0000584 crondlog("\311cannot find %s\n", CDir);
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000585 }
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000586 {
587 DIR *dir = opendir(".");
588 struct dirent *den;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000589
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000590 if (dir) {
591 while ((den = readdir(dir))) {
592 if (strchr(den->d_name, '.') != NULL) {
593 continue;
594 }
595 if (getpwnam(den->d_name)) {
596 SynchronizeFile(den->d_name);
597 } else {
598 crondlog("\007ignoring %s\n", den->d_name);
599 }
600 }
601 closedir(dir);
602 } else {
Denis Vlasenko89f0b342006-11-18 22:04:09 +0000603 crondlog("\311cannot open current dir!\n");
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000604 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000605 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000606}
607
608
609/*
610 * DeleteFile() - delete user database
611 *
612 * Note: multiple entries for same user may exist if we were unable to
613 * completely delete a database due to running processes.
614 */
615
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000616static void DeleteFile(const char *userName)
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000617{
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000618 CronFile **pfile = &FileBase;
619 CronFile *file;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000620
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000621 while ((file = *pfile) != NULL) {
622 if (strcmp(userName, file->cf_User) == 0) {
623 CronLine **pline = &file->cf_LineBase;
624 CronLine *line;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000625
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000626 file->cf_Running = 0;
627 file->cf_Deleted = 1;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000628
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000629 while ((line = *pline) != NULL) {
630 if (line->cl_Pid > 0) {
631 file->cf_Running = 1;
632 pline = &line->cl_Next;
633 } else {
634 *pline = line->cl_Next;
635 free(line->cl_Shell);
636 free(line);
637 }
638 }
639 if (file->cf_Running == 0) {
640 *pfile = file->cf_Next;
641 free(file->cf_User);
642 free(file);
643 } else {
644 pfile = &file->cf_Next;
645 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000646 } else {
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000647 pfile = &file->cf_Next;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000648 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000649 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000650}
651
652/*
653 * TestJobs()
654 *
655 * determine which jobs need to be run. Under normal conditions, the
656 * period is about a minute (one scan). Worst case it will be one
657 * hour (60 scans).
658 */
659
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000660static int TestJobs(time_t t1, time_t t2)
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000661{
"Vladimir N. Oleynik"cd5c15d2006-01-30 13:36:03 +0000662 int nJobs = 0;
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000663 time_t t;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000664
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000665 /* Find jobs > t1 and <= t2 */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000666
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000667 for (t = t1 - t1 % 60; t <= t2; t += 60) {
668 if (t > t1) {
669 struct tm *tp = localtime(&t);
670 CronFile *file;
671 CronLine *line;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000672
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000673 for (file = FileBase; file; file = file->cf_Next) {
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000674#if ENABLE_DEBUG_CROND_OPTION
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000675 if (DebugOpt)
676 crondlog("\005FILE %s:\n", file->cf_User);
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000677#endif
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000678 if (file->cf_Deleted)
679 continue;
680 for (line = file->cf_LineBase; line; line = line->cl_Next) {
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000681#if ENABLE_DEBUG_CROND_OPTION
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000682 if (DebugOpt)
683 crondlog("\005 LINE %s\n", line->cl_Shell);
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000684#endif
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000685 if (line->cl_Mins[tp->tm_min] && line->cl_Hrs[tp->tm_hour] &&
686 (line->cl_Days[tp->tm_mday] || line->cl_Dow[tp->tm_wday])
687 && line->cl_Mons[tp->tm_mon]) {
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000688#if ENABLE_DEBUG_CROND_OPTION
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000689 if (DebugOpt) {
690 crondlog("\005 JobToDo: %d %s\n",
691 line->cl_Pid, line->cl_Shell);
692 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000693#endif
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000694 if (line->cl_Pid > 0) {
695 crondlog("\010 process already running: %s %s\n",
696 file->cf_User, line->cl_Shell);
697 } else if (line->cl_Pid == 0) {
698 line->cl_Pid = -1;
699 file->cf_Ready = 1;
700 ++nJobs;
701 }
702 }
703 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000704 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000705 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000706 }
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000707 return nJobs;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000708}
709
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000710static void RunJobs(void)
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000711{
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000712 CronFile *file;
713 CronLine *line;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000714
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000715 for (file = FileBase; file; file = file->cf_Next) {
716 if (file->cf_Ready) {
717 file->cf_Ready = 0;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000718
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000719 for (line = file->cf_LineBase; line; line = line->cl_Next) {
720 if (line->cl_Pid < 0) {
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000721
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000722 RunJob(file->cf_User, line);
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000723
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000724 crondlog("\010USER %s pid %3d cmd %s\n",
725 file->cf_User, line->cl_Pid, line->cl_Shell);
726 if (line->cl_Pid < 0) {
727 file->cf_Ready = 1;
728 }
729 else if (line->cl_Pid > 0) {
730 file->cf_Running = 1;
731 }
732 }
733 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000734 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000735 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000736}
737
738/*
739 * CheckJobs() - check for job completion
740 *
741 * Check for job completion, return number of jobs still running after
742 * all done.
743 */
744
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000745static int CheckJobs(void)
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000746{
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000747 CronFile *file;
748 CronLine *line;
749 int nStillRunning = 0;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000750
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000751 for (file = FileBase; file; file = file->cf_Next) {
752 if (file->cf_Running) {
753 file->cf_Running = 0;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000754
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000755 for (line = file->cf_LineBase; line; line = line->cl_Next) {
756 if (line->cl_Pid > 0) {
757 int status;
Denis Vlasenkofb0eba72008-01-02 19:55:04 +0000758 int r = waitpid(line->cl_Pid, &status, WNOHANG);
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000759
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000760 if (r < 0 || r == line->cl_Pid) {
761 EndJob(file->cf_User, line);
762 if (line->cl_Pid) {
763 file->cf_Running = 1;
764 }
765 } else if (r == 0) {
766 file->cf_Running = 1;
767 }
768 }
769 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000770 }
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000771 nStillRunning += file->cf_Running;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000772 }
Denis Vlasenkof0ed3762006-10-26 23:21:47 +0000773 return nStillRunning;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000774}
775
776
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000777#if ENABLE_FEATURE_CROND_CALL_SENDMAIL
Eric Andersen35e643b2003-07-28 07:40:39 +0000778static void
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000779ForkJob(const char *user, CronLine * line, int mailFd,
Denis Vlasenko314820e2008-01-24 01:33:12 +0000780 const char *prog, const char *cmd, const char *arg,
781 const char *mail_filename)
Eric Andersen35e643b2003-07-28 07:40:39 +0000782{
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000783 /* Fork as the user in question and run program */
784 pid_t pid = fork();
Eric Andersen35e643b2003-07-28 07:40:39 +0000785
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000786 line->cl_Pid = pid;
787 if (pid == 0) {
788 /* CHILD */
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000789 /* Change running state to the user in question */
Eric Andersen35e643b2003-07-28 07:40:39 +0000790
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000791 if (ChangeUser(user) < 0) {
792 exit(0);
793 }
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000794#if ENABLE_DEBUG_CROND_OPTION
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000795 if (DebugOpt) {
796 crondlog("\005Child Running %s\n", prog);
797 }
Eric Andersen35e643b2003-07-28 07:40:39 +0000798#endif
799
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000800 if (mailFd >= 0) {
Denis Vlasenko314820e2008-01-24 01:33:12 +0000801 xmove_fd(mailFd, mail_filename ? 1 : 0);
802 dup2(1, 2);
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000803 }
804 execl(prog, prog, cmd, arg, NULL);
Denis Vlasenko89f0b342006-11-18 22:04:09 +0000805 crondlog("\024cannot exec, user %s cmd %s %s %s\n", user, prog, cmd, arg);
Denis Vlasenko314820e2008-01-24 01:33:12 +0000806 if (mail_filename) {
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000807 fdprintf(1, "Exec failed: %s -c %s\n", prog, arg);
808 }
809 exit(0);
Denis Vlasenko314820e2008-01-24 01:33:12 +0000810 }
811
812 if (pid < 0) {
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000813 /* FORK FAILED */
Denis Vlasenko314820e2008-01-24 01:33:12 +0000814 crondlog("\024cannot fork\n");
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000815 line->cl_Pid = 0;
Denis Vlasenko314820e2008-01-24 01:33:12 +0000816 if (mail_filename) {
817 remove(mail_filename);
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000818 }
Denis Vlasenko314820e2008-01-24 01:33:12 +0000819 } else if (mail_filename) {
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000820 /* PARENT, FORK SUCCESS
821 * rename mail-file based on pid of process
822 */
823 char mailFile2[128];
824
825 snprintf(mailFile2, sizeof(mailFile2), TMPDIR "/cron.%s.%d", user, pid);
Denis Vlasenko314820e2008-01-24 01:33:12 +0000826 rename(mail_filename, mailFile2);
Eric Andersen35e643b2003-07-28 07:40:39 +0000827 }
Eric Andersen35e643b2003-07-28 07:40:39 +0000828 /*
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000829 * Close the mail file descriptor.. we can't just leave it open in
830 * a structure, closing it later, because we might run out of descriptors
Eric Andersen35e643b2003-07-28 07:40:39 +0000831 */
Eric Andersen35e643b2003-07-28 07:40:39 +0000832
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000833 if (mailFd >= 0) {
834 close(mailFd);
835 }
Eric Andersen35e643b2003-07-28 07:40:39 +0000836}
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000837
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000838static void RunJob(const char *user, CronLine * line)
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000839{
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000840 char mailFile[128];
841 int mailFd;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000842
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000843 line->cl_Pid = 0;
844 line->cl_MailFlag = 0;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000845
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000846 /* open mail file - owner root so nobody can screw with it. */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000847
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000848 snprintf(mailFile, sizeof(mailFile), TMPDIR "/cron.%s.%d", user, getpid());
849 mailFd = open(mailFile, O_CREAT | O_TRUNC | O_WRONLY | O_EXCL | O_APPEND, 0600);
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000850
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000851 if (mailFd >= 0) {
852 line->cl_MailFlag = 1;
853 fdprintf(mailFd, "To: %s\nSubject: cron: %s\n\n", user,
854 line->cl_Shell);
Denis Vlasenkoea620772006-10-14 02:23:43 +0000855 line->cl_MailPos = lseek(mailFd, 0, SEEK_CUR);
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000856 } else {
Denis Vlasenko89f0b342006-11-18 22:04:09 +0000857 crondlog("\024cannot create mail file user %s file %s, output to /dev/null\n", user, mailFile);
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000858 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000859
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000860 ForkJob(user, line, mailFd, DEFAULT_SHELL, "-c", line->cl_Shell, mailFile);
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000861}
862
863/*
864 * EndJob - called when job terminates and when mail terminates
865 */
866
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000867static void EndJob(const char *user, CronLine * line)
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000868{
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000869 int mailFd;
870 char mailFile[128];
871 struct stat sbuf;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000872
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000873 /* No job */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000874
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000875 if (line->cl_Pid <= 0) {
876 line->cl_Pid = 0;
877 return;
878 }
879
880 /*
881 * End of job and no mail file
882 * End of sendmail job
883 */
884
885 snprintf(mailFile, sizeof(mailFile), TMPDIR "/cron.%s.%d", user, line->cl_Pid);
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000886 line->cl_Pid = 0;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000887
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000888 if (line->cl_MailFlag != 1) {
889 return;
890 }
891 line->cl_MailFlag = 0;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000892
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000893 /*
894 * End of primary job - check for mail file. If size has increased and
895 * the file is still valid, we sendmail it.
896 */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000897
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000898 mailFd = open(mailFile, O_RDONLY);
899 remove(mailFile);
900 if (mailFd < 0) {
901 return;
902 }
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000903
Denis Vlasenkob9c02dd2007-08-18 15:48:00 +0000904 if (fstat(mailFd, &sbuf) < 0 || sbuf.st_uid != DaemonUid
905 || sbuf.st_nlink != 0 || sbuf.st_size == line->cl_MailPos
906 || !S_ISREG(sbuf.st_mode)
907 ) {
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000908 close(mailFd);
909 return;
910 }
911 ForkJob(user, line, mailFd, SENDMAIL, SENDMAIL_ARGS, NULL);
Eric Andersen35e643b2003-07-28 07:40:39 +0000912}
913#else
Eric Andersenaff114c2004-04-14 17:51:38 +0000914/* crond without sendmail */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000915
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000916static void RunJob(const char *user, CronLine * line)
Eric Andersen35e643b2003-07-28 07:40:39 +0000917{
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000918 /* Fork as the user in question and run program */
919 pid_t pid = fork();
Eric Andersen35e643b2003-07-28 07:40:39 +0000920
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000921 if (pid == 0) {
922 /* CHILD */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000923
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000924 /* Change running state to the user in question */
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000925
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000926 if (ChangeUser(user) < 0) {
927 exit(0);
928 }
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000929#if ENABLE_DEBUG_CROND_OPTION
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000930 if (DebugOpt) {
931 crondlog("\005Child Running %s\n", DEFAULT_SHELL);
932 }
Eric Andersen35e643b2003-07-28 07:40:39 +0000933#endif
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000934
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000935 execl(DEFAULT_SHELL, DEFAULT_SHELL, "-c", line->cl_Shell, NULL);
Denis Vlasenko89f0b342006-11-18 22:04:09 +0000936 crondlog("\024cannot exec, user %s cmd %s -c %s\n", user,
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000937 DEFAULT_SHELL, line->cl_Shell);
938 exit(0);
939 } else if (pid < 0) {
940 /* FORK FAILED */
Denis Vlasenkoe1a0d482006-10-20 13:28:22 +0000941 crondlog("\024cannot, user %s\n", user);
Glenn L McGrath9079ad02004-02-22 04:44:21 +0000942 pid = 0;
943 }
944 line->cl_Pid = pid;
Eric Andersenf6f7bfb2002-10-22 12:24:59 +0000945}
Bernhard Reutner-Fischeref216292006-05-20 14:14:05 +0000946#endif /* ENABLE_FEATURE_CROND_CALL_SENDMAIL */