1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
#include <stdarg.h>
#include <sys/socket.h>
#include <stdio.h>
#include <unistd.h>
#include <syslog.h>
#include <time.h>
#include <signal.h>
#include <string.h>
#include <pthread.h>
#include <errno.h>
#include <fcntl.h>
#include "lock.h"
#include "fork_impl.h"
#include "locale_impl.h"
static volatile int lock[1];
static char log_ident[32];
static int log_opt;
static int log_facility = LOG_USER;
static int log_mask = 0xff;
static int log_fd = -1;
volatile int *const __syslog_lockptr = lock;
int setlogmask(int maskpri)
{
LOCK(lock);
int ret = log_mask;
if (maskpri) log_mask = maskpri;
UNLOCK(lock);
return ret;
}
static const struct {
short sun_family;
char sun_path[9];
} log_addr = {
AF_UNIX,
"/dev/log"
};
void closelog(void)
{
int cs;
pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &cs);
LOCK(lock);
close(log_fd);
log_fd = -1;
UNLOCK(lock);
pthread_setcancelstate(cs, 0);
}
static void __openlog()
{
log_fd = socket(AF_UNIX, SOCK_DGRAM|SOCK_CLOEXEC, 0);
if (log_fd >= 0) connect(log_fd, (void *)&log_addr, sizeof log_addr);
}
void openlog(const char *ident, int opt, int facility)
{
int cs;
pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &cs);
LOCK(lock);
if (ident) {
size_t n = strnlen(ident, sizeof log_ident - 1);
memcpy(log_ident, ident, n);
log_ident[n] = 0;
} else {
log_ident[0] = 0;
}
log_opt = opt;
log_facility = facility;
if ((opt & LOG_NDELAY) && log_fd<0) __openlog();
UNLOCK(lock);
pthread_setcancelstate(cs, 0);
}
static int is_lost_conn(int e)
{
return e==ECONNREFUSED || e==ECONNRESET || e==ENOTCONN || e==EPIPE;
}
static void _vsyslog(int priority, const char *message, va_list ap)
{
char timebuf[16];
time_t now;
struct tm tm;
char buf[1024];
int errno_save = errno;
int pid;
int l, l2;
int hlen;
int fd;
if (log_fd < 0) __openlog();
if (!(priority & LOG_FACMASK)) priority |= log_facility;
now = time(NULL);
gmtime_r(&now, &tm);
strftime_l(timebuf, sizeof timebuf, "%b %e %T", &tm, C_LOCALE);
pid = (log_opt & LOG_PID) ? getpid() : 0;
l = snprintf(buf, sizeof buf, "<%d>%s %n%s%s%.0d%s: ",
priority, timebuf, &hlen, log_ident, "["+!pid, pid, "]"+!pid);
errno = errno_save;
l2 = vsnprintf(buf+l, sizeof buf - l, message, ap);
if (l2 >= 0) {
if (l2 >= sizeof buf - l) l = sizeof buf - 1;
else l += l2;
if (buf[l-1] != '\n') buf[l++] = '\n';
if (send(log_fd, buf, l, 0) < 0 && (!is_lost_conn(errno)
|| connect(log_fd, (void *)&log_addr, sizeof log_addr) < 0
|| send(log_fd, buf, l, 0) < 0)
&& (log_opt & LOG_CONS)) {
fd = open("/dev/console", O_WRONLY|O_NOCTTY|O_CLOEXEC);
if (fd >= 0) {
dprintf(fd, "%.*s", l-hlen, buf+hlen);
close(fd);
}
}
if (log_opt & LOG_PERROR) dprintf(2, "%.*s", l-hlen, buf+hlen);
}
}
static void __vsyslog(int priority, const char *message, va_list ap)
{
int cs;
if (!(log_mask & LOG_MASK(priority&7)) || (priority&~0x3ff)) return;
pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &cs);
LOCK(lock);
_vsyslog(priority, message, ap);
UNLOCK(lock);
pthread_setcancelstate(cs, 0);
}
void syslog(int priority, const char *message, ...)
{
va_list ap;
va_start(ap, message);
__vsyslog(priority, message, ap);
va_end(ap);
}
weak_alias(__vsyslog, vsyslog);
|
