Aren/NetBSD
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
c5d7701cd4
NetBSD/usr.bin/newsyslog/newsyslog.c
ad 604db10508 - Add '-F' option which forces rotation of logs (from FreeBSD). 
- Add 'sigtype' field specifying signal to be sent (from FreeBSD).
- Add 'N' flag which specifies that no signal should be sent.
- Fix some breakage.
1999-11-30 12:03:24 +00:00

677 lines
21 KiB
C
Raw Blame History

/* $NetBSD: newsyslog.c,v 1.21 1999/11/30 12:03:24 ad Exp $ */
/*
* This file contains changes from the Open Software Foundation.
*/
/*
Copyright 1988, 1989 by the Massachusetts Institute of Technology
Permission to use, copy, modify, and distribute this software
and its documentation for any purpose and without fee is
hereby granted, provided that the above copyright notice
appear in all copies and that both that copyright notice and
this permission notice appear in supporting documentation,
and that the names of M.I.T. and the M.I.T. S.I.P.B. not be
used in advertising or publicity pertaining to distribution
of the software without specific, written prior permission.
M.I.T. and the M.I.T. S.I.P.B. make no representations about
the suitability of this software for any purpose. It is
provided "as is" without express or implied warranty.
*/
/*
* newsyslog - roll over selected logs at the appropriate time,
* keeping the a specified number of backup files around.
*/
#include <sys/cdefs.h>
#ifndef lint
__RCSID("$NetBSD: newsyslog.c,v 1.21 1999/11/30 12:03:24 ad Exp $");
#endif /* not lint */
#ifndef CONF
#define CONF "/etc/athena/newsyslog.conf" /* Configuration file */
#endif
#ifndef PIDFILE
#define PIDFILE "/etc/syslog.pid"
#endif
#ifndef COMPRESS
#define COMPRESS "/usr/ucb/compress" /* File compression program */
#endif
#ifndef COMPRESS_POSTFIX
#define COMPRESS_POSTFIX ".Z"
#endif
#include <sys/types.h>
#include <sys/time.h>
#include <sys/stat.h>
#include <sys/param.h>
#include <sys/wait.h>
#include <ctype.h>
#include <fcntl.h>
#include <grp.h>
#include <pwd.h>
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#define kbytes(size) (((size) + 1023) >> 10)
#ifdef _IBMR2
/* Calculates (db * DEV_BSIZE) */
#define dbtob(db) ((unsigned)(db) << UBSHIFT)
#endif
#define CE_COMPACT 1 /* Compact the achived log files */
#define CE_BINARY 2 /* Logfile is in binary, don't add */
/* status messages */
#define CE_NOSIGNAL 4 /* Don't send a signal when trimmed */
#define NONE -1
struct conf_entry {
char *log; /* Name of the log */
int uid; /* Owner of log */
int gid; /* Group of log */
int numlogs; /* Number of logs to keep */
int size; /* Size cutoff to trigger trimming the log */
int hours; /* Hours between log trimming */
int permissions; /* File permissions on the log */
int flags; /* Flags (CE_*) */
char *pidfile; /* Name of file containing PID to signal */
int signum; /* Signal to send */
struct conf_entry *next; /* Linked list pointer */
};
char *progname; /* contains argv[0] */
int verbose = 0; /* Print out what's going on */
int needroot = 1; /* Root privs are necessary */
int noaction = 0; /* Don't do anything, just show it */
int force; /* Force the trim no matter what */
char *conf = CONF; /* Configuration file to use */
time_t timenow;
int syslog_pid; /* read in from /etc/syslog.pid */
#define MIN_PID 3
#define MAX_PID 65534
char hostname[MAXHOSTNAMELEN + 1]; /* hostname */
char *daytime; /* timenow in human readable form */
void PRS __P((int, char **));
int age_old_log __P((char *));
void compress_log __P((char *));
void dotrim __P((char *, int, int, int, int, int, char *, int));
void do_entry __P((struct conf_entry *));
int isnumber __P((char *));
int log_trim __P((char *));
int main __P((int, char **));
char *missing_field __P((char *, char *));
struct conf_entry *parse_file __P((void));
int sizefile __P((char *));
char *sob __P((char *));
char *son __P((char *));
void usage __P((void));
int getsig __P((char *));
int
main(argc,argv)
int argc;
char **argv;
{
struct conf_entry *p, *q;
PRS(argc,argv);
if (needroot && getuid() && geteuid()) {
fprintf(stderr,"%s: must have root privs\n",progname);
exit(1);
}
p = q = parse_file();
while (p) {
do_entry(p);
p=p->next;
free((char *) q);
q=p;
}
exit(0);
}
void
do_entry(ent)
struct conf_entry *ent;
{
int size, modtime;
if (verbose) {
if (ent->flags & CE_COMPACT)
printf("%s <%dZ>: ",ent->log,ent->numlogs);
else
printf("%s <%d>: ",ent->log,ent->numlogs);
}
size = sizefile(ent->log);
modtime = age_old_log(ent->log);
if (size < 0) {
if (verbose)
printf("does not exist.\n");
} else {
if (verbose && (ent->size > 0))
printf("size (Kb): %d [%d] ", size, ent->size);
if (verbose && (ent->hours > 0))
printf(" age (hr): %d [%d] ", modtime, ent->hours);
if (force || ((ent->size > 0) && (size >= ent->size)) ||
((ent->hours > 0) && ((modtime >= ent->hours)
|| (modtime < 0)))) {
if (verbose)
printf("--> trimming log....\n");
if (noaction && !verbose) {
if (ent->flags & CE_COMPACT)
printf("%s <%dZ>: trimming",
ent->log,ent->numlogs);
else
printf("%s <%d>: trimming",
ent->log,ent->numlogs);
}
dotrim(ent->log, ent->numlogs, ent->flags,
ent->permissions, ent->uid, ent->gid,
ent->pidfile, ent->signum);
} else {
if (verbose)
printf("--> skipping\n");
}
}
}
void
PRS(argc,argv)
int argc;
char **argv;
{
int c;
FILE *f;
char line[BUFSIZ];
char *p;
progname = argv[0];
timenow = time((time_t *) 0);
daytime = ctime(&timenow) + 4;
daytime[15] = '\0';
/* Let's find the pid of syslogd */
syslog_pid = 0;
f = fopen(PIDFILE,"r");
if (f && fgets(line,BUFSIZ,f))
syslog_pid = atoi(line);
if (f)
(void)fclose(f);
/* Let's get our hostname */
(void)gethostname(hostname, sizeof(hostname));
hostname[sizeof(hostname) - 1] = '\0';
/* Truncate domain */
if ((p = strchr(hostname, '.')) != NULL) {
*p = '\0';
}
optind = 1; /* Start options parsing */
while ((c=getopt(argc,argv,"Fnrvf:")) != -1)
switch (c) {
case 'n':
noaction++; /* This implies needroot as off */
/* fall through */
case 'r':
needroot = 0;
break;
case 'v':
verbose++;
break;
case 'f':
conf = optarg;
break;
case 'F':
force++;
break;
default:
usage();
}
}
void
usage()
{
fprintf(stderr,
"Usage: %s <-Fnrv> <-f config-file>\n", progname);
exit(1);
}
/* Parse a configuration file and return a linked list of all the logs
* to process
*/
struct conf_entry *
parse_file()
{
FILE *f;
char line[BUFSIZ], *parse, *q;
char *errline, *group, prev;
struct conf_entry *first = NULL;
struct conf_entry *working;
struct passwd *pass;
struct group *grp;
working = NULL;
if (strcmp(conf,"-"))
f = fopen(conf,"r");
else
f = stdin;
if (!f) {
(void) fprintf(stderr,"%s: ",progname);
perror(conf);
exit(1);
}
while (fgets(line,BUFSIZ,f)) {
if ((line[0]== '\n') || (line[0] == '#'))
continue;
errline = strdup(line);
if (!first) {
working = (struct conf_entry *) malloc(sizeof(struct conf_entry));
first = working;
} else {
working->next = (struct conf_entry *) malloc(sizeof(struct conf_entry));
working = working->next;
}
q = parse = missing_field(sob(line),errline);
*(parse = son(line)) = '\0';
working->log = strdup(q);
q = parse = missing_field(sob(++parse),errline);
*(parse = son(parse)) = '\0';
if ((group = strchr(q, ':')) != NULL || (group = strchr(q, '.')) != NULL) {
*group++ = '\0';
if (*q) {
if (!(isnumber(q))) {
if ((pass = getpwnam(q)) == NULL) {
fprintf(stderr,
"Error in config file; unknown user:\n");
fputs(errline,stderr);
exit(1);
}
working->uid = pass->pw_uid;
} else
working->uid = atoi(q);
} else
working->uid = NONE;
q = group;
if (*q) {
if (!(isnumber(q))) {
if ((grp = getgrnam(q)) == NULL) {
fprintf(stderr,
"Error in config file; unknown group:\n");
fputs(errline,stderr);
exit(1);
}
working->gid = grp->gr_gid;
} else
working->gid = atoi(q);
} else
working->gid = NONE;
q = parse = missing_field(sob(++parse),errline);
*(parse = son(parse)) = '\0';
}
else
working->uid = working->gid = NONE;
if (!sscanf(q,"%o",&working->permissions)) {
fprintf(stderr,
"Error in config file; bad permissions:\n");
fputs(errline,stderr);
exit(1);
}
q = parse = missing_field(sob(++parse),errline);
*(parse = son(parse)) = '\0';
if (!sscanf(q,"%d",&working->numlogs)) {
fprintf(stderr,
"Error in config file; bad number:\n");
fputs(errline,stderr);
exit(1);
}
q = parse = missing_field(sob(++parse),errline);
*(parse = son(parse)) = '\0';
if (isdigit((unsigned char)*q))
working->size = atoi(q);
else
working->size = -1;
q = parse = missing_field(sob(++parse),errline);
*(parse = son(parse)) = '\0';
if (isdigit((unsigned char)*q))
working->hours = atoi(q);
else
working->hours = -1;
q = parse = sob(++parse); /* Optional field */
prev = *(parse = son(parse));
*parse = '\0';
working->flags = 0;
while (q && *q && !isspace((unsigned char)*q)) {
if ((*q == 'Z') || (*q == 'z'))
working->flags |= CE_COMPACT;
else if ((*q == 'B') || (*q == 'b'))
working->flags |= CE_BINARY;
else if ((*q == 'N') || (*q == 'n'))
working->flags |= CE_NOSIGNAL;
else if (*q != '-') {
fprintf(stderr,
"Illegal flag in config file -- %c\n",
*q);
exit(1);
}
q++;
}
if (prev != '\0' && (q = parse = sob(++parse)) != NULL &&
q[0] == '/') {
prev = *(parse = son(parse));
*parse++ = '\0';
working->pidfile = strdup(q);
} else {
working->pidfile = NULL;
prev = *parse;
}
if (prev != '\0' && (q = parse = sob(parse)) != NULL &&
q[0] != '\0') {
*(parse = son(parse)) = '\0';
if ((working->signum = getsig(q)) < 0) {
fprintf(stderr,
"Illegal signal in config file -- %s\n",
q);
exit(1);
}
} else
working->signum = SIGHUP;
free(errline);
}
if (working)
working->next = (struct conf_entry *) NULL;
(void) fclose(f);
return(first);
}
char *
missing_field(p,errline)
char *p,*errline;
{
if (!p || !*p) {
fprintf(stderr,"Missing field in config file:\n");
fputs(errline,stderr);
exit(1);
}
return(p);
}
void
dotrim(log,numdays,flags,perm,owner_uid,group_gid,pidfile,signum)
char *log;
int numdays;
int flags;
int perm;
int owner_uid;
int group_gid;
char *pidfile;
int signum;
{
char file1[128], file2[128];
char zfile1[128], zfile2[128];
char line[BUFSIZ];
int fd;
struct stat st;
int ngen = numdays;
FILE *f;
pid_t pid;
#ifdef _IBMR2
/* AIX 3.1 has a broken fchown- if the owner_uid is -1, it will actually */
/* change it to be owned by uid -1, instead of leaving it as is, as it is */
/* supposed to. */
if (owner_uid == -1)
owner_uid = geteuid();
#endif
if (pidfile != NULL && pidfile[0] != '\0') {
if ((f = fopen(pidfile,"r")) == NULL) {
(void) fprintf(stderr,"%s: ",progname);
perror(conf);
return;
}
if (fgets(line,BUFSIZ,f))
pid = atoi(line);
if (f)
(void)fclose(f);
} else
pid = syslog_pid;
/* Remove oldest log */
(void) sprintf(file1,"%s.%d",log,numdays);
(void) strcpy(zfile1, file1);
(void) strcat(zfile1, COMPRESS_POSTFIX);
if (noaction) {
printf("rm -f %s\n", file1);
printf("rm -f %s\n", zfile1);
} else {
(void) unlink(file1);
(void) unlink(zfile1);
}
/* Move down log files */
while (numdays--) {
(void) strcpy(file2,file1);
(void) sprintf(file1,"%s.%d",log,numdays);
(void) strcpy(zfile1, file1);
(void) strcpy(zfile2, file2);
if (lstat(file1, &st)) {
(void) strcat(zfile1, COMPRESS_POSTFIX);
(void) strcat(zfile2, COMPRESS_POSTFIX);
if (lstat(zfile1, &st)) continue;
}
if (noaction) {
printf("mv %s %s\n",zfile1,zfile2);
printf("chmod %o %s\n", perm, zfile2);
printf("chown %d.%d %s\n",
owner_uid, group_gid, zfile2);
} else {
(void) rename(zfile1, zfile2);
(void) chmod(zfile2, perm);
(void) chown(zfile2, owner_uid, group_gid);
}
}
if (!noaction && !(flags & CE_BINARY))
(void) log_trim(log); /* Report the trimming to the old log */
if (ngen == 0) {
if (noaction)
printf("rm %s\n",log);
else
(void) unlink(log);
} else
if (noaction)
printf("mv %s to %s\n",log,file1);
else
(void) rename(log,file1);
if (noaction)
printf("Start new log...");
else {
fd = creat(log,perm);
if (fd < 0) {
perror("can't start new log");
exit(1);
}
if (fchown(fd, owner_uid, group_gid)) {
perror("can't chmod new log file");
exit(1);
}
(void) close(fd);
if (!(flags & CE_BINARY))
if (log_trim(log)) { /* Add status message */
perror("can't add status message to log");
exit(1);
}
}
if (noaction)
printf("chmod %o %s...",perm,log);
else
(void) chmod(log,perm);
if ((flags & CE_NOSIGNAL) == 0) {
if (noaction)
printf("kill -HUP %d\n",pid);
else if (pid < MIN_PID || pid > MAX_PID) {
fprintf(stderr,"%s: preposterous process number: %d\n",
progname, pid);
} else if (kill(pid, signum)) {
fprintf(stderr,"%s: ", progname);
perror("warning - could not restart daemon");
}
}
if ((flags & CE_COMPACT) != 0) {
if (noaction)
printf("Compress %s.0\n",log);
else
compress_log(log);
}
}
/* Log the fact that the logs were turned over */
int
log_trim(log)
char *log;
{
FILE *f;
if ((f = fopen(log,"a")) == NULL)
return(-1);
fprintf(f,"%s %s newsyslog[%ld]: logfile turned over\n",
daytime, hostname, (u_long)getpid());
if (fclose(f) == EOF) {
perror("log_trim: fclose");
exit(1);
}
return(0);
}
/* Fork off compress/gzip to compress the old log file */
void
compress_log(log)
char *log;
{
int pid;
char tmp[128];
pid = fork();
(void) sprintf(tmp,"%s.0",log);
if (pid < 0) {
fprintf(stderr,"%s: ",progname);
perror("fork");
exit(1);
} else if (!pid) {
(void) execl(COMPRESS,"compress","-f",tmp,0);
fprintf(stderr,"%s: ",progname);
perror(COMPRESS);
exit(1);
}
}
/* Return size in kilobytes of a file */
int
sizefile(file)
char *file;
{
struct stat sb;
if (stat(file,&sb) < 0)
return(-1);
return(kbytes(dbtob(sb.st_blocks)));
}
/* Return the age of old log file (file.0) */
int
age_old_log(file)
char *file;
{
struct stat sb;
char tmp[MAXPATHLEN+3];
(void) strcpy(tmp,file);
if (stat(strcat(tmp,".0"),&sb) < 0)
if (stat(strcat(tmp,COMPRESS_POSTFIX), &sb) < 0)
return(-1);
return( (int) (timenow - sb.st_mtime + 1800) / 3600);
}
/* Skip Over Blanks */
char *sob(p)
char *p;
{
while (p && *p && isspace((unsigned char)*p))
p++;
return(p);
}
/* Skip Over Non-Blanks */
char *
son(p)
char *p;
{
while (p && *p && !isspace((unsigned char)*p))
p++;
return(p);
}
/* Check if string is actually a number */
int
isnumber(string)
char *string;
{
while (*string != '\0') {
if (*string < '0' || *string > '9') return(0);
string++;
}
return(1);
}
int
getsig(sig)
char *sig;
{
int n;
if (isnumber(sig)) {
n = strtol(sig, &sig, 0);
if ((unsigned)n >= NSIG)
return (-1);
return (n);
}
if (!strncasecmp(sig, "sig", 3))
sig += 3;
for (n = 1; n < NSIG; n++) {
if (!strcasecmp(sys_signame[n], sig))
return (n);
}
return (-1);
}
Reference in New Issue View Git Blame Copy Permalink