Home | History | Annotate | Line # | Download | only in newsyslog
newsyslog.c revision 1.43
      1  1.43       wiz /*	$NetBSD: newsyslog.c,v 1.43 2002/02/11 10:57:58 wiz Exp $	*/
      2  1.22        ad 
      3  1.22        ad /*
      4  1.22        ad  * Copyright (c) 1999, 2000 Andrew Doran <ad (at) NetBSD.org>
      5  1.22        ad  * All rights reserved.
      6  1.22        ad  *
      7  1.22        ad  * Redistribution and use in source and binary forms, with or without
      8  1.22        ad  * modification, are permitted provided that the following conditions
      9  1.22        ad  * are met:
     10  1.22        ad  * 1. Redistributions of source code must retain the above copyright
     11  1.22        ad  *    notice, this list of conditions and the following disclaimer.
     12  1.22        ad  * 2. Redistributions in binary form must reproduce the above copyright
     13  1.22        ad  *    notice, this list of conditions and the following disclaimer in the
     14  1.22        ad  *    documentation and/or other materials provided with the distribution.
     15  1.22        ad  *
     16  1.22        ad  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
     17  1.22        ad  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     18  1.22        ad  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     19  1.22        ad  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
     20  1.22        ad  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     21  1.22        ad  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     22  1.22        ad  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     23  1.22        ad  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     24  1.22        ad  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     25  1.22        ad  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     26  1.22        ad  * SUCH DAMAGE.
     27  1.22        ad  *
     28  1.22        ad  */
     29  1.12   thorpej 
     30   1.1       cgd /*
     31   1.1       cgd  * This file contains changes from the Open Software Foundation.
     32   1.1       cgd  */
     33   1.1       cgd 
     34   1.1       cgd /*
     35  1.22        ad  * Copyright 1988, 1989 by the Massachusetts Institute of Technology
     36  1.22        ad  *
     37  1.22        ad  * Permission to use, copy, modify, and distribute this software
     38  1.22        ad  * and its documentation for any purpose and without fee is
     39  1.22        ad  * hereby granted, provided that the above copyright notice
     40  1.22        ad  * appear in all copies and that both that copyright notice and
     41  1.22        ad  * this permission notice appear in supporting documentation,
     42  1.22        ad  * and that the names of M.I.T. and the M.I.T. S.I.P.B. not be
     43  1.22        ad  * used in advertising or publicity pertaining to distribution
     44  1.22        ad  * of the software without specific, written prior permission.
     45  1.22        ad  * M.I.T. and the M.I.T. S.I.P.B. make no representations about
     46  1.22        ad  * the suitability of this software for any purpose.  It is
     47  1.22        ad  * provided "as is" without express or implied warranty.
     48  1.22        ad  *
     49  1.22        ad  */
     50   1.1       cgd 
     51   1.1       cgd /*
     52  1.32        ad  * newsyslog(8) - a program to roll over log files provided that specified
     53  1.22        ad  * critera are met, optionally preserving a number of historical log files.
     54   1.1       cgd  */
     55   1.1       cgd 
     56  1.13     lukem #include <sys/cdefs.h>
     57   1.5   mycroft #ifndef lint
     58  1.43       wiz __RCSID("$NetBSD: newsyslog.c,v 1.43 2002/02/11 10:57:58 wiz Exp $");
     59   1.5   mycroft #endif /* not lint */
     60   1.1       cgd 
     61   1.1       cgd #include <sys/types.h>
     62   1.1       cgd #include <sys/time.h>
     63   1.1       cgd #include <sys/stat.h>
     64   1.1       cgd #include <sys/param.h>
     65  1.36      tron #include <sys/wait.h>
     66   1.1       cgd 
     67  1.13     lukem #include <ctype.h>
     68  1.13     lukem #include <fcntl.h>
     69  1.13     lukem #include <grp.h>
     70  1.13     lukem #include <pwd.h>
     71  1.13     lukem #include <signal.h>
     72  1.13     lukem #include <stdio.h>
     73  1.13     lukem #include <stdlib.h>
     74  1.22        ad #include <stdarg.h>
     75  1.13     lukem #include <string.h>
     76  1.14    kleink #include <time.h>
     77  1.13     lukem #include <unistd.h>
     78  1.22        ad #include <errno.h>
     79  1.22        ad #include <err.h>
     80  1.22        ad #include <util.h>
     81  1.31        ad #include <paths.h>
     82  1.22        ad 
     83  1.22        ad #include "pathnames.h"
     84  1.22        ad 
     85  1.28        ad #define	PRHDRINFO(x)	((void)(verbose ? printf x : 0))
     86  1.28        ad #define	PRINFO(x)	((void)(verbose ? printf("  ") + printf x : 0))
     87  1.22        ad 
     88  1.43       wiz #define	CE_COMPRESS	0x01	/* Compress the archived log files */
     89  1.29        ad #define	CE_BINARY	0x02	/* Logfile is a binary file/non-syslog */
     90  1.29        ad #define	CE_NOSIGNAL	0x04	/* Don't send a signal when trimmed */
     91  1.32        ad #define	CE_CREATE	0x08	/* Create log file if none exists */
     92  1.32        ad #define	CE_PLAIN0	0x10	/* Do not compress zero'th history file */
     93  1.13     lukem 
     94   1.1       cgd struct conf_entry {
     95  1.22        ad 	uid_t	uid;			/* Owner of log */
     96  1.22        ad 	gid_t	gid;			/* Group of log */
     97  1.22        ad 	mode_t	mode;			/* File permissions */
     98  1.22        ad 	int	numhist;		/* Number of historical logs to keep */
     99  1.22        ad 	size_t	maxsize;		/* Maximum log size */
    100  1.22        ad 	int	maxage;			/* Hours between log trimming */
    101  1.32        ad 	time_t	trimat;			/* Specific trim time */
    102  1.22        ad 	int	flags;			/* Flags (CE_*) */
    103  1.22        ad 	int	signum;			/* Signal to send */
    104  1.22        ad 	char	pidfile[MAXPATHLEN];	/* File containing PID to signal */
    105  1.22        ad 	char	logfile[MAXPATHLEN];	/* Path to log file */
    106   1.1       cgd };
    107   1.1       cgd 
    108  1.38        ad int	verbose;			/* Be verbose */
    109  1.38        ad int	noaction;			/* Take no action */
    110  1.38        ad int	nosignal;			/* Do not send signals */
    111  1.25        ad char    hostname[MAXHOSTNAMELEN + 1];	/* Hostname, stripped of domain */
    112  1.32        ad uid_t	myeuid;				/* EUID we are running with */
    113   1.1       cgd 
    114  1.32        ad int	getsig(const char *);
    115  1.32        ad int	isnumber(const char *);
    116  1.22        ad int	main(int, char **);
    117  1.32        ad int	parse_cfgline(struct conf_entry *, FILE *, size_t *);
    118  1.32        ad time_t	parse_iso8601(char *);
    119  1.32        ad time_t	parse_dwm(char *);
    120  1.32        ad int	parse_userspec(const char *, struct passwd **, struct group **);
    121  1.32        ad pid_t	readpidfile(const char *);
    122  1.32        ad void	usage(void);
    123  1.22        ad 
    124  1.29        ad void	log_compress(struct conf_entry *, const char *);
    125  1.22        ad void	log_create(struct conf_entry *);
    126  1.22        ad void	log_examine(struct conf_entry *, int);
    127  1.22        ad void	log_trim(struct conf_entry *);
    128  1.22        ad void	log_trimmed(struct conf_entry *);
    129  1.22        ad 
    130  1.22        ad /*
    131  1.22        ad  * Program entry point.
    132  1.22        ad  */
    133  1.13     lukem int
    134  1.22        ad main(int argc, char **argv)
    135   1.1       cgd {
    136  1.29        ad 	struct conf_entry log;
    137  1.22        ad 	FILE *fd;
    138  1.22        ad 	char *p, *cfile;
    139  1.32        ad 	int c, needroot, i, force;
    140  1.22        ad 	size_t lineno;
    141  1.39        ad 
    142  1.22        ad 	force = 0;
    143  1.22        ad 	needroot = 1;
    144  1.22        ad 	cfile = _PATH_NEWSYSLOGCONF;
    145   1.1       cgd 
    146  1.32        ad 	gethostname(hostname, sizeof (hostname));
    147  1.32        ad 	hostname[sizeof (hostname) - 1] = '\0';
    148   1.8       jtc 
    149  1.32        ad 	/* Truncate domain. */
    150  1.22        ad 	if ((p = strchr(hostname, '.')) != NULL)
    151   1.8       jtc 		*p = '\0';
    152  1.22        ad 
    153  1.32        ad 	/* Parse command line options. */
    154  1.38        ad 	while ((c = getopt(argc, argv, "f:nrsvF")) != -1) {
    155  1.22        ad 		switch (c) {
    156  1.28        ad 		case 'f':
    157  1.28        ad 			cfile = optarg;
    158  1.28        ad 			break;
    159  1.28        ad 		case 'n':
    160  1.28        ad 			noaction = 1;
    161  1.29        ad 			verbose = 1;
    162  1.28        ad 			break;
    163  1.22        ad 		case 'r':
    164  1.22        ad 			needroot = 0;
    165  1.22        ad 			break;
    166  1.38        ad 		case 's':
    167  1.38        ad 			nosignal = 1;
    168  1.38        ad 			break;
    169  1.22        ad 		case 'v':
    170  1.22        ad 			verbose = 1;
    171  1.22        ad 			break;
    172  1.22        ad 		case 'F':
    173  1.22        ad 			force = 1;
    174  1.22        ad 			break;
    175  1.22        ad 		default:
    176  1.22        ad 			usage();
    177  1.28        ad 			/* NOTREACHED */
    178  1.22        ad 		}
    179   1.8       jtc 	}
    180   1.1       cgd 
    181  1.32        ad 	myeuid = geteuid();
    182  1.32        ad 	if (needroot && myeuid != 0)
    183  1.22        ad 		errx(EXIT_FAILURE, "must be run as root");
    184  1.22        ad 
    185  1.32        ad 	argc -= optind;
    186  1.32        ad 	argv += optind;
    187  1.32        ad 
    188  1.22        ad 	if (strcmp(cfile, "-") == 0)
    189  1.22        ad 		fd = stdin;
    190  1.22        ad 	else if ((fd = fopen(cfile, "rt")) == NULL)
    191  1.22        ad 		err(EXIT_FAILURE, "%s", cfile);
    192  1.32        ad 
    193  1.32        ad 	for (lineno = 0; !parse_cfgline(&log, fd, &lineno);) {
    194  1.32        ad 		/*
    195  1.32        ad 		 * If specific log files were specified, touch only
    196  1.32        ad 		 * those.
    197  1.32        ad 		 */
    198  1.32        ad 		if (argc != 0) {
    199  1.32        ad 			for (i = 0; i < argc; i++)
    200  1.32        ad 				if (strcmp(log.logfile, argv[i]) == 0)
    201  1.32        ad 					break;
    202  1.32        ad 			if (i == argc)
    203  1.32        ad 				continue;
    204  1.32        ad 		}
    205  1.29        ad 		log_examine(&log, force);
    206  1.32        ad 	}
    207  1.22        ad 
    208  1.22        ad 	if (fd != stdin)
    209  1.22        ad 		fclose(fd);
    210   1.1       cgd 
    211  1.22        ad 	exit(EXIT_SUCCESS);
    212  1.22        ad 	/* NOTREACHED */
    213   1.1       cgd }
    214   1.1       cgd 
    215  1.22        ad /*
    216  1.22        ad  * Parse a single line from the configuration file.
    217   1.1       cgd  */
    218  1.22        ad int
    219  1.32        ad parse_cfgline(struct conf_entry *log, FILE *fd, size_t *_lineno)
    220   1.1       cgd {
    221  1.22        ad 	char *line, *q, **ap, *argv[10];
    222  1.22        ad 	struct passwd *pw;
    223  1.22        ad 	struct group *gr;
    224  1.33     enami 	int nf, lineno, i, rv;
    225  1.33     enami 
    226  1.33     enami 	rv = -1;
    227  1.33     enami 	line = NULL;
    228  1.30        ad 
    229  1.32        ad 	/* Place the white-space separated fields into an array. */
    230  1.33     enami 	do {
    231  1.33     enami 		if (line != NULL)
    232  1.33     enami 			free(line);
    233  1.33     enami 		if ((line = fparseln(fd, NULL, _lineno, NULL, 0)) == NULL)
    234  1.33     enami 			return (rv);
    235  1.33     enami 		lineno = (int)*_lineno;
    236  1.33     enami 
    237  1.33     enami 		for (ap = argv, nf = 0; (*ap = strsep(&line, " \t")) != NULL;)
    238  1.33     enami 			if (**ap != '\0') {
    239  1.33     enami 				if (++nf == sizeof (argv) / sizeof (argv[0])) {
    240  1.33     enami 					warnx("config line %d: "
    241  1.33     enami 					    "too many fields", lineno);
    242  1.33     enami 					goto bad;
    243  1.33     enami 				}
    244  1.33     enami 				ap++;
    245  1.22        ad 			}
    246  1.33     enami 	} while (nf == 0);
    247  1.22        ad 
    248  1.22        ad 	if (nf < 6)
    249  1.22        ad 		errx(EXIT_FAILURE, "config line %d: too few fields", lineno);
    250  1.22        ad 
    251  1.33     enami 	memset(log, 0, sizeof (*log));
    252  1.33     enami 
    253  1.32        ad 	/* logfile_name */
    254  1.22        ad 	ap = argv;
    255  1.32        ad 	strlcpy(log->logfile, *ap++, sizeof (log->logfile));
    256  1.32        ad 	if (log->logfile[0] != '/')
    257  1.32        ad 		errx(EXIT_FAILURE,
    258  1.32        ad 		    "config line %d: logfile must have a full path", lineno);
    259  1.21        ad 
    260  1.32        ad 	/* owner:group */
    261  1.31        ad 	if (strchr(*ap, ':') != NULL || strchr(*ap, '.') != NULL) {
    262  1.32        ad 		if (parse_userspec(*ap++, &pw, &gr)) {
    263  1.22        ad 			warnx("config line %d: unknown user/group", lineno);
    264  1.33     enami 			goto bad;
    265  1.22        ad 		}
    266  1.32        ad 
    267  1.32        ad 		/*
    268  1.35        ad 		 * We may only change the file's owner as non-root.
    269  1.32        ad 		 */
    270  1.32        ad 		if (myeuid != 0) {
    271  1.32        ad 			if (pw->pw_uid != myeuid)
    272  1.32        ad 				errx(EXIT_FAILURE, "config line %d: user:group "
    273  1.32        ad 				    "as non-root must match current user",
    274  1.32        ad 				    lineno);
    275  1.32        ad 			log->uid = (uid_t)-1;
    276  1.32        ad 		} else
    277  1.32        ad 			log->uid = pw->pw_uid;
    278  1.22        ad 		log->gid = gr->gr_gid;
    279  1.22        ad 		if (nf < 7)
    280  1.22        ad 			errx(EXIT_FAILURE, "config line %d: too few fields",
    281  1.22        ad 			    lineno);
    282  1.32        ad 	} else if (myeuid != 0) {
    283  1.32        ad 		log->uid = (uid_t)-1;
    284  1.32        ad 		log->gid = getegid();
    285  1.22        ad 	}
    286  1.22        ad 
    287  1.32        ad 	/* mode */
    288  1.22        ad 	if (sscanf(*ap++, "%o", &i) != 1) {
    289  1.22        ad 		warnx("config line %d: bad permissions", lineno);
    290  1.33     enami 		goto bad;
    291  1.22        ad 	}
    292  1.22        ad 	log->mode = (mode_t)i;
    293  1.22        ad 
    294  1.32        ad 	/* count */
    295  1.26   aymeric 	if (sscanf(*ap++, "%d", &log->numhist) != 1) {
    296  1.22        ad 		warnx("config line %d: bad log count", lineno);
    297  1.33     enami 		goto bad;
    298  1.22        ad 	}
    299  1.22        ad 
    300  1.32        ad 	/* size */
    301  1.32        ad 	if (isdigit(**ap)) {
    302  1.32        ad 		log->maxsize = (int)strtol(*ap, &q, 0);
    303  1.32        ad 		if (*q != '\0') {
    304  1.32        ad 			warnx("config line %d: bad log size", lineno);
    305  1.33     enami 			goto bad;
    306  1.32        ad 		}
    307  1.32        ad 	} else if (**ap == '*')
    308  1.22        ad 		log->maxsize = (size_t)-1;
    309  1.22        ad 	else {
    310  1.22        ad 		warnx("config line %d: bad log size", lineno);
    311  1.33     enami 		goto bad;
    312  1.22        ad 	}
    313  1.22        ad 	ap++;
    314  1.32        ad 
    315  1.32        ad 	/* when */
    316  1.32        ad 	log->maxage = -1;
    317  1.32        ad 	log->trimat = (time_t)-1;
    318  1.32        ad 	q = *ap++;
    319  1.32        ad 
    320  1.32        ad 	if (strcmp(q, "*") != 0) {
    321  1.32        ad 		if (isdigit(*q))
    322  1.32        ad 			log->maxage = (int)strtol(q, &q, 10);
    323  1.32        ad 
    324  1.32        ad 		/*
    325  1.32        ad 		 * One class of periodic interval specification can follow a
    326  1.32        ad 		 * maximum age specification.  Handle it.
    327  1.32        ad 		 */
    328  1.32        ad 		if (*q == '@') {
    329  1.32        ad 			log->trimat = parse_iso8601(q + 1);
    330  1.32        ad 			if (log->trimat == (time_t)-1) {
    331  1.32        ad 				warnx("config line %d: bad trim time", lineno);
    332  1.33     enami 				goto bad;
    333  1.32        ad 			}
    334  1.32        ad 		} else if (*q == '$') {
    335  1.32        ad 			if ((log->trimat = parse_dwm(q + 1)) == (time_t)-1) {
    336  1.32        ad 				warnx("config line %d: bad trim time", lineno);
    337  1.33     enami 				goto bad;
    338  1.32        ad 			}
    339  1.32        ad 		} else if (log->maxage == -1) {
    340  1.32        ad 			warnx("config line %d: bad log age", lineno);
    341  1.33     enami 			goto bad;
    342  1.32        ad 		}
    343  1.22        ad 	}
    344  1.32        ad 
    345  1.32        ad 	/* flags */
    346  1.42        ad 	log->flags = (nosignal ? CE_NOSIGNAL : 0);
    347  1.42        ad 
    348  1.28        ad 	for (q = *ap++; q != NULL && *q != '\0'; q++) {
    349  1.22        ad 		switch (tolower(*q)) {
    350  1.22        ad 		case 'b':
    351  1.22        ad 			log->flags |= CE_BINARY;
    352  1.22        ad 			break;
    353  1.22        ad 		case 'c':
    354  1.22        ad 			log->flags |= CE_CREATE;
    355  1.22        ad 			break;
    356  1.22        ad 		case 'n':
    357  1.22        ad 			log->flags |= CE_NOSIGNAL;
    358  1.22        ad 			break;
    359  1.29        ad 		case 'p':
    360  1.29        ad 			log->flags |= CE_PLAIN0;
    361  1.29        ad 			break;
    362  1.22        ad 		case 'z':
    363  1.29        ad 			log->flags |= CE_COMPRESS;
    364  1.22        ad 			break;
    365  1.22        ad 		case '-':
    366  1.22        ad 			break;
    367  1.22        ad 		default:
    368  1.22        ad 			warnx("config line %d: bad flags", lineno);
    369  1.33     enami 			goto bad;
    370  1.22        ad 		}
    371  1.22        ad 	}
    372   1.1       cgd 
    373  1.32        ad 	/* path_to_pidfile */
    374  1.22        ad 	if (*ap != NULL && **ap == '/')
    375  1.32        ad 		strlcpy(log->pidfile, *ap++, sizeof (log->pidfile));
    376  1.22        ad 	else
    377  1.22        ad 		log->pidfile[0] = '\0';
    378  1.22        ad 
    379  1.32        ad 	/* sigtype */
    380  1.40        ad 	if (*ap != NULL) {
    381  1.40        ad 		if ((log->signum = getsig(*ap++)) < 0) {
    382  1.40        ad 			warnx("config line %d: bad signal type", lineno);
    383  1.40        ad 			goto bad;
    384  1.40        ad 		}
    385  1.22        ad 	} else
    386  1.22        ad 		log->signum = SIGHUP;
    387  1.33     enami 
    388  1.33     enami 	rv = 0;
    389  1.33     enami 
    390  1.33     enami bad:
    391  1.33     enami 	free(line);
    392  1.33     enami 	return (rv);
    393   1.1       cgd }
    394   1.1       cgd 
    395  1.22        ad /*
    396  1.22        ad  * Examine a log file.  If the trim conditions are met, call log_trim() to
    397  1.22        ad  * trim the log file.
    398  1.22        ad  */
    399  1.13     lukem void
    400  1.29        ad log_examine(struct conf_entry *log, int force)
    401  1.22        ad {
    402  1.22        ad 	struct stat sb;
    403  1.22        ad 	size_t size;
    404  1.32        ad 	int age, trim;
    405  1.34        ad 	char tmp[MAXPATHLEN];
    406  1.34        ad 	const char *reason;
    407  1.22        ad 	time_t now;
    408  1.28        ad 
    409  1.32        ad 	now = time(NULL);
    410  1.32        ad 
    411  1.29        ad 	PRHDRINFO(("\n%s <%d%s>: ", log->logfile, log->numhist,
    412  1.29        ad 	    (log->flags & CE_COMPRESS) != 0 ? "Z" : ""));
    413  1.28        ad 
    414  1.32        ad 	/*
    415  1.32        ad 	 * stat() the logfile.  If it doesn't exist and the `c' flag has
    416  1.32        ad 	 * been specified, create it.  If it doesn't exist and the `c' flag
    417  1.32        ad 	 * hasn't been specified, give up.
    418  1.32        ad 	 */
    419  1.29        ad 	if (stat(log->logfile, &sb) < 0) {
    420  1.29        ad 		if (errno == ENOENT && (log->flags & CE_CREATE) != 0) {
    421  1.28        ad 			PRHDRINFO(("creating; "));
    422  1.28        ad 			if (!noaction)
    423  1.29        ad 				log_create(log);
    424  1.28        ad 			else {
    425  1.28        ad 				PRHDRINFO(("can't proceed with `-n'\n"));
    426  1.28        ad 				return;
    427  1.28        ad 			}
    428  1.29        ad 			if (stat(log->logfile, &sb))
    429  1.29        ad 				err(EXIT_FAILURE, "%s", log->logfile);
    430  1.28        ad 		} else if (errno == ENOENT) {
    431  1.28        ad 			PRHDRINFO(("does not exist --> skip log\n"));
    432  1.22        ad 			return;
    433  1.28        ad 		} else if (errno != 0)
    434  1.29        ad 			err(EXIT_FAILURE, "%s", log->logfile);
    435  1.22        ad 	}
    436  1.22        ad 
    437  1.32        ad 	/* Size of the log file in kB. */
    438  1.22        ad 	size = ((size_t)sb.st_blocks * S_BLKSIZE) >> 10;
    439  1.20        ad 
    440  1.32        ad 	/*
    441  1.32        ad 	 * Get the age (expressed in hours) of the current log file with
    442  1.32        ad 	 * respect to the newest historical log file.
    443  1.32        ad 	 */
    444  1.32        ad 	strlcpy(tmp, log->logfile, sizeof (tmp));
    445  1.32        ad 	strlcat(tmp, ".0", sizeof (tmp));
    446  1.22        ad 	if (stat(tmp, &sb) < 0) {
    447  1.32        ad 		strlcat(tmp, ".gz", sizeof (tmp));
    448  1.22        ad 		if (stat(tmp, &sb) < 0)
    449  1.28        ad 			age = -1;
    450  1.11   thorpej 		else
    451  1.28        ad 			age = (int)(now - sb.st_mtime + 1800) / 3600;
    452  1.17  christos 	} else
    453  1.28        ad 		age = (int)(now - sb.st_mtime + 1800) / 3600;
    454  1.11   thorpej 
    455  1.22        ad 	/*
    456  1.32        ad 	 * Examine the set of given trim conditions and if any one is met,
    457  1.32        ad 	 * trim the log.
    458  1.32        ad 	 *
    459  1.32        ad 	 * Note: if `maxage' or `trimat' is used as a trim condition, we
    460  1.32        ad 	 * need at least one historical log file to determine the `age' of
    461  1.32        ad 	 * the active log file.  WRT `trimat', we will trim up to one hour
    462  1.32        ad 	 * after the specific trim time has passed - we need to know if
    463  1.32        ad 	 * we've trimmed to meet that condition with a previous invocation
    464  1.32        ad 	 * of newsyslog(8).
    465  1.22        ad 	 */
    466  1.32        ad 	if (log->maxage >= 0 && (age >= log->maxage || age < 0)) {
    467  1.32        ad 		trim = 1;
    468  1.32        ad 		reason = "log age > interval";
    469  1.32        ad 	} else if (size >= log->maxsize) {
    470  1.32        ad 		trim = 1;
    471  1.32        ad 		reason = "log size > size";
    472  1.32        ad 	} else if (log->trimat != (time_t)-1 && now >= log->trimat &&
    473  1.39        ad 		   (age == -1 || age > 1) &&
    474  1.39        ad 		   difftime(now, log->trimat) < 60 * 60) {
    475  1.32        ad 		trim = 1;
    476  1.32        ad 		reason = "specific trim time";
    477  1.32        ad 	} else {
    478  1.32        ad 		trim = force;
    479  1.32        ad 		reason = "trim forced";
    480  1.32        ad 	}
    481  1.32        ad 
    482  1.32        ad 	if (trim) {
    483  1.32        ad 		PRHDRINFO(("--> trim log (%s)\n", reason));
    484  1.29        ad 		log_trim(log);
    485  1.22        ad 	} else
    486  1.32        ad 		PRHDRINFO(("--> skip log (trim conditions not met)\n"));
    487   1.1       cgd }
    488   1.1       cgd 
    489  1.22        ad /*
    490  1.22        ad  * Trim the specified log file.
    491  1.22        ad  */
    492  1.22        ad void
    493  1.22        ad log_trim(struct conf_entry *log)
    494   1.1       cgd {
    495  1.22        ad 	char file1[MAXPATHLEN], file2[MAXPATHLEN];
    496  1.22        ad 	int i;
    497  1.22        ad 	struct stat st;
    498  1.22        ad 	pid_t pid;
    499  1.22        ad 
    500  1.32        ad 	/* Remove oldest historical log. */
    501  1.35        ad 	snprintf(file1, sizeof (file1), "%s.%d", log->logfile,
    502  1.35        ad 	    log->numhist - 1);
    503  1.22        ad 
    504  1.22        ad 	PRINFO(("rm -f %s\n", file1));
    505  1.28        ad 	if (!noaction)
    506  1.28        ad 		unlink(file1);
    507  1.32        ad 	strlcat(file1, ".gz", sizeof (file1));
    508  1.29        ad 	PRINFO(("rm -f %s\n", file1));
    509  1.28        ad 	if (!noaction)
    510  1.29        ad 		unlink(file1);
    511  1.22        ad 
    512  1.32        ad 	/* Move down log files. */
    513  1.22        ad 	for (i = log->numhist - 1; i != 0; i--) {
    514  1.32        ad 		snprintf(file1, sizeof (file1), "%s.%d", log->logfile, i - 1);
    515  1.32        ad 		snprintf(file2, sizeof (file2), "%s.%d", log->logfile, i);
    516  1.22        ad 
    517  1.22        ad 		if (lstat(file1, &st) != 0) {
    518  1.32        ad 			strlcat(file1, ".gz", sizeof (file1));
    519  1.32        ad 			strlcat(file2, ".gz", sizeof (file2));
    520  1.29        ad 			if (lstat(file1, &st) != 0)
    521  1.22        ad 				continue;
    522  1.22        ad 		}
    523  1.22        ad 
    524  1.29        ad 		PRINFO(("mv %s %s\n", file1, file2));
    525  1.28        ad 		if (!noaction)
    526  1.29        ad 			if (rename(file1, file2))
    527  1.29        ad 				err(EXIT_FAILURE, "%s", file1);
    528  1.29        ad 		PRINFO(("chmod %o %s\n", log->mode, file2));
    529  1.28        ad 		if (!noaction)
    530  1.29        ad 			if (chmod(file2, log->mode))
    531  1.29        ad 				err(EXIT_FAILURE, "%s", file2);
    532  1.32        ad 		PRINFO(("chown %d:%d %s\n", log->uid, log->gid,
    533  1.32        ad 		    file2));
    534  1.28        ad 		if (!noaction)
    535  1.29        ad 			if (chown(file2, log->uid, log->gid))
    536  1.32        ad 				err(EXIT_FAILURE, "%s", file2);
    537  1.29        ad 	}
    538  1.29        ad 
    539  1.29        ad 	/*
    540  1.29        ad 	 * If a historical log file isn't compressed, and 'z' has been
    541  1.29        ad 	 * specified, compress it.  (This is convenient, but is also needed
    542  1.29        ad 	 * if 'p' has been specified.)  It should be noted that gzip(1)
    543  1.29        ad 	 * preserves file ownership and file mode.
    544  1.29        ad 	 */
    545  1.29        ad 	for (i = (log->flags & CE_PLAIN0) != 0; i < log->numhist; i++) {
    546  1.32        ad 		snprintf(file1, sizeof (file1), "%s.%d", log->logfile, i);
    547  1.29        ad 		if (lstat(file1, &st) != 0)
    548  1.29        ad 			continue;
    549  1.32        ad 		snprintf(file2, sizeof (file2), "%s.gz", file1);
    550  1.29        ad 		if (lstat(file2, &st) == 0)
    551  1.29        ad 			continue;
    552  1.29        ad 		log_compress(log, file1);
    553  1.22        ad 	}
    554  1.22        ad 
    555  1.28        ad 	log_trimmed(log);
    556  1.22        ad 
    557  1.32        ad 	/* Create the historical log file if we're maintaining history. */
    558  1.22        ad 	if (log->numhist == 0) {
    559  1.28        ad 		PRINFO(("rm -f %s\n", log->logfile));
    560  1.28        ad 		if (!noaction)
    561  1.28        ad 			if (unlink(log->logfile))
    562  1.28        ad 				err(EXIT_FAILURE, "%s", log->logfile);
    563  1.22        ad 	} else {
    564  1.32        ad 		snprintf(file1, sizeof (file1), "%s.0", log->logfile);
    565  1.28        ad 		PRINFO(("mv %s %s\n", log->logfile, file1));
    566  1.28        ad 		if (!noaction)
    567  1.28        ad 			if (rename(log->logfile, file1))
    568  1.28        ad 				err(EXIT_FAILURE, "%s", log->logfile);
    569  1.22        ad 	}
    570  1.22        ad 
    571  1.29        ad 	PRINFO(("(create new log)\n"));
    572  1.22        ad 	log_create(log);
    573  1.28        ad 	log_trimmed(log);
    574  1.22        ad 
    575  1.32        ad 	/* Set the correct permissions on the log. */
    576  1.22        ad 	PRINFO(("chmod %o %s\n", log->mode, log->logfile));
    577  1.28        ad 	if (!noaction)
    578  1.28        ad 		if (chmod(log->logfile, log->mode))
    579  1.28        ad 			err(EXIT_FAILURE, "%s", log->logfile);
    580  1.22        ad 
    581  1.32        ad 	/* Do we need to signal a daemon? */
    582  1.42        ad 	if ((log->flags & CE_NOSIGNAL) == 0) {
    583  1.22        ad 		if (log->pidfile[0] != '\0')
    584  1.22        ad 			pid = readpidfile(log->pidfile);
    585  1.22        ad 		else
    586  1.22        ad 			pid = readpidfile(_PATH_SYSLOGDPID);
    587  1.22        ad 
    588  1.22        ad 		if (pid != (pid_t)-1) {
    589  1.32        ad 			PRINFO(("kill -%s %lu\n",
    590  1.32        ad 			    sys_signame[log->signum], (u_long)pid));
    591  1.28        ad 			if (!noaction)
    592  1.28        ad 				if (kill(pid, log->signum))
    593  1.28        ad 					warn("kill");
    594  1.22        ad 		}
    595  1.22        ad 	}
    596  1.29        ad 
    597  1.32        ad 	/* If the newest historical log is to be compressed, do it here. */
    598  1.29        ad 	if ((log->flags & (CE_PLAIN0 | CE_COMPRESS)) == CE_COMPRESS) {
    599  1.32        ad 		snprintf(file1, sizeof (file1), "%s.0", log->logfile);
    600  1.42        ad 		if ((log->flags & CE_NOSIGNAL) == 0) {
    601  1.42        ad 			PRINFO(("sleep for 10 seconds before compressing...\n"));
    602  1.42        ad 			sleep(10);
    603  1.42        ad 		}
    604  1.29        ad 		log_compress(log, file1);
    605  1.22        ad 	}
    606   1.1       cgd }
    607   1.1       cgd 
    608  1.22        ad /*
    609  1.22        ad  * Write an entry to the log file recording the fact that it was trimmed.
    610  1.22        ad  */
    611  1.13     lukem void
    612  1.22        ad log_trimmed(struct conf_entry *log)
    613   1.1       cgd {
    614  1.22        ad 	FILE *fd;
    615  1.22        ad 	time_t now;
    616  1.22        ad 	char *daytime;
    617  1.22        ad 
    618  1.28        ad 	if ((log->flags & CE_BINARY) != 0)
    619  1.28        ad 		return;
    620  1.28        ad 	PRINFO(("(append rotation notice to %s)\n", log->logfile));
    621  1.28        ad 	if (noaction)
    622  1.28        ad 		return;
    623  1.28        ad 
    624  1.22        ad 	if ((fd = fopen(log->logfile, "at")) == NULL)
    625  1.22        ad 		err(EXIT_FAILURE, "%s", log->logfile);
    626  1.22        ad 
    627  1.22        ad 	now = time(NULL);
    628  1.22        ad 	daytime = ctime(&now) + 4;
    629  1.22        ad 	daytime[15] = '\0';
    630  1.22        ad 
    631  1.29        ad 	fprintf(fd, "%s %s newsyslog[%lu]: log file turned over\n", daytime,
    632  1.29        ad 	    hostname, (u_long)getpid());
    633  1.22        ad 	fclose(fd);
    634   1.1       cgd }
    635   1.1       cgd 
    636  1.22        ad /*
    637  1.29        ad  * Create a new log file.
    638  1.22        ad  */
    639  1.22        ad void
    640  1.29        ad log_create(struct conf_entry *log)
    641   1.1       cgd {
    642  1.22        ad 	int fd;
    643   1.1       cgd 
    644  1.28        ad 	if (noaction)
    645  1.28        ad 		return;
    646  1.28        ad 
    647  1.29        ad 	if ((fd = creat(log->logfile, log->mode)) < 0)
    648  1.29        ad 		err(EXIT_FAILURE, "%s", log->logfile);
    649  1.29        ad 	if (fchown(fd, log->uid, log->gid) < 0)
    650  1.29        ad 		err(EXIT_FAILURE, "%s", log->logfile);
    651  1.28        ad 	close(fd);
    652   1.1       cgd }
    653   1.1       cgd 
    654  1.22        ad /*
    655  1.32        ad  * Fork off gzip(1) to compress a log file.  This routine takes an
    656  1.32        ad  * additional string argument (the name of the file to compress): it is also
    657  1.32        ad  * used to compress historical log files other than the newest.
    658  1.29        ad  */
    659  1.29        ad void
    660  1.29        ad log_compress(struct conf_entry *log, const char *fn)
    661  1.29        ad {
    662  1.32        ad 	char tmp[MAXPATHLEN];
    663  1.29        ad 
    664  1.29        ad 	PRINFO(("gzip %s\n", fn));
    665  1.29        ad 	if (!noaction) {
    666  1.36      tron 		pid_t pid;
    667  1.36      tron 		int status;
    668  1.36      tron 
    669  1.36      tron 		if ((pid = vfork()) < 0)
    670  1.36      tron 			err(EXIT_FAILURE, "vfork");
    671  1.29        ad 		else if (pid == 0) {
    672  1.29        ad 			execl(_PATH_GZIP, "gzip", "-f", fn, NULL);
    673  1.36      tron 			_exit(EXIT_FAILURE);
    674  1.29        ad 		}
    675  1.36      tron 		while (waitpid(pid, &status, 0) != pid);
    676  1.36      tron 
    677  1.36      tron 		if (!WIFEXITED(status) || (WEXITSTATUS(status) != 0))
    678  1.36      tron 			errx(EXIT_FAILURE, "gzip failed");
    679  1.29        ad 	}
    680  1.32        ad 
    681  1.32        ad 	snprintf(tmp, sizeof (tmp), "%s.gz", fn);
    682  1.32        ad 	PRINFO(("chown %d:%d %s\n", log->uid, log->gid, tmp));
    683  1.32        ad 	if (!noaction)
    684  1.37      tron 		if (chown(tmp, log->uid, log->gid))
    685  1.32        ad 			err(EXIT_FAILURE, "%s", tmp);
    686  1.29        ad }
    687  1.29        ad 
    688  1.29        ad /*
    689  1.22        ad  * Display program usage information.
    690  1.22        ad  */
    691  1.22        ad void
    692  1.22        ad usage(void)
    693   1.1       cgd {
    694   1.1       cgd 
    695  1.32        ad 	fprintf(stderr,
    696  1.38        ad 	    "usage: newsyslog [-nrsvF] [-f config-file] [file ...]\n");
    697  1.22        ad 	exit(EXIT_FAILURE);
    698   1.1       cgd }
    699   1.1       cgd 
    700  1.22        ad /*
    701  1.22        ad  * Return non-zero if a string represents a decimal value.
    702  1.22        ad  */
    703  1.22        ad int
    704  1.22        ad isnumber(const char *string)
    705  1.22        ad {
    706   1.1       cgd 
    707  1.22        ad 	while (isdigit(*string))
    708  1.22        ad 		string++;
    709   1.1       cgd 
    710  1.22        ad 	return (*string == '\0');
    711  1.21        ad }
    712  1.21        ad 
    713  1.22        ad /*
    714  1.22        ad  * Given a signal name, attempt to find the corresponding signal number.
    715  1.22        ad  */
    716  1.21        ad int
    717  1.22        ad getsig(const char *sig)
    718  1.21        ad {
    719  1.22        ad 	char *p;
    720  1.21        ad 	int n;
    721  1.21        ad 
    722  1.21        ad 	if (isnumber(sig)) {
    723  1.22        ad 		n = (int)strtol(sig, &p, 0);
    724  1.28        ad 		if (p != '\0' || n < 0 || n >= NSIG)
    725  1.21        ad 			return (-1);
    726  1.21        ad 		return (n);
    727  1.21        ad 	}
    728  1.21        ad 
    729  1.28        ad 	if (strncasecmp(sig, "SIG", 3) == 0)
    730  1.21        ad 		sig += 3;
    731  1.22        ad 	for (n = 1; n < NSIG; n++)
    732  1.22        ad 		if (strcasecmp(sys_signame[n], sig) == 0)
    733  1.21        ad 			return (n);
    734  1.22        ad 	return (-1);
    735  1.22        ad }
    736  1.22        ad 
    737  1.22        ad /*
    738  1.22        ad  * Given a path to a PID file, return the PID contained within.
    739  1.22        ad  */
    740  1.22        ad pid_t
    741  1.22        ad readpidfile(const char *file)
    742  1.22        ad {
    743  1.22        ad 	FILE *fd;
    744  1.22        ad 	char line[BUFSIZ];
    745  1.22        ad 	pid_t pid;
    746  1.22        ad 
    747  1.28        ad #ifdef notyet
    748  1.28        ad 	if (file[0] != '/')
    749  1.32        ad 		snprintf(tmp, sizeof (tmp), "%s%s", _PATH_VARRUN, file);
    750  1.28        ad 	else
    751  1.32        ad 		strlcpy(tmp, file, sizeof (tmp));
    752  1.28        ad #endif
    753  1.28        ad 
    754  1.25        ad 	if ((fd = fopen(file, "rt")) == NULL) {
    755  1.25        ad 		warn("%s", file);
    756  1.22        ad 		return (-1);
    757  1.21        ad 	}
    758  1.25        ad 
    759  1.32        ad 	if (fgets(line, sizeof (line) - 1, fd) != NULL) {
    760  1.32        ad 		line[sizeof (line) - 1] = '\0';
    761  1.22        ad 		pid = (pid_t)strtol(line, NULL, 0);
    762  1.29        ad 	} else {
    763  1.29        ad 		warnx("unable to read %s", file);
    764  1.29        ad 		pid = (pid_t)-1;
    765  1.22        ad 	}
    766  1.29        ad 
    767  1.22        ad 	fclose(fd);
    768  1.22        ad 	return (pid);
    769  1.22        ad }
    770  1.22        ad 
    771  1.22        ad /*
    772  1.22        ad  * Parse a user:group specification.
    773  1.22        ad  *
    774  1.32        ad  * XXX This is over the top for newsyslog(8).  It should be moved to libutil.
    775  1.22        ad  */
    776  1.22        ad int
    777  1.32        ad parse_userspec(const char *name, struct passwd **pw, struct group **gr)
    778  1.22        ad {
    779  1.22        ad 	char buf[MAXLOGNAME * 2 + 2], *group;
    780  1.22        ad 
    781  1.32        ad 	strlcpy(buf, name, sizeof (buf));
    782  1.22        ad 	*gr = NULL;
    783  1.22        ad 
    784  1.22        ad 	/*
    785  1.22        ad 	 * Before attempting to use '.' as a separator, see if the whole
    786  1.28        ad 	 * string resolves as a user name.
    787  1.22        ad 	 */
    788  1.22        ad 	if ((*pw = getpwnam(buf)) != NULL) {
    789  1.22        ad 		*gr = getgrgid((*pw)->pw_gid);
    790  1.22        ad 		return (0);
    791  1.22        ad 	}
    792  1.22        ad 
    793  1.22        ad 	/* Split the user and group name. */
    794  1.22        ad 	if ((group = strchr(buf, ':')) != NULL ||
    795  1.22        ad 	    (group = strchr(buf, '.')) != NULL)
    796  1.22        ad 		*group++ = '\0';
    797  1.22        ad 
    798  1.22        ad 	if (isnumber(buf))
    799  1.22        ad 		*pw = getpwuid((uid_t)atoi(buf));
    800  1.22        ad 	else
    801  1.22        ad 		*pw = getpwnam(buf);
    802  1.22        ad 
    803  1.22        ad 	/*
    804  1.22        ad 	 * Find the group.  If a group wasn't specified, use the user's
    805  1.22        ad 	 * `natural' group.  We get to this point even if no user was found.
    806  1.22        ad 	 * This is to allow the caller to get a better idea of what went
    807  1.22        ad 	 * wrong, if anything.
    808  1.22        ad 	 */
    809  1.22        ad 	if (group == NULL || *group == '\0') {
    810  1.22        ad 		if (*pw == NULL)
    811  1.22        ad 			return (-1);
    812  1.22        ad 		*gr = getgrgid((*pw)->pw_gid);
    813  1.22        ad 	} else if (isnumber(group))
    814  1.22        ad 		*gr = getgrgid((gid_t)atoi(group));
    815  1.22        ad 	else
    816  1.22        ad 		*gr = getgrnam(group);
    817  1.22        ad 
    818  1.28        ad 	return (*pw != NULL && *gr != NULL ? 0 : -1);
    819  1.32        ad }
    820  1.32        ad 
    821  1.32        ad /*
    822  1.32        ad  * Parse a cyclic time specification, the format is as follows:
    823  1.32        ad  *
    824  1.32        ad  *	[Dhh] or [Wd[Dhh]] or [Mdd[Dhh]]
    825  1.32        ad  *
    826  1.32        ad  * to rotate a log file cyclic at
    827  1.32        ad  *
    828  1.32        ad  *	- every day (D) within a specific hour (hh)	(hh = 0...23)
    829  1.32        ad  *	- once a week (W) at a specific day (d)     OR	(d = 0..6, 0 = Sunday)
    830  1.32        ad  *	- once a month (M) at a specific day (d)	(d = 1..31,l|L)
    831  1.32        ad  *
    832  1.32        ad  * We don't accept a timezone specification; missing fields are defaulted to
    833  1.32        ad  * the current date but time zero.
    834  1.32        ad  */
    835  1.32        ad time_t
    836  1.32        ad parse_dwm(char *s)
    837  1.32        ad {
    838  1.32        ad 	char *t;
    839  1.32        ad 	struct tm tm, *tmp;
    840  1.32        ad 	u_long ul;
    841  1.32        ad 	time_t now;
    842  1.32        ad 	static int mtab[] = { 31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31 };
    843  1.32        ad 	int wmseen, dseen, nd, save;
    844  1.32        ad 
    845  1.32        ad 	wmseen = 0;
    846  1.32        ad 	dseen = 0;
    847  1.32        ad 
    848  1.32        ad 	now = time(NULL);
    849  1.32        ad 	tmp = localtime(&now);
    850  1.32        ad 	tm = *tmp;
    851  1.32        ad 
    852  1.32        ad 	/* Set no. of days per month */
    853  1.32        ad 	nd = mtab[tm.tm_mon];
    854  1.32        ad 
    855  1.32        ad 	if (tm.tm_mon == 1 &&
    856  1.32        ad 	    ((tm.tm_year + 1900) % 4 == 0) &&
    857  1.32        ad 	    ((tm.tm_year + 1900) % 100 != 0) &&
    858  1.32        ad 	    ((tm.tm_year + 1900) % 400 == 0))
    859  1.32        ad 		nd++;	/* leap year, 29 days in february */
    860  1.32        ad 	tm.tm_hour = tm.tm_min = tm.tm_sec = 0;
    861  1.32        ad 
    862  1.32        ad 	for (;;) {
    863  1.32        ad 		switch (*s) {
    864  1.32        ad 		case 'D':
    865  1.32        ad 			if (dseen)
    866  1.32        ad 				return ((time_t)-1);
    867  1.32        ad 			dseen++;
    868  1.32        ad 			s++;
    869  1.32        ad 			ul = strtoul(s, &t, 10);
    870  1.32        ad 			if (ul < 0 || ul > 23)
    871  1.32        ad 				return ((time_t)-1);
    872  1.32        ad 			tm.tm_hour = ul;
    873  1.32        ad 			break;
    874  1.32        ad 
    875  1.32        ad 		case 'W':
    876  1.32        ad 			if (wmseen)
    877  1.32        ad 				return (-1);
    878  1.32        ad 			wmseen++;
    879  1.32        ad 			s++;
    880  1.32        ad 			ul = strtoul(s, &t, 10);
    881  1.32        ad 			if (ul < 0 || ul > 6)
    882  1.32        ad 				return (-1);
    883  1.32        ad 			if (ul != tm.tm_wday) {
    884  1.32        ad 				if (ul < tm.tm_wday) {
    885  1.32        ad 					save = 6 - tm.tm_wday;
    886  1.32        ad 					save += (ul + 1);
    887  1.32        ad 				} else
    888  1.32        ad 					save = ul - tm.tm_wday;
    889  1.32        ad 				tm.tm_mday += save;
    890  1.32        ad 
    891  1.32        ad 				if (tm.tm_mday > nd) {
    892  1.32        ad 					tm.tm_mon++;
    893  1.32        ad 					tm.tm_mday = tm.tm_mday - nd;
    894  1.32        ad 				}
    895  1.32        ad 			}
    896  1.32        ad 			break;
    897  1.32        ad 
    898  1.32        ad 		case 'M':
    899  1.32        ad 			if (wmseen)
    900  1.32        ad 				return (-1);
    901  1.32        ad 			wmseen++;
    902  1.32        ad 			s++;
    903  1.32        ad 			if (tolower(*s) == 'l') {
    904  1.32        ad 				tm.tm_mday = nd;
    905  1.32        ad 				s++;
    906  1.32        ad 				t = s;
    907  1.32        ad 			} else {
    908  1.32        ad 				ul = strtoul(s, &t, 10);
    909  1.32        ad 				if (ul < 1 || ul > 31)
    910  1.32        ad 					return (-1);
    911  1.32        ad 
    912  1.32        ad 				if (ul > nd)
    913  1.32        ad 					return (-1);
    914  1.32        ad 				tm.tm_mday = ul;
    915  1.32        ad 			}
    916  1.32        ad 			break;
    917  1.32        ad 
    918  1.32        ad 		default:
    919  1.32        ad 			return (-1);
    920  1.32        ad 			break;
    921  1.32        ad 		}
    922  1.32        ad 
    923  1.32        ad 		if (*t == '\0' || isspace(*t))
    924  1.32        ad 			break;
    925  1.32        ad 		else
    926  1.32        ad 			s = t;
    927  1.32        ad 	}
    928  1.32        ad 
    929  1.32        ad 	return (mktime(&tm));
    930  1.32        ad }
    931  1.32        ad 
    932  1.32        ad /*
    933  1.32        ad  * Parse a limited subset of ISO 8601.  The specific format is as follows:
    934  1.32        ad  *
    935  1.32        ad  * [CC[YY[MM[DD]]]][THH[MM[SS]]]	(where `T' is the literal letter)
    936  1.32        ad  *
    937  1.32        ad  * We don't accept a timezone specification; missing fields (including
    938  1.32        ad  * timezone) are defaulted to the current date but time zero.
    939  1.32        ad  */
    940  1.32        ad time_t
    941  1.32        ad parse_iso8601(char *s)
    942  1.32        ad {
    943  1.32        ad 	char *t;
    944  1.32        ad 	struct tm tm, *tmp;
    945  1.32        ad 	u_long ul;
    946  1.32        ad 	time_t now;
    947  1.32        ad 
    948  1.32        ad 	now = time(NULL);
    949  1.32        ad 	tmp = localtime(&now);
    950  1.32        ad 	tm = *tmp;
    951  1.32        ad 
    952  1.32        ad 	tm.tm_hour = tm.tm_min = tm.tm_sec = 0;
    953  1.32        ad 
    954  1.32        ad 	ul = strtoul(s, &t, 10);
    955  1.32        ad 	if (*t != '\0' && *t != 'T')
    956  1.32        ad 		return ((time_t)-1);
    957  1.32        ad 
    958  1.32        ad 	/*
    959  1.32        ad 	 * Now t points either to the end of the string (if no time was
    960  1.32        ad 	 * provided) or to the letter `T' which separates date and time in
    961  1.32        ad 	 * ISO 8601.  The pointer arithmetic is the same for either case.
    962  1.32        ad 	 */
    963  1.32        ad 	switch (t - s) {
    964  1.32        ad 	case 8:
    965  1.32        ad 		tm.tm_year = ((ul / 1000000) - 19) * 100;
    966  1.32        ad 		ul = ul % 1000000;
    967  1.32        ad 		/* FALLTHROUGH */
    968  1.32        ad 	case 6:
    969  1.32        ad 		tm.tm_year = tm.tm_year - (tm.tm_year % 100);
    970  1.32        ad 		tm.tm_year += ul / 10000;
    971  1.32        ad 		ul = ul % 10000;
    972  1.32        ad 		/* FALLTHROUGH */
    973  1.32        ad 	case 4:
    974  1.32        ad 		tm.tm_mon = (ul / 100) - 1;
    975  1.32        ad 		ul = ul % 100;
    976  1.32        ad 		/* FALLTHROUGH */
    977  1.32        ad 	case 2:
    978  1.32        ad 		tm.tm_mday = ul;
    979  1.32        ad 		/* FALLTHROUGH */
    980  1.32        ad 	case 0:
    981  1.32        ad 		break;
    982  1.32        ad 	default:
    983  1.32        ad 		return ((time_t)-1);
    984  1.32        ad 	}
    985  1.32        ad 
    986  1.32        ad 	/* Sanity check */
    987  1.32        ad 	if (tm.tm_year < 70 || tm.tm_mon < 0 || tm.tm_mon > 12 ||
    988  1.32        ad 	    tm.tm_mday < 1 || tm.tm_mday > 31)
    989  1.32        ad 		return ((time_t)-1);
    990  1.32        ad 
    991  1.32        ad 	if (*t != '\0') {
    992  1.32        ad 		s = ++t;
    993  1.32        ad 		ul = strtoul(s, &t, 10);
    994  1.32        ad 		if (*t != '\0' && !isspace(*t))
    995  1.32        ad 			return ((time_t)-1);
    996  1.32        ad 
    997  1.32        ad 		switch (t - s) {
    998  1.32        ad 		case 6:
    999  1.32        ad 			tm.tm_sec = ul % 100;
   1000  1.32        ad 			ul /= 100;
   1001  1.32        ad 			/* FALLTHROUGH */
   1002  1.32        ad 		case 4:
   1003  1.32        ad 			tm.tm_min = ul % 100;
   1004  1.32        ad 			ul /= 100;
   1005  1.32        ad 			/* FALLTHROUGH */
   1006  1.32        ad 		case 2:
   1007  1.32        ad 			tm.tm_hour = ul;
   1008  1.32        ad 			/* FALLTHROUGH */
   1009  1.32        ad 		case 0:
   1010  1.32        ad 			break;
   1011  1.32        ad 		default:
   1012  1.32        ad 			return ((time_t)-1);
   1013  1.32        ad 		}
   1014  1.32        ad 
   1015  1.32        ad 		/* Sanity check */
   1016  1.32        ad 		if (tm.tm_sec < 0 || tm.tm_sec > 60 || tm.tm_min < 0 ||
   1017  1.32        ad 		    tm.tm_min > 59 || tm.tm_hour < 0 || tm.tm_hour > 23)
   1018  1.32        ad 			return ((time_t)-1);
   1019  1.32        ad 	}
   1020  1.32        ad 
   1021  1.32        ad 	return (mktime(&tm));
   1022   1.1       cgd }
   1023