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