123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344 |
- #define __FORCE_GLIBC
- #define _GNU_SOURCE
- #include <features.h>
- #include <sys/types.h>
- #include <sys/socket.h>
- #include <sys/file.h>
- #include <sys/signal.h>
- #include <sys/syslog.h>
- #include <sys/uio.h>
- #include <sys/wait.h>
- #include <netdb.h>
- #include <string.h>
- #include <time.h>
- #include <unistd.h>
- #include <errno.h>
- #include <stdarg.h>
- #include <paths.h>
- #include <stdio.h>
- #include <ctype.h>
- #include <signal.h>
- #ifdef __UCLIBC_HAS_THREADS__
- #include <pthread.h>
- static pthread_mutex_t mylock = PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP;
- # define LOCK __pthread_mutex_lock(&mylock)
- # define UNLOCK __pthread_mutex_unlock(&mylock);
- #else
- # define LOCK
- # define UNLOCK
- #endif
- static int LogFile = -1;
- static int connected;
- static int LogStat = 0;
- static const char *LogTag = "syslog";
- static int LogFacility = LOG_USER;
- static int LogMask = 0xff;
- static struct sockaddr SyslogAddr;
- static void closelog_intern( int );
- void syslog( int, const char *, ...);
- void vsyslog( int, const char *, va_list );
- void openlog( const char *, int, int );
- void closelog( void );
- int setlogmask(int pmask);
- static void
- closelog_intern(int to_default)
- {
- LOCK;
- if (LogFile != -1) {
- (void) close(LogFile);
- }
- LogFile = -1;
- connected = 0;
- if (to_default)
- {
- LogStat = 0;
- LogTag = "syslog";
- LogFacility = LOG_USER;
- LogMask = 0xff;
- }
- UNLOCK;
- }
- static void
- sigpipe_handler (int sig)
- {
- closelog_intern (0);
- }
- void
- syslog(int pri, const char *fmt, ...)
- {
- va_list ap;
- va_start(ap, fmt);
- vsyslog(pri, fmt, ap);
- va_end(ap);
- }
- void
- vsyslog( int pri, const char *fmt, va_list ap )
- {
- register char *p;
- char *last_chr, *head_end, *end, *stdp;
- time_t now;
- int fd, saved_errno;
- int rc;
- char tbuf[1024];
- struct sigaction action, oldaction;
- int sigpipe;
- memset (&action, 0, sizeof (action));
- action.sa_handler = sigpipe_handler;
- sigemptyset (&action.sa_mask);
- sigpipe = sigaction (SIGPIPE, &action, &oldaction);
- saved_errno = errno;
- LOCK;
-
- if (!(LogMask & LOG_MASK(LOG_PRI(pri))) || (pri &~ (LOG_PRIMASK|LOG_FACMASK)))
- goto getout;
- if (LogFile < 0 || !connected)
- openlog(LogTag, LogStat | LOG_NDELAY, 0);
-
- if ((pri & LOG_FACMASK) == 0)
- pri |= LogFacility;
-
- (void)time(&now);
- stdp = p = tbuf + sprintf(tbuf, "<%d>%.15s ", pri, ctime(&now) + 4);
- if (LogTag) {
- if (strlen(LogTag) < sizeof(tbuf) - 64)
- p += sprintf(p, "%s", LogTag);
- else
- p += sprintf(p, "<BUFFER OVERRUN ATTEMPT>");
- }
- if (LogStat & LOG_PID)
- p += sprintf(p, "[%d]", getpid());
- if (LogTag) {
- *p++ = ':';
- *p++ = ' ';
- }
- head_end = p;
-
- end = tbuf + sizeof(tbuf) - 1;
- __set_errno(saved_errno);
- p += vsnprintf(p, end - p, fmt, ap);
- if (p >= end || p < head_end) {
- static const char truncate_msg[12] = "[truncated] ";
- memmove(head_end + sizeof(truncate_msg), head_end,
- end - head_end - sizeof(truncate_msg));
- memcpy(head_end, truncate_msg, sizeof(truncate_msg));
- if (p < head_end) {
- while (p < end && *p) {
- p++;
- }
- }
- else {
- p = end - 1;
- }
- }
- last_chr = p;
-
- if (LogStat & LOG_PERROR) {
- *last_chr = '\n';
- (void)write(STDERR_FILENO, stdp, last_chr - stdp + 1);
- }
-
- p = tbuf;
- *last_chr = 0;
- do {
- rc = write(LogFile, p, last_chr + 1 - p);
- if (rc < 0) {
- if ((errno==EAGAIN) || (errno==EINTR))
- rc=0;
- else {
- closelog_intern(0);
- break;
- }
- }
- p+=rc;
- } while (p <= last_chr);
- if (rc >= 0)
- goto getout;
-
-
- if (LogStat & LOG_CONS &&
- (fd = open(_PATH_CONSOLE, O_WRONLY, 0)) >= 0) {
- p = index(tbuf, '>') + 1;
- last_chr[0] = '\r';
- last_chr[1] = '\n';
- (void)write(fd, p, last_chr - p + 2);
- (void)close(fd);
- }
- getout:
- UNLOCK;
- if (sigpipe == 0)
- sigaction (SIGPIPE, &oldaction,
- (struct sigaction *) NULL);
- }
- void
- openlog( const char *ident, int logstat, int logfac )
- {
- int logType = SOCK_DGRAM;
- LOCK;
- if (ident != NULL)
- LogTag = ident;
- LogStat = logstat;
- if (logfac != 0 && (logfac &~ LOG_FACMASK) == 0)
- LogFacility = logfac;
- if (LogFile == -1) {
- SyslogAddr.sa_family = AF_UNIX;
- (void)strncpy(SyslogAddr.sa_data, _PATH_LOG,
- sizeof(SyslogAddr.sa_data));
- retry:
- if (LogStat & LOG_NDELAY) {
- if ((LogFile = socket(AF_UNIX, logType, 0)) == -1){
- UNLOCK;
- return;
- }
-
- }
- }
- if (LogFile != -1 && !connected) {
- if (connect(LogFile, &SyslogAddr, sizeof(SyslogAddr) -
- sizeof(SyslogAddr.sa_data) + strlen(SyslogAddr.sa_data)) != -1)
- {
- connected = 1;
- } else if (logType == SOCK_DGRAM) {
- logType = SOCK_STREAM;
- if (LogFile != -1) {
- close(LogFile);
- LogFile = -1;
- }
- goto retry;
- } else {
- if (LogFile != -1) {
- close(LogFile);
- LogFile = -1;
- }
- }
- }
- UNLOCK;
- }
- void
- closelog( void )
- {
- closelog_intern(1);
- }
- int setlogmask(int pmask)
- {
- int omask;
- omask = LogMask;
- LOCK;
- if (pmask != 0)
- LogMask = pmask;
- UNLOCK;
- return (omask);
- }
|