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