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