#pragma prototyped

#include <ast.h>

#if _lib_syslog

NoN(syslog)

#else

#define LOG_TABLES

#include "sysloglib.h"

#include <error.h>

#include <tm.h>

Syslog_state_t log = { LOG_USER, -1, 0, ~0 };

static const Namval_t attempt[] =

{

"/dev/log", 0,

"lib/syslog/log", 0,

"/dev/console", LOG_CONS,

};

const Namval_t log_facility[] =

{

"default", 0,

"user", LOG_USER,

"kernel", LOG_KERN,

"mail", LOG_MAIL,

"daemon", LOG_DAEMON,

"security", LOG_AUTH,

"syslog", LOG_SYSLOG,

"lpr", LOG_LPR,

"news", LOG_NEWS,

"uucp", LOG_UUCP,

"cron", LOG_CRON,

"audit", LOG_AUDIT,

"logalert", LOG_LFMT,

#ifdef LOG_SYSTEM2

"system2", LOG_SYSTEM2,

#endif

#ifdef LOG_SYSTEM1

"system1", LOG_SYSTEM1,

#endif

#ifdef LOG_SYSTEM0

"system0", LOG_SYSTEM0,

#endif

0, 0

};

const Namval_t log_severity[] =

{

"panic", LOG_EMERG,

"alert", LOG_ALERT,

"critical", LOG_CRIT,

"error", LOG_ERR,

"warning", LOG_WARNING,

"notice", LOG_NOTICE,

"info", LOG_INFO,

"debug", LOG_DEBUG,

0, 0

};

#if _UWIN

#include <ctype.h>

#include <ls.h>

#include <sys/socket.h>

#include <sys/un.h>

#include <netdb.h>

#include <netinet/in.h>

#if !defined(htons) && !_lib_htons

# define htons(x) (x)

#endif

#if !defined(htonl) && !_lib_htonl

# define htonl(x) (x)

#endif

#ifndef INADDR_LOOPBACK

#define INADDR_LOOPBACK 0x7f000001L

#endif

static int

str2inet(register char* s, char* prot, struct sockaddr_in* addr)

{

register int c;

register int v;

register int n = 0;

unsigned long a = 0;

unsigned short p = 0;

if (!memcmp(s, "local/", 6))

{

a = INADDR_LOOPBACK;

n = 4;

s += 6;

}

else if (!isdigit(*s))

{

struct hostent* hp;

char* e = strchr(s, '/');

if (!(e = strchr(s, '/')))

return -1;

*e = 0;

hp = gethostbyname(s);

*e = '/';

if (!hp || hp->h_addrtype != AF_INET || hp->h_length > sizeof(struct in_addr))

return -1;

a = (unsigned long)((struct in_addr*)hp->h_addr)->s_addr;

n = 6;

s = e + 1;

}

for (;;)

{

v = 0;

while ((c = *s++) >= '0' && c <= '9')

v = v * 10 + c - '0';

if (++n <= 4)

a = (a << 8) | (v & 0xff);

else

{

if (n <= 5)

a = htonl(a);

if (c)

{

struct servent* sp;

if (!(sp = getservbyname(s - 1, prot)))

return -1;

p = sp->s_port;

}

else

p = htons(v);

break;

}

if (c != '.' && c != '/')

return -1;

}

memset((char*)addr, 0, sizeof(*addr));

addr->sin_family = AF_INET;

addr->sin_addr.s_addr = a;

addr->sin_port = p;

return 0;

}

sockopen(const char* path)

{

int fd;

struct sockaddr_in addr;

char buf[PATH_MAX];

if (pathgetlink(path, buf, sizeof(buf)) <= 0)

{

if (strlen(path) >= sizeof(buf))

return -1;

strcpy(buf, path);

}

#if LOCAL

{

int ul;

struct sockaddr_un ua;

struct stat st;

if ((ul = strlen(buf)) < sizeof(ua.sun_path) && !stat(buf, &st) && S_ISSOCK(st.st_mode))

{

if ((fd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0)

return -1;

ua.sun_family = AF_UNIX;

strcpy(ua.sun_path, buf);

ul += sizeof(ua.sun_family) + 1;

if (!connect(fd, (struct sockaddr*)&ua, ul))

return fd;

close(fd);

return -1;

}

}

#endif

if (!strmatch(buf, "/dev/(tcp|udp)/*/*"))

return -1;

buf[8] = 0;

if (str2inet(buf + 9, buf + 5, &addr))

return -1;

if ((fd = socket(AF_INET, buf[5] == 't' ? SOCK_STREAM : SOCK_DGRAM, 0)) < 0)

return -1;

if (connect(fd, (struct sockaddr*)&addr, sizeof(addr)))

{

close(fd);

return -1;

}

return fd;

}

#else

sockopen(const char* path)

{

return -1;

}

#endif

sendlog(const char* msg)

{

register char* s;

register Namval_t* p;

register int n;

n = msg ? strlen(msg) : 0;

for (;;)

{

if (log.fd < 0)

{

char buf[PATH_MAX];

if (log.attempt >= elementsof(attempt))

break;

p = (Namval_t*)&attempt[log.attempt++];

if (p->value && !(p->value & log.flags))

continue;

if (*(s = p->name) != '/' && !(s = pathpath(buf, s, "", PATH_REGULAR|PATH_READ)))

continue;

if ((log.fd = open(s, O_WRONLY|O_APPEND|O_NOCTTY)) < 0 && (log.fd = sockopen(s)) < 0)

continue;

fcntl(log.fd, F_SETFD, FD_CLOEXEC);

}

if (!n || write(log.fd, msg, n) > 0)

break;

close(log.fd);

log.fd = -1;

}

if (n && (log.flags & LOG_PERROR))

write(2, msg, n);

}

static int

extend(Sfio_t* sp, void* vp, Sffmt_t* dp)

{

if (dp->fmt == 'm')

{

dp->flags |= SFFMT_VALUE;

dp->fmt = 's';

dp->size = -1;

*((char**)vp) = fmterror(errno);

}

return 0;

}

vsyslog(int priority, const char* format, va_list ap)

{

register int c;

register char* s;

Sfio_t* sp;

Sffmt_t fmt;

char buf[16];

if (!LOG_FACILITY(priority))

priority |= log.facility;

if (!(priority & log.mask))

return;

if (sp = sfstropen())

{

sfputr(sp, fmttime("%b %d %H:%M:%S", time(NiL)), -1);

if (log.flags & LOG_LEVEL)

{

if ((c = LOG_SEVERITY(priority)) < elementsof(log_severity))

s = (char*)log_severity[c].name;

else

sfsprintf(s = buf, sizeof(buf), "debug%d", c);

sfprintf(sp, " %-8s ", s);

if ((c = LOG_FACILITY(priority)) < elementsof(log_facility))

s = (char*)log_facility[c].name;

else

sfsprintf(s = buf, sizeof(buf), "local%d", c);

sfprintf(sp, " %-8s ", s);

}

#if _lib_gethostname

if (!*log.host && gethostname(log.host, sizeof(log.host)-1))

strcpy(log.host, "localhost");

sfprintf(sp, " %s", log.host);

#endif

if (*log.ident)

sfprintf(sp, " %s", log.ident);

if (log.flags & LOG_PID)

{

if (!*log.ident)

sfprintf(sp, " ");

sfprintf(sp, "[%d]", getpid());

}

if (format)

{

sfprintf(sp, ": ");

memset(&fmt, 0, sizeof(fmt));

fmt.version = SFIO_VERSION;

fmt.form = (char*)format;

fmt.extf = extend;

va_copy(fmt.args, ap);

sfprintf(sp, "%!", &fmt);

}

if ((s = sfstrseek(sp, 0, SEEK_CUR)) && *(s - 1) != '\n')

sfputc(sp, '\n');

if (s = sfstruse(sp))

sendlog(s);

sfstrclose(sp);

}

}

syslog(int priority, const char* format, ...)

{

va_list ap;

va_start(ap, format);

vsyslog(priority, format, ap);

va_end(ap);

}

#endif