#ifdef HAVE_CONFIG_H
# include <config.h>
#endif
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include "ntpd.h"
#include "ntp_io.h"
#include "ntp_string.h"
#include "ntp_calendar.h"
#include "ntp_filegen.h"
#include "ntp_stdlib.h"
#define SUFFIX_SEP '.'
#define FGEN_AGE_SECS (24*60*60)
static void filegen_open P((FILEGEN *, u_long));
static int valid_fileref P((char *, char *));
#ifdef UNUSED
static FILEGEN *filegen_unregister P((char *));
#endif
static void filegen_init P((char *, const char *, FILEGEN *));
static void
filegen_init(char *prefix, const char *basename, FILEGEN *fp)
{
fp->fp = NULL;
fp->prefix = prefix;
fp->basename = (char*)emalloc(strlen(basename) + 1);
strcpy(fp->basename, basename);
fp->id = 0;
fp->type = FILEGEN_DAY;
fp->flag = FGEN_FLAG_LINK;
}
static void
filegen_open(
FILEGEN *gen,
u_long newid
)
{
char *filename;
char *basename;
u_int len;
FILE *fp;
struct calendar cal;
len = strlen(gen->prefix) + strlen(gen->basename) + 1;
basename = (char*)emalloc(len);
sprintf(basename, "%s%s", gen->prefix, gen->basename);
switch(gen->type) {
default:
msyslog(LOG_ERR, "unsupported file generations type %d for \"%s\" - reverting to FILEGEN_NONE",
gen->type, basename);
gen->type = FILEGEN_NONE;
case FILEGEN_NONE:
filename = (char*)emalloc(len);
sprintf(filename,"%s", basename);
break;
case FILEGEN_PID:
filename = (char*)emalloc(len + 1 + 1 + 10);
sprintf(filename,"%s%c#%ld", basename, SUFFIX_SEP, newid);
break;
case FILEGEN_DAY:
caljulian(newid,&cal);
filename = (char*)emalloc(len + 1 + 4 + 2 + 2);
sprintf(filename, "%s%c%04d%02d%02d",
basename, SUFFIX_SEP, cal.year, cal.month, cal.monthday);
break;
case FILEGEN_WEEK:
caljulian(newid,&cal);
filename = (char*)emalloc(len + 1 + 4 + 1 + 2);
sprintf(filename, "%s%c%04dw%02d",
basename, SUFFIX_SEP, cal.year, cal.yearday / 7);
break;
case FILEGEN_MONTH:
caljulian(newid,&cal);
filename = (char*)emalloc(len + 1 + 4 + 2);
sprintf(filename, "%s%c%04d%02d",
basename, SUFFIX_SEP, cal.year, cal.month);
break;
case FILEGEN_YEAR:
caljulian(newid,&cal);
filename = (char*)emalloc(len + 1 + 4);
sprintf(filename, "%s%c%04d", basename, SUFFIX_SEP, cal.year);
break;
case FILEGEN_AGE:
filename = (char*)emalloc(len + 1 + 2 + 10);
sprintf(filename, "%s%ca%08ld", basename, SUFFIX_SEP, newid);
break;
}
if (gen->type != FILEGEN_NONE) {
struct stat stats;
static u_long conflicts = 0;
#ifndef S_ISREG
#define S_ISREG(mode) (((mode) & S_IFREG) == S_IFREG)
#endif
if (stat(basename, &stats) == 0) {
if (S_ISREG(stats.st_mode)) {
if (stats.st_nlink <= 1) {
char *savename = (char*)emalloc(len + 1 + 1 + 10 + 10);
sprintf(savename, "%s%c%dC%lu",
basename,
SUFFIX_SEP,
(int) getpid(),
(u_long)conflicts++);
if (rename(basename, savename) != 0)
msyslog(LOG_ERR," couldn't save %s: %m", basename);
free(savename);
} else {
if (
#if !defined(VMS)
unlink(basename) != 0
#else
delete(basename) != 0
#endif
)
msyslog(LOG_ERR, "couldn't unlink %s: %m", basename);
}
} else {
msyslog(LOG_ERR, "expected regular file for %s (found mode 0%lo)",
basename, (unsigned long)stats.st_mode);
}
} else {
if (errno != ENOENT)
msyslog(LOG_ERR,"stat(%s) failed: %m", basename);
}
}
fp = fopen(filename, "a");
#ifdef DEBUG
if (debug > 3)
printf("opening filegen (type=%d/id=%lu) \"%s\"\n",
gen->type, (u_long)newid, filename);
#endif
if (fp == NULL) {
if (errno != ENOENT)
msyslog(LOG_ERR, "can't open %s: %m", filename);
} else {
if (gen->fp != NULL) {
fclose(gen->fp);
}
gen->fp = fp;
gen->id = newid;
if (gen->flag & FGEN_FLAG_LINK) {
#if defined SYS_WINNT || defined SYS_VXWORKS
SetLastError(0);
#elif defined(VMS)
errno = 0;
#else
if (link(filename, basename) != 0)
if (errno != EEXIST)
msyslog(LOG_ERR, "can't link(%s, %s): %m", filename, basename);
#endif
}
}
free(basename);
free(filename);
return;
}
void
filegen_setup(
FILEGEN *gen,
u_long now
)
{
u_long new_gen = ~ (u_long) 0;
struct calendar cal;
if (!(gen->flag & FGEN_FLAG_ENABLED)) {
if (gen->fp != NULL)
fclose(gen->fp);
return;
}
switch (gen->type) {
case FILEGEN_NONE:
if (gen->fp != NULL) return;
break;
case FILEGEN_PID:
new_gen = getpid();
break;
case FILEGEN_DAY:
caljulian(now, &cal);
cal.hour = cal.minute = cal.second = 0;
new_gen = caltontp(&cal);
break;
case FILEGEN_WEEK:
new_gen = now - (now - calyearstart(now)) % TIMES7(SECSPERDAY)
+ 60;
caljulian(new_gen, &cal);
cal.hour = cal.minute = cal.second = 0;
new_gen = caltontp(&cal);
break;
case FILEGEN_MONTH:
caljulian(now, &cal);
cal.yearday = (u_short) (cal.yearday - cal.monthday + 1);
cal.monthday = 1;
cal.hour = cal.minute = cal.second = 0;
new_gen = caltontp(&cal);
break;
case FILEGEN_YEAR:
new_gen = calyearstart(now);
break;
case FILEGEN_AGE:
new_gen = current_time - (current_time % FGEN_AGE_SECS);
break;
}
if (gen->fp == NULL || gen->id != new_gen) {
#if DEBUG
if (debug)
printf("filegen %0x %lu %lu %lu\n", gen->type, now,
gen->id, new_gen);
#endif
filegen_open(gen, new_gen);
}
}
void
filegen_config(
FILEGEN *gen,
char *basename,
u_int type,
u_int flag
)
{
if ((basename == gen->basename || strcmp(basename,gen->basename) == 0) &&
type == gen->type &&
flag == gen->flag)
return;
if (!valid_fileref(gen->prefix,basename))
return;
if (gen->fp != NULL)
fclose(gen->fp);
#ifdef DEBUG
if (debug > 2)
printf("configuring filegen:\n\tprefix:\t%s\n\tbasename:\t%s -> %s\n\ttype:\t%d -> %d\n\tflag: %x -> %x\n",
gen->prefix, gen->basename, basename, gen->type, type, gen->flag, flag);
#endif
if (gen->basename != basename || strcmp(gen->basename, basename) != 0) {
free(gen->basename);
gen->basename = (char*)emalloc(strlen(basename) + 1);
strcpy(gen->basename, basename);
}
gen->type = (u_char) type;
gen->flag = (u_char) flag;
if (gen->fp != NULL) {
l_fp now;
get_systime(&now);
filegen_setup(gen, now.l_ui);
}
}
static int
valid_fileref(
char *prefix,
char *basename
)
{
register char *p = basename;
if (prefix == NULL || *prefix == '\0')
return 0;
if (basename == NULL)
return 0;
for (p = basename; p; p = strchr(p, '/')) {
if (*p == '.' && *(p+1) == '.' && (*(p+2) == '\0' || *(p+2) == '/'))
return 0;
}
return 1;
}
static struct filegen_entry {
char *name;
FILEGEN *filegen;
struct filegen_entry *next;
} *filegen_registry = NULL;
FILEGEN *
filegen_get(
char *name
)
{
struct filegen_entry *f = filegen_registry;
while(f) {
if (f->name == name || strcmp(name, f->name) == 0) {
#ifdef XXX
if (debug > 3)
printf("filegen_get(\"%s\") = %x\n", name,
(u_int)f->filegen);
#endif
return f->filegen;
}
f = f->next;
}
#ifdef DEBUG
if (debug > 3)
printf("filegen_get(\"%s\") = NULL\n", name);
#endif
return NULL;
}
void
filegen_register(
char *prefix,
const char *name,
FILEGEN *filegen
)
{
struct filegen_entry **f = &filegen_registry;
#ifdef XXX
if (debug > 3)
printf("filegen_register(\"%s\",%x)\n", name, (u_int)filegen);
#endif
filegen_init(prefix, name, filegen);
while (*f) {
if ((*f)->name == name || strcmp(name, (*f)->name) == 0) {
#ifdef XXX
if (debug > 4) {
printf("replacing filegen %x\n", (u_int)(*f)->filegen);
}
#endif
(*f)->filegen = filegen;
return;
}
f = &((*f)->next);
}
*f = (struct filegen_entry *) emalloc(sizeof(struct filegen_entry));
if (*f) {
(*f)->next = NULL;
(*f)->name = (char*)emalloc(strlen(name) + 1);
strcpy((*f)->name, name);
(*f)->filegen = filegen;
#ifdef DEBUG
if (debug > 5) {
printf("adding new filegen\n");
}
#endif
}
return;
}
#ifdef UNUSED
static FILEGEN *
filegen_unregister(
char *name
)
{
struct filegen_entry **f = &filegen_registry;
#ifdef DEBUG
if (debug > 3)
printf("filegen_unregister(\"%s\")\n", name);
#endif
while (*f) {
if (strcmp((*f)->name,name) == 0) {
struct filegen_entry *ff = *f;
FILEGEN *fg;
*f = (*f)->next;
fg = ff->filegen;
free(ff->name);
free(ff);
return fg;
}
f = &((*f)->next);
}
return NULL;
}
#endif