1 /*
2 * CDDL HEADER START
3 *
4 * The contents of this file are subject to the terms of the
5 * Common Development and Distribution License (the "License").
6 * You may not use this file except in compliance with the License.
7 *
8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9 * or http://www.opensolaris.org/os/licensing.
10 * See the License for the specific language governing permissions
11 * and limitations under the License.
12 *
13 * When distributing Covered Code, include this CDDL HEADER in each
14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15 * If applicable, add the following below this CDDL HEADER, with the
16 * fields enclosed by brackets "[]" replaced with your own identifying
17 * information: Portions Copyright [yyyy] [name of copyright owner]
18 *
19 * CDDL HEADER END
20 */
21
22 /*
23 * Copyright (c) 2011 Gary Mills
24 *
25 * Copyright 2009 Sun Microsystems, Inc. All rights reserved.
26 * Use is subject to license terms.
27 */
28
29 /* Copyright (c) 1984, 1986, 1987, 1988, 1989 AT&T */
30 /* All Rights Reserved */
31
32 #include <sys/resource.h>
33 #include <sys/stat.h>
34 #include <sys/types.h>
35
36 #include <dirent.h>
37 #include <string.h>
38 #include <stdlib.h>
39 #include <fcntl.h>
40 #include <pwd.h>
41 #include <stdio.h>
42 #include <ctype.h>
43 #include <time.h>
44 #include <signal.h>
45 #include <errno.h>
46 #include <limits.h>
47 #include <ulimit.h>
48 #include <unistd.h>
49 #include <locale.h>
50 #include <libintl.h>
51 #include <tzfile.h>
52 #include <project.h>
53 #include <paths.h>
54
55 #include "cron.h"
56
57 #define TMPFILE "_at" /* prefix for temporary files */
58 /*
59 * Mode for creating files in ATDIR.
60 * Setuid bit on so that if an owner of a file gives that file
61 * away to someone else, the setuid bit will no longer be set.
62 * If this happens, atrun will not execute the file
63 */
64 #define ATMODE (S_ISUID | S_IRUSR | S_IRGRP | S_IROTH)
65 #define ROOT 0 /* user-id of super-user */
66 #define MAXTRYS 100 /* max trys to create at job file */
67
68 #define BADTIME "bad time specification"
69 #define BADQUEUE "queue name must be a single character a-z"
70 #define NOTCQUEUE "queue c is reserved for cron entries"
71 #define BADSHELL "because your login shell isn't /usr/bin/sh,"\
72 "you can't use at"
73 #define WARNSHELL "commands will be executed using %s\n"
74 #define CANTCD "can't change directory to the at directory"
75 #define CANTCHOWN "can't change the owner of your job to you"
76 #define CANTCHUID "can't change user identifier"
77 #define CANTCREATE "can't create a job for you"
78 #define INVALIDUSER "you are not a valid user (no entry in /etc/passwd)"
79 #define NOOPENDIR "can't open the at directory"
80 #define NOTALLOWED "you are not authorized to use at. Sorry."
81 #define USAGE\
82 "usage: at [-c|-k|-s] [-m] [-f file] [-p project] [-q queuename] "\
83 "-t time\n"\
84 " at [-c|-k|-s] [-m] [-f file] [-p project] [-q queuename] "\
85 "timespec\n"\
86 " at -l [-p project] [-q queuename] [at_job_id...]\n"\
87 " at -r at_job_id ...\n"
88
89 #define FORMAT "%a %b %e %H:%M:%S %Y"
90
91 static int leap(int);
92 static int atoi_for2(char *);
93 static int check_queue(char *, int);
94 static int list_jobs(int, char **, int, int);
95 static int remove_jobs(int, char **, char *);
96 static void usage(void);
97 static void catch(int);
98 static void copy(char *, FILE *, int);
99 static void atime(struct tm *, struct tm *);
100 static int not_this_project(char *);
101 static char *mkjobname(time_t);
102 static time_t parse_time(char *);
103 static time_t gtime(struct tm *);
104 void atabort(char *)__NORETURN;
105 void yyerror(void);
106 extern int yyparse(void);
107
108 extern void audit_at_delete(char *, char *, int);
109 extern int audit_at_create(char *, int);
110 extern int audit_cron_is_anc_name(char *);
111 extern int audit_cron_delete_anc_file(char *, char *);
112
113 /*
114 * Error in getdate(3G)
115 */
116 static char *errlist[] = {
117 /* 0 */ "",
118 /* 1 */ "getdate: The DATEMSK environment variable is not set",
119 /* 2 */ "getdate: Error on \"open\" of the template file",
120 /* 3 */ "getdate: Error on \"stat\" of the template file",
121 /* 4 */ "getdate: The template file is not a regular file",
122 /* 5 */ "getdate: An error is encountered while reading the template",
123 /* 6 */ "getdate: Malloc(3C) failed",
124 /* 7 */ "getdate: There is no line in the template that matches the input",
125 /* 8 */ "getdate: Invalid input specification"
126 };
127
128 int gmtflag = 0;
129 int mday[12] = {31, 29, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31};
130 uid_t user;
131 struct tm *tp, at, rt;
132 static int cshflag = 0;
133 static int kshflag = 0;
134 static int shflag = 0;
135 static int mflag = 0;
136 static int pflag = 0;
137 static char *Shell;
138 static char *tfname;
139 static char pname[80];
140 static char pname1[80];
141 static short jobtype = ATEVENT; /* set to 1 if batch job */
142 extern char *argp;
143 extern int per_errno;
144 static projid_t project;
145
146 int
147 main(int argc, char **argv)
148 {
149 FILE *inputfile;
150 int i, fd;
151 int try = 0;
152 int fflag = 0;
153 int lflag = 0;
154 int qflag = 0;
155 int rflag = 0;
156 int tflag = 0;
157 int c;
158 int tflen;
159 char *file;
160 char *login;
161 char *job;
162 char *jobfile = NULL; /* file containing job to be run */
163 char argpbuf[LINE_MAX], timebuf[80];
164 time_t now;
165 time_t when = 0;
166 struct tm *ct;
167 char *proj;
168 struct project prj, *pprj;
169 char mybuf[PROJECT_BUFSZ];
170 char ipbuf[PROJECT_BUFSZ];
171
172 (void) setlocale(LC_ALL, "");
173 #if !defined(TEXT_DOMAIN) /* Should be defined by cc -D */
174 #define TEXT_DOMAIN "SYS_TEST" /* Use this only if it weren't */
175 #endif
176 (void) textdomain(TEXT_DOMAIN);
177
178 user = getuid();
179 login = getuser(user);
180 if (login == NULL) {
181 if (per_errno == 2)
182 atabort(BADSHELL);
183 else
184 atabort(INVALIDUSER);
185 }
186
187 if (!allowed(login, ATALLOW, ATDENY))
188 atabort(NOTALLOWED);
189
190 while ((c = getopt(argc, argv, "cklmsrf:p:q:t:")) != EOF)
191 switch (c) {
192 case 'c':
193 cshflag++;
194 break;
195 case 'f':
196 fflag++;
197 jobfile = optarg;
198 break;
199 case 'k':
200 kshflag++;
201 break;
202 case 'l':
203 lflag++;
204 break;
205 case 'm':
206 mflag++;
207 break;
208 case 'p':
209 proj = optarg;
210 pprj = &prj;
211 if ((pprj = getprojbyname(proj, pprj,
212 (void *)&mybuf, sizeof (mybuf))) != NULL) {
213 project = pprj->pj_projid;
214 if (inproj(login, pprj->pj_name,
215 (void *)&ipbuf, sizeof (ipbuf)))
216 pflag++;
217 else {
218 (void) fprintf(stderr,
219 gettext("at: user %s is "
220 "not a member of "
221 "project %s (%d)\n"),
222 login, pprj->pj_name,
223 project);
224 exit(2);
225 }
226 break;
227 }
228 pprj = &prj;
229 if (isdigit(proj[0]) &&
230 (pprj = getprojbyid(atoi(proj), pprj,
231 (void *)&mybuf, sizeof (mybuf))) != NULL) {
232 project = pprj->pj_projid;
233 if (inproj(login, pprj->pj_name,
234 (void *)&ipbuf, sizeof (ipbuf)))
235 pflag++;
236 else {
237 (void) fprintf(stderr,
238 gettext("at: user %s is "
239 "not a member of "
240 "project %s (%d)\n"),
241 login, pprj->pj_name,
242 project);
243 exit(2);
244 }
245 break;
246 }
247 (void) fprintf(stderr, gettext("at: project "
248 "%s not found.\n"), proj);
249 exit(2);
250 break;
251 case 'q':
252 qflag++;
253 if (optarg[1] != '\0')
254 atabort(BADQUEUE);
255 jobtype = *optarg - 'a';
256 if ((jobtype < 0) || (jobtype > 25))
257 atabort(BADQUEUE);
258 if (jobtype == 2)
259 atabort(NOTCQUEUE);
260 break;
261 case 'r':
262 rflag++;
263 break;
264 case 's':
265 shflag++;
266 break;
267 case 't':
268 tflag++;
269 when = parse_time(optarg);
270 break;
271 default:
272 usage();
273 }
274
275 argc -= optind;
276 argv += optind;
277
278 if (lflag + rflag > 1)
279 usage();
280
281 if (lflag) {
282 if (cshflag || kshflag || shflag || mflag ||
283 fflag || tflag || rflag)
284 usage();
285 return (list_jobs(argc, argv, qflag, jobtype));
286 }
287
288 if (rflag) {
289 if (cshflag || kshflag || shflag || mflag ||
290 fflag || tflag || qflag)
291 usage();
292 return (remove_jobs(argc, argv, login));
293 }
294
295 if ((argc + tflag == 0) && (jobtype != BATCHEVENT))
296 usage();
297
298 if (cshflag + kshflag + shflag > 1)
299 atabort("ambiguous shell request");
300
301 time(&now);
302
303 if (jobtype == BATCHEVENT)
304 when = now;
305
306 if (when == 0) { /* figure out what time to run the job */
307 int argplen = sizeof (argpbuf) - 1;
308
309 argpbuf[0] = '\0';
310 argp = argpbuf;
311 i = 0;
312 while (i < argc) {
313 /* guard against buffer overflow */
314 argplen -= strlen(argv[i]) + 1;
315 if (argplen < 0)
316 atabort(BADTIME);
317
318 strcat(argp, argv[i]);
319 strcat(argp, " ");
320 i++;
321 }
322 if ((file = getenv("DATEMSK")) == 0 || file[0] == '\0') {
323 tp = localtime(&now);
324 /*
325 * Fix for 1047182 - we have to let yyparse
326 * check bounds on mday[] first, then fixup
327 * the leap year case.
328 */
329 yyparse();
330
331 mday[1] = 28 + leap(at.tm_year);
332
333 if (at.tm_mday > mday[at.tm_mon])
334 atabort("bad date");
335
336 atime(&at, &rt);
337 when = gtime(&at);
338 if (!gmtflag) {
339 when += timezone;
340 if (localtime(&when)->tm_isdst)
341 when -= (timezone-altzone);
342 }
343 } else { /* DATEMSK is set */
344 if ((ct = getdate(argpbuf)) == NULL)
345 atabort(errlist[getdate_err]);
346 else
347 when = mktime(ct);
348 }
349 }
350
351 if (when < now) /* time has already past */
352 atabort("too late");
353
354 tflen = strlen(ATDIR) + 1 + strlen(TMPFILE) +
355 10 + 1; /* 10 for an INT_MAX pid */
356 tfname = xmalloc(tflen);
357 snprintf(tfname, tflen, "%s/%s%d", ATDIR, TMPFILE, getpid());
358
359 /* catch INT, HUP, TERM and QUIT signals */
360 if (signal(SIGINT, catch) == SIG_IGN)
361 signal(SIGINT, SIG_IGN);
362 if (signal(SIGHUP, catch) == SIG_IGN)
363 signal(SIGHUP, SIG_IGN);
364 if (signal(SIGQUIT, catch) == SIG_IGN)
365 signal(SIGQUIT, SIG_IGN);
366 if (signal(SIGTERM, catch) == SIG_IGN)
367 signal(SIGTERM, SIG_IGN);
368 if ((fd = open(tfname, O_CREAT|O_EXCL|O_WRONLY, ATMODE)) < 0)
369 atabort(CANTCREATE);
370 if (chown(tfname, user, getgid()) == -1) {
371 unlink(tfname);
372 atabort(CANTCHOWN);
373 }
374 close(1);
375 dup(fd);
376 close(fd);
377 sprintf(pname, "%s", PROTO);
378 sprintf(pname1, "%s.%c", PROTO, 'a'+jobtype);
379
380 /*
381 * Open the input file with the user's permissions.
382 */
383 if (jobfile != NULL) {
384 if ((seteuid(user) < 0) ||
385 (inputfile = fopen(jobfile, "r")) == NULL) {
386 unlink(tfname);
387 fprintf(stderr, "at: %s: %s\n", jobfile, errmsg(errno));
388 exit(1);
389 }
390 else
391 seteuid(0);
392 } else
393 inputfile = stdin;
394
395 copy(jobfile, inputfile, when);
396 while (rename(tfname, job = mkjobname(when)) == -1) {
397 sleep(1);
398 if (++try > MAXTRYS / 10) {
399 unlink(tfname);
400 atabort(CANTCREATE);
401 }
402 }
403 unlink(tfname);
404 if (audit_at_create(job, 0))
405 atabort(CANTCREATE);
406
407 cron_sendmsg(ADD, login, strrchr(job, '/')+1, AT);
408 if (per_errno == 2)
409 fprintf(stderr, gettext(WARNSHELL), Shell);
410 cftime(timebuf, FORMAT, &when);
411 fprintf(stderr, gettext("job %s at %s\n"),
412 strrchr(job, '/')+1, timebuf);
413 if (when - MINUTE < HOUR)
414 fprintf(stderr, gettext(
415 "at: this job may not be executed at the proper time.\n"));
416 return (0);
417 }
418
419
420 static char *
421 mkjobname(t)
422 time_t t;
423 {
424 int i, fd;
425 char *name;
426
427 name = xmalloc(200);
428 for (i = 0; i < MAXTRYS; i++) {
429 sprintf(name, "%s/%ld.%c", ATDIR, t, 'a'+jobtype);
430 /* fix for 1099183, 1116833 - create file here, avoid race */
431 if ((fd = open(name, O_CREAT | O_EXCL, ATMODE)) > 0) {
432 close(fd);
433 return (name);
434 }
435 t += 1;
436 }
437 atabort("queue full");
438 /* NOTREACHED */
439 }
440
441
442 static void
443 catch(int x)
444 {
445 unlink(tfname);
446 exit(1);
447 }
448
449
450 void
451 atabort(msg)
452 char *msg;
453 {
454 fprintf(stderr, "at: %s\n", gettext(msg));
455
456 exit(1);
457 }
458
459 int
460 yywrap(void)
461 {
462 return (1);
463 }
464
465 void
466 yyerror(void)
467 {
468 atabort(BADTIME);
469 }
470
471 /*
472 * add time structures logically
473 */
474 static void
475 atime(struct tm *a, struct tm *b)
476 {
477 if ((a->tm_sec += b->tm_sec) >= 60) {
478 b->tm_min += a->tm_sec / 60;
479 a->tm_sec %= 60;
480 }
481 if ((a->tm_min += b->tm_min) >= 60) {
482 b->tm_hour += a->tm_min / 60;
483 a->tm_min %= 60;
484 }
485 if ((a->tm_hour += b->tm_hour) >= 24) {
486 b->tm_mday += a->tm_hour / 24;
487 a->tm_hour %= 24;
488 }
489 a->tm_year += b->tm_year;
490 if ((a->tm_mon += b->tm_mon) >= 12) {
491 a->tm_year += a->tm_mon / 12;
492 a->tm_mon %= 12;
493 }
494 a->tm_mday += b->tm_mday;
495 mday[1] = 28 + leap(a->tm_year);
496 while (a->tm_mday > mday[a->tm_mon]) {
497 a->tm_mday -= mday[a->tm_mon++];
498 if (a->tm_mon > 11) {
499 a->tm_mon = 0;
500 mday[1] = 28 + leap(++a->tm_year);
501 }
502 }
503
504 }
505
506 static int
507 leap(int year)
508 {
509 return (isleap(year + TM_YEAR_BASE));
510 }
511
512 /*
513 * return time from time structure
514 */
515 static time_t
516 gtime(tptr)
517 struct tm *tptr;
518 {
519 int i;
520 long tv;
521 int dmsize[12] =
522 {31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31};
523
524
525 tv = 0;
526 for (i = 1970; i != tptr->tm_year+TM_YEAR_BASE; i++)
527 tv += (365 + isleap(i));
528 /*
529 * We call isleap since leap() adds
530 * 1900 onto any value passed
531 */
532
533 if (!leap(tptr->tm_year) && at.tm_mday == 29 && at.tm_mon == 1)
534 atabort("bad date - not a leap year");
535
536 if ((leap(tptr->tm_year)) && tptr->tm_mon >= 2)
537 ++tv;
538
539 for (i = 0; i < tptr->tm_mon; ++i)
540 tv += dmsize[i];
541 tv += tptr->tm_mday - 1;
542 tv = 24 * tv + tptr->tm_hour;
543 tv = 60 * tv + tptr->tm_min;
544 tv = 60 * tv + tptr->tm_sec;
545 return (tv);
546 }
547
548 /*
549 * make job file from proto + stdin
550 */
551 static void
552 copy(char *jobfile, FILE *inputfile, int when)
553 {
554 int c;
555 FILE *pfp;
556 char *shell;
557 char dirbuf[PATH_MAX + 1];
558 char line[LINE_MAX];
559 char **ep;
560 mode_t um;
561 char *val;
562 extern char **environ;
563 uid_t realusr, effeusr;
564 int ttyinput;
565 int ulimit_flag = 0;
566 struct rlimit rlp;
567 struct project prj, *pprj;
568 char pbuf[PROJECT_BUFSZ];
569 char pbuf2[PROJECT_BUFSZ];
570 char *user;
571
572 /*
573 * Fix for 1099381:
574 * If the inputfile is from a tty, then turn on prompting, and
575 * put out a prompt now, instead of waiting for a lot of file
576 * activity to complete.
577 */
578 ttyinput = isatty(fileno(inputfile));
579 if (ttyinput) {
580 fputs("at> ", stderr);
581 fflush(stderr);
582 }
583
584 /*
585 * Fix for 1053807:
586 * Determine what shell we should use to run the job. If the user
587 * didn't explicitly request that his/her current shell be over-
588 * ridden (shflag or cshflag), then we use the current shell.
589 */
590 if (cshflag)
591 Shell = shell = "/bin/csh";
592 else if (kshflag) {
593 Shell = shell = "/bin/ksh";
594 ulimit_flag = 1;
595 } else if (shflag) {
596 Shell = shell = "/bin/sh";
597 ulimit_flag = 1;
598 } else if (((Shell = val = getenv("SHELL")) != NULL) &&
599 (*val != '\0')) {
600 shell = "$SHELL";
601 if ((strstr(val, "/sh") != NULL) ||
602 (strstr(val, "/ksh") != NULL))
603 ulimit_flag = 1;
604 } else {
605 /* SHELL is NULL or unset, therefore use default */
606 Shell = shell = _PATH_BSHELL;
607 ulimit_flag = 1;
608 }
609
610 printf(": %s job\n", jobtype ? "batch" : "at");
611 printf(": jobname: %.127s\n", (jobfile == NULL) ? "stdin" : jobfile);
612 printf(": notify by mail: %s\n", (mflag) ? "yes" : "no");
613
614 if (pflag) {
615 (void) printf(": project: %d\n", project);
616 } else {
617 /*
618 * Check if current user is a member of current project.
619 * This check is done here to avoid setproject() failure
620 * later when the job gets executed. If current user does
621 * not belong to current project, user's default project
622 * will be used instead. This is achieved by not specifying
623 * the project (": project: <project>\n") in the job file.
624 */
625 if ((user = getuser(getuid())) == NULL)
626 atabort(INVALIDUSER);
627 project = getprojid();
628 pprj = getprojbyid(project, &prj, pbuf, sizeof (pbuf));
629 if (pprj != NULL) {
630 if (inproj(user, pprj->pj_name, pbuf2, sizeof (pbuf2)))
631 (void) printf(": project: %d\n", project);
632 }
633 }
634
635 for (ep = environ; *ep; ep++) {
636 if (strchr(*ep, '\'') != NULL)
637 continue;
638 if ((val = strchr(*ep, '=')) == NULL)
639 continue;
640 *val++ = '\0';
641 printf("export %s; %s='%s'\n", *ep, *ep, val);
642 *--val = '=';
643 }
644 if ((pfp = fopen(pname1, "r")) == NULL &&
645 (pfp = fopen(pname, "r")) == NULL)
646 atabort("no prototype");
647 /*
648 * Put in a line to run the proper shell using the rest of
649 * the file as input. Note that 'exec'ing the shell will
650 * cause sh() to leave a /tmp/sh### file around. (1053807)
651 */
652 printf("%s << '...the rest of this file is shell input'\n", shell);
653
654 um = umask(0);
655 while ((c = getc(pfp)) != EOF) {
656 if (c != '$')
657 putchar(c);
658 else switch (c = getc(pfp)) {
659 case EOF:
660 goto out;
661 case 'd':
662 /*
663 * Must obtain current working directory as the user
664 */
665
666 dirbuf[0] = '\0';
667 realusr = getuid();
668 effeusr = geteuid();
669 /* change euid for getcwd */
670 if (seteuid(realusr) < 0) {
671 atabort(CANTCHUID);
672 }
673 if (getcwd(dirbuf, sizeof (dirbuf)) == NULL) {
674 atabort(
675 "can't obtain current working directory");
676 }
677 /* change back afterwards */
678 if (seteuid(effeusr) < 0) {
679 atabort(CANTCHUID);
680 }
681 printf("%s", dirbuf);
682 break;
683 case 'm':
684 printf("%o", um);
685 break;
686 case '<':
687 if (ulimit_flag) {
688 if (getrlimit(RLIMIT_FSIZE, &rlp) == 0) {
689 if (rlp.rlim_cur == RLIM_INFINITY)
690 printf("ulimit unlimited\n");
691 else
692 printf("ulimit %lld\n",
693 rlp.rlim_cur / 512);
694 }
695 }
696 /*
697 * fix for 1113572 - use fputs() so that a
698 * newline isn't appended to the one returned
699 * with fgets(); 1099381 - prompt for input.
700 */
701 while (fgets(line, LINE_MAX, inputfile) != NULL) {
702 fputs(line, stdout);
703 if (ttyinput)
704 fputs("at> ", stderr);
705 }
706 if (ttyinput) /* clean up the final output */
707 fputs("<EOT>\n", stderr);
708 break;
709 case 't':
710 printf(":%lu", when);
711 break;
712 default:
713 putchar(c);
714 }
715 }
716 out:
717 fclose(pfp);
718 fflush(NULL);
719 }
720
721 static int
722 remove_jobs(int argc, char **argv, char *login)
723 /* remove jobs that are specified */
724 {
725 int i, r;
726 int error = 0;
727 struct stat buf;
728 struct passwd *pw;
729
730 pw = getpwuid(user);
731 if (pw == NULL) {
732 atabort("Invalid user.\n");
733 }
734
735 if (argc == 0)
736 usage();
737 if (chdir(ATDIR) == -1)
738 atabort(CANTCD);
739 for (i = 0; i < argc; i++)
740 if (strchr(argv[i], '/') != NULL) {
741 fprintf(stderr, "at: %s: not a valid job-id\n",
742 argv[i]);
743 } else if (stat(argv[i], &buf)) {
744 fprintf(stderr, "at: %s: ", argv[i]);
745 perror("");
746 } else if ((user != buf.st_uid) &&
747 (!cron_admin(pw->pw_name))) {
748 fprintf(stderr, "at: you don't own %s\n",
749 argv[i]);
750 error = 1;
751 } else {
752 if (cron_admin(pw->pw_name)) {
753 login = getuser((uid_t)buf.st_uid);
754 if (login == NULL) {
755 if (per_errno == 2)
756 atabort(BADSHELL);
757 else
758 atabort(INVALIDUSER);
759 }
760 }
761 cron_sendmsg(DELETE, login, argv[i], AT);
762 r = unlink(argv[i]);
763 audit_at_delete(argv[i], ATDIR, r);
764 }
765 return (error);
766 }
767
768
769
770 static int
771 list_jobs(int argc, char **argv, int qflag, int queue)
772 {
773 DIR *dir;
774 int i;
775 int error = 0;
776 char *patdir, *atdir, *ptr;
777 char timebuf[80];
778 time_t t;
779 struct stat buf, st1, st2;
780 struct dirent *dentry;
781 struct passwd *pw;
782 unsigned int atdirlen;
783 int r;
784 struct passwd *pwd, pwds;
785 char buf_pwd[1024];
786 char job_file[PATH_MAX];
787
788 pwd = getpwuid_r(user, &pwds, buf_pwd, sizeof (buf_pwd));
789 if (pwd == NULL) {
790 atabort("Invalid user.\n");
791 }
792
793 /* list jobs for user */
794 if (chdir(ATDIR) == -1)
795 atabort(CANTCD);
796
797 atdirlen = strlen(ATDIR);
798 atdir = xmalloc(atdirlen + 1);
799 strcpy(atdir, ATDIR);
800 patdir = strrchr(atdir, '/');
801 *patdir = '\0';
802 if (argc == 0) {
803 /* list all jobs for a user */
804 if (stat(ATDIR, &st1) != 0 || stat(atdir, &st2) != 0)
805 atabort("Can not get status of spooling"
806 "directory for at");
807 if ((dir = opendir(ATDIR)) == NULL)
808 atabort(NOOPENDIR);
809 while (1) {
810 if ((dentry = readdir(dir)) == NULL)
811 break;
812 if ((dentry->d_ino == st1.st_ino) ||
813 (dentry->d_ino == st2.st_ino))
814 continue;
815 if ((r = audit_cron_is_anc_name(dentry->d_name)) == 1)
816 continue;
817 if (stat(dentry->d_name, &buf)) {
818 unlink(dentry->d_name);
819 audit_cron_delete_anc_file(dentry->d_name,
820 NULL);
821 continue;
822 }
823 if ((!cron_admin(pwd->pw_name)) &&
824 (buf.st_uid != user))
825 continue;
826 ptr = dentry->d_name;
827 if (((t = num(&ptr)) == 0) || (*ptr != '.'))
828 continue;
829 strcpy(job_file, patdir);
830 strcat(job_file, dentry->d_name);
831 if (pflag && not_this_project(job_file))
832 continue;
833 ascftime(timebuf, FORMAT, localtime(&t));
834 if ((cron_admin(pwd->pw_name)) &&
835 ((pw = getpwuid(buf.st_uid)) != NULL)) {
836 if (!qflag || (qflag &&
837 check_queue(ptr, queue)))
838 printf("user = %s\t%s\t%s\n",
839 pw->pw_name, dentry->d_name,
840 timebuf);
841 } else
842 if (!qflag || (qflag &&
843 check_queue(ptr, queue)))
844 printf("%s\t%s\n",
845 dentry->d_name, timebuf);
846 }
847 (void) closedir(dir);
848 } else /* list particular jobs for user */
849 for (i = 0; i < argc; i++) {
850 ptr = argv[i];
851 strlcpy(job_file, patdir, PATH_MAX);
852 strlcat(job_file, ptr, PATH_MAX);
853 if (((t = num(&ptr)) == 0) || (*ptr != '.')) {
854 fprintf(stderr, gettext(
855 "at: invalid job name %s\n"), argv[i]);
856 error = 1;
857 } else if (stat(argv[i], &buf)) {
858 fprintf(stderr, "at: %s: ", argv[i]);
859 perror("");
860 error = 1;
861 } else if ((user != buf.st_uid) &&
862 (!cron_admin(pwd->pw_name))) {
863 fprintf(stderr, gettext(
864 "at: you don't own %s\n"), argv[i]);
865 error = 1;
866 } else if (pflag && not_this_project(job_file)) {
867 continue;
868 } else {
869 if (!qflag || (qflag &&
870 check_queue(ptr, queue))) {
871 ascftime(timebuf, FORMAT,
872 localtime(&t));
873 printf("%s\t%s\n", argv[i], timebuf);
874 }
875 }
876 }
877 return (error);
878 }
879
880 /*
881 * open the command file and read the project id line
882 * compare to the project number provided via -p on the command line
883 * return 0 if they match, 1 if they don't match or an error occurs.
884 */
885 #define SKIPCOUNT 3 /* lines to skip to get to project line in file */
886
887 static int
888 not_this_project(char *filename)
889 {
890 FILE *fp;
891 projid_t sproj;
892 int i;
893
894 if ((fp = fopen(filename, "r")) == NULL)
895 return (1);
896
897 for (i = 0; i < SKIPCOUNT; i++)
898 fscanf(fp, "%*[^\n]\n");
899
900 fscanf(fp, ": project: %d\n", &sproj);
901 fclose(fp);
902
903 return (sproj == project ? 0 : 1);
904 }
905
906 static int
907 check_queue(char *name, int queue)
908 {
909 if ((name[strlen(name) - 1] - 'a') == queue)
910 return (1);
911 else
912 return (0);
913 }
914
915 static time_t
916 parse_time(char *t)
917 {
918 int century = 0;
919 int seconds = 0;
920 char *p;
921 time_t when = 0;
922 struct tm tm;
923
924 /*
925 * time in the following format (defined by the touch(1) spec):
926 * [[CC]YY]MMDDhhmm[.SS]
927 */
928 if ((p = strchr(t, '.')) != NULL) {
929 if (strchr(p+1, '.') != NULL)
930 atabort(BADTIME);
931 seconds = atoi_for2(p+1);
932 *p = '\0';
933 }
934
935 memset(&tm, 0, sizeof (struct tm));
936 when = time(0);
937 tm.tm_year = localtime(&when)->tm_year;
938
939 switch (strlen(t)) {
940 case 12: /* CCYYMMDDhhmm */
941 century = atoi_for2(t);
942 t += 2;
943 case 10: /* YYMMDDhhmm */
944 tm.tm_year = atoi_for2(t);
945 t += 2;
946 if (century == 0) {
947 if (tm.tm_year < 69)
948 tm.tm_year += 100;
949 } else
950 tm.tm_year += (century - 19) * 100;
951 case 8: /* MMDDhhmm */
952 tm.tm_mon = atoi_for2(t) - 1;
953 t += 2;
954 tm.tm_mday = atoi_for2(t);
955 t += 2;
956 tm.tm_hour = atoi_for2(t);
957 t += 2;
958 tm.tm_min = atoi_for2(t);
959 t += 2;
960 tm.tm_sec = seconds;
961 break;
962 default:
963 atabort(BADTIME);
964 }
965
966 if ((when = mktime(&tm)) == -1)
967 atabort(BADTIME);
968 if (tm.tm_isdst)
969 when -= (timezone-altzone);
970 return (when);
971 }
972
973 static int
974 atoi_for2(char *p) {
975 int value;
976
977 value = (*p - '0') * 10 + *(p+1) - '0';
978 if ((value < 0) || (value > 99))
979 atabort(BADTIME);
980 return (value);
981 }
982
983 static void
984 usage(void)
985 {
986 fprintf(stderr, USAGE);
987 exit(1);
988 }