123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997 |
- #include <sys/un.h>
- #include <sys/uio.h>
- #if ENABLE_FEATURE_REMOTE_LOG
- #include <netinet/in.h>
- #endif
- #if ENABLE_FEATURE_IPC_SYSLOG
- #include <sys/ipc.h>
- #include <sys/sem.h>
- #include <sys/shm.h>
- #endif
- #define DEBUG 0
- #undef SYSLOGD_MARK
- #undef SYSLOGD_WRLOCK
- enum {
- MAX_READ = CONFIG_FEATURE_SYSLOGD_READ_BUFFER_SIZE,
- DNS_WAIT_SEC = 2 * 60,
- };
- struct shbuf_ds {
- int32_t size;
- int32_t tail;
- char data[1];
- };
- #if ENABLE_FEATURE_REMOTE_LOG
- typedef struct {
- int remoteFD;
- unsigned last_dns_resolve;
- len_and_sockaddr *remoteAddr;
- const char *remoteHostname;
- } remoteHost_t;
- #endif
- typedef struct logFile_t {
- const char *path;
- int fd;
- #if ENABLE_FEATURE_ROTATE_LOGFILE
- unsigned size;
- uint8_t isRegular;
- #endif
- } logFile_t;
- #if ENABLE_FEATURE_SYSLOGD_CFG
- typedef struct logRule_t {
- uint8_t enabled_facility_priomap[LOG_NFACILITIES];
- struct logFile_t *file;
- struct logRule_t *next;
- } logRule_t;
- #endif
- #define GLOBALS \
- logFile_t logFile; \
- \
- \
- \
- int logLevel; \
- IF_FEATURE_ROTATE_LOGFILE( \
- \
- unsigned logFileSize; \
- \
- unsigned logFileRotate; \
- ) \
- IF_FEATURE_IPC_SYSLOG( \
- int shmid; \
- int s_semid; \
- int shm_size; \
- struct sembuf SMwup[1]; \
- struct sembuf SMwdn[3]; \
- ) \
- IF_FEATURE_SYSLOGD_CFG( \
- logRule_t *log_rules; \
- )
- struct init_globals {
- GLOBALS
- };
- struct globals {
- GLOBALS
- #if ENABLE_FEATURE_REMOTE_LOG
- llist_t *remoteHosts;
- #endif
- #if ENABLE_FEATURE_IPC_SYSLOG
- struct shbuf_ds *shbuf;
- #endif
- time_t last_log_time;
-
- char *hostname;
-
- char recvbuf[MAX_READ * (1 + ENABLE_FEATURE_SYSLOGD_DUP)];
-
-
- char parsebuf[MAX_READ*2];
-
-
- char printbuf[MAX_READ*2 + 128];
- };
- static const struct init_globals init_data = {
- .logFile = {
- .path = "/var/log/messages",
- .fd = -1,
- },
- #ifdef SYSLOGD_MARK
- .markInterval = 20 * 60,
- #endif
- .logLevel = 8,
- #if ENABLE_FEATURE_ROTATE_LOGFILE
- .logFileSize = 200 * 1024,
- .logFileRotate = 1,
- #endif
- #if ENABLE_FEATURE_IPC_SYSLOG
- .shmid = -1,
- .s_semid = -1,
- .shm_size = ((CONFIG_FEATURE_IPC_SYSLOG_BUFFER_SIZE)*1024),
- .SMwup = { {1, -1, IPC_NOWAIT} },
- .SMwdn = { {0, 0}, {1, 0}, {1, +1} },
- #endif
- };
- #define G (*ptr_to_globals)
- #define INIT_G() do { \
- SET_PTR_TO_GLOBALS(memcpy(xzalloc(sizeof(G)), &init_data, sizeof(init_data))); \
- } while (0)
- enum {
- OPTBIT_mark = 0,
- OPTBIT_nofork,
- OPTBIT_outfile,
- OPTBIT_loglevel,
- OPTBIT_small,
- IF_FEATURE_ROTATE_LOGFILE(OPTBIT_filesize ,)
- IF_FEATURE_ROTATE_LOGFILE(OPTBIT_rotatecnt ,)
- IF_FEATURE_REMOTE_LOG( OPTBIT_remotelog ,)
- IF_FEATURE_REMOTE_LOG( OPTBIT_locallog ,)
- IF_FEATURE_IPC_SYSLOG( OPTBIT_circularlog,)
- IF_FEATURE_SYSLOGD_DUP( OPTBIT_dup ,)
- IF_FEATURE_SYSLOGD_CFG( OPTBIT_cfg ,)
- OPT_mark = 1 << OPTBIT_mark ,
- OPT_nofork = 1 << OPTBIT_nofork ,
- OPT_outfile = 1 << OPTBIT_outfile ,
- OPT_loglevel = 1 << OPTBIT_loglevel,
- OPT_small = 1 << OPTBIT_small ,
- OPT_filesize = IF_FEATURE_ROTATE_LOGFILE((1 << OPTBIT_filesize )) + 0,
- OPT_rotatecnt = IF_FEATURE_ROTATE_LOGFILE((1 << OPTBIT_rotatecnt )) + 0,
- OPT_remotelog = IF_FEATURE_REMOTE_LOG( (1 << OPTBIT_remotelog )) + 0,
- OPT_locallog = IF_FEATURE_REMOTE_LOG( (1 << OPTBIT_locallog )) + 0,
- OPT_circularlog = IF_FEATURE_IPC_SYSLOG( (1 << OPTBIT_circularlog)) + 0,
- OPT_dup = IF_FEATURE_SYSLOGD_DUP( (1 << OPTBIT_dup )) + 0,
- OPT_cfg = IF_FEATURE_SYSLOGD_CFG( (1 << OPTBIT_cfg )) + 0,
- };
- #define OPTION_STR "m:nO:l:S" \
- IF_FEATURE_ROTATE_LOGFILE("s:" ) \
- IF_FEATURE_ROTATE_LOGFILE("b:" ) \
- IF_FEATURE_REMOTE_LOG( "R:" ) \
- IF_FEATURE_REMOTE_LOG( "L" ) \
- IF_FEATURE_IPC_SYSLOG( "C::") \
- IF_FEATURE_SYSLOGD_DUP( "D" ) \
- IF_FEATURE_SYSLOGD_CFG( "f:" )
- #define OPTION_DECL *opt_m, *opt_l \
- IF_FEATURE_ROTATE_LOGFILE(,*opt_s) \
- IF_FEATURE_ROTATE_LOGFILE(,*opt_b) \
- IF_FEATURE_IPC_SYSLOG( ,*opt_C = NULL) \
- IF_FEATURE_SYSLOGD_CFG( ,*opt_f = NULL)
- #define OPTION_PARAM &opt_m, &(G.logFile.path), &opt_l \
- IF_FEATURE_ROTATE_LOGFILE(,&opt_s) \
- IF_FEATURE_ROTATE_LOGFILE(,&opt_b) \
- IF_FEATURE_REMOTE_LOG( ,&remoteAddrList) \
- IF_FEATURE_IPC_SYSLOG( ,&opt_C) \
- IF_FEATURE_SYSLOGD_CFG( ,&opt_f)
- #if ENABLE_FEATURE_SYSLOGD_CFG
- static const CODE* find_by_name(char *name, const CODE* c_set)
- {
- for (; c_set->c_name; c_set++) {
- if (strcmp(name, c_set->c_name) == 0)
- return c_set;
- }
- return NULL;
- }
- #endif
- static const CODE* find_by_val(int val, const CODE* c_set)
- {
- for (; c_set->c_name; c_set++) {
- if (c_set->c_val == val)
- return c_set;
- }
- return NULL;
- }
- #if ENABLE_FEATURE_SYSLOGD_CFG
- static void parse_syslogdcfg(const char *file)
- {
- char *t;
- logRule_t **pp_rule;
-
-
-
- char *tok[3];
- parser_t *parser;
- parser = config_open2(file ? file : "/etc/syslog.conf",
- file ? xfopen_for_read : fopen_for_read);
- if (!parser)
-
-
- return;
-
- pp_rule = &G.log_rules;
-
- while (config_read(parser, tok, 3, 2, "# \t", PARSE_NORMAL | PARSE_MIN_DIE)) {
- char *cur_selector;
- logRule_t *cur_rule;
-
- if (tok[2])
- goto cfgerr;
- cur_rule = *pp_rule = xzalloc(sizeof(*cur_rule));
- cur_selector = tok[0];
-
- do {
- const CODE *code;
- char *next_selector;
- uint8_t negated_prio;
- uint8_t single_prio;
- uint32_t facmap;
- uint8_t primap;
- unsigned i;
- next_selector = strchr(cur_selector, ';');
- if (next_selector)
- *next_selector++ = '\0';
- t = strchr(cur_selector, '.');
- if (!t)
- goto cfgerr;
- *t++ = '\0';
- negated_prio = 0;
- single_prio = 0;
- if (*t == '!') {
- negated_prio = 1;
- ++t;
- }
- if (*t == '=') {
- single_prio = 1;
- ++t;
- }
-
- if (*t == '*')
- primap = 0xff;
- else {
- uint8_t priority;
- code = find_by_name(t, prioritynames);
- if (!code)
- goto cfgerr;
- primap = 0;
- priority = code->c_val;
- if (priority == INTERNAL_NOPRI) {
-
- negated_prio = 1;
- } else {
- priority = 1 << priority;
- do {
- primap |= priority;
- if (single_prio)
- break;
- priority >>= 1;
- } while (priority);
- if (negated_prio)
- primap = ~primap;
- }
- }
-
- if (*cur_selector == '*')
- facmap = (1<<LOG_NFACILITIES) - 1;
- else {
- char *next_facility;
- facmap = 0;
- t = cur_selector;
-
- do {
- next_facility = strchr(t, ',');
- if (next_facility)
- *next_facility++ = '\0';
- code = find_by_name(t, facilitynames);
- if (!code)
- goto cfgerr;
-
- if (code->c_val != INTERNAL_MARK)
- facmap |= 1<<(LOG_FAC(code->c_val));
- t = next_facility;
- } while (t);
- }
-
- for (i = 0; i < LOG_NFACILITIES; ++i) {
- if (!(facmap & (1<<i)))
- continue;
- if (negated_prio)
- cur_rule->enabled_facility_priomap[i] &= primap;
- else
- cur_rule->enabled_facility_priomap[i] |= primap;
- }
- cur_selector = next_selector;
- } while (cur_selector);
-
- if (strcmp(G.logFile.path, tok[1]) == 0) {
- cur_rule->file = &G.logFile;
- goto found;
- }
-
- for (cur_rule = G.log_rules; cur_rule != *pp_rule; cur_rule = cur_rule->next) {
- if (strcmp(cur_rule->file->path, tok[1]) == 0) {
-
- (*pp_rule)->file = cur_rule->file;
- cur_rule = *pp_rule;
- goto found;
- }
- }
- cur_rule->file = xzalloc(sizeof(*cur_rule->file));
- cur_rule->file->fd = -1;
- cur_rule->file->path = xstrdup(tok[1]);
- found:
- pp_rule = &cur_rule->next;
- }
- config_close(parser);
- return;
- cfgerr:
- bb_error_msg_and_die("error in '%s' at line %d", file, parser->lineno);
- }
- #endif
- #if ENABLE_FEATURE_IPC_SYSLOG
- #if CONFIG_FEATURE_IPC_SYSLOG_BUFFER_SIZE < 4
- #error Sorry, you must set the syslogd buffer size to at least 4KB.
- #error Please check CONFIG_FEATURE_IPC_SYSLOG_BUFFER_SIZE
- #endif
- enum { KEY_ID = 0x414e4547 };
- static void ipcsyslog_cleanup(void)
- {
- if (G.shmid != -1) {
- shmdt(G.shbuf);
- }
- if (G.shmid != -1) {
- shmctl(G.shmid, IPC_RMID, NULL);
- }
- if (G.s_semid != -1) {
- semctl(G.s_semid, 0, IPC_RMID, 0);
- }
- }
- static void ipcsyslog_init(void)
- {
- if (DEBUG)
- printf("shmget(%x, %d,...)\n", (int)KEY_ID, G.shm_size);
- G.shmid = shmget(KEY_ID, G.shm_size, IPC_CREAT | 0644);
- if (G.shmid == -1) {
- bb_perror_msg_and_die("shmget");
- }
- G.shbuf = shmat(G.shmid, NULL, 0);
- if (G.shbuf == (void*) -1L) {
- bb_perror_msg_and_die("shmat");
- }
- memset(G.shbuf, 0, G.shm_size);
- G.shbuf->size = G.shm_size - offsetof(struct shbuf_ds, data) - 1;
-
-
- G.s_semid = semget(KEY_ID, 2, IPC_CREAT | IPC_EXCL | 1023);
- if (G.s_semid == -1) {
- if (errno == EEXIST) {
- G.s_semid = semget(KEY_ID, 2, 0);
- if (G.s_semid != -1)
- return;
- }
- bb_perror_msg_and_die("semget");
- }
- }
- static void log_to_shmem(const char *msg)
- {
- int old_tail, new_tail;
- int len;
- if (semop(G.s_semid, G.SMwdn, 3) == -1) {
- bb_perror_msg_and_die("SMwdn");
- }
-
- len = strlen(msg) + 1;
- again:
- old_tail = G.shbuf->tail;
- new_tail = old_tail + len;
- if (new_tail < G.shbuf->size) {
-
- memcpy(G.shbuf->data + old_tail, msg, len);
- G.shbuf->tail = new_tail;
- } else {
-
- int k = G.shbuf->size - old_tail;
-
- memcpy(G.shbuf->data + old_tail, msg, k);
- msg += k;
- len -= k;
- G.shbuf->tail = 0;
- goto again;
- }
- if (semop(G.s_semid, G.SMwup, 1) == -1) {
- bb_perror_msg_and_die("SMwup");
- }
- if (DEBUG)
- printf("tail:%d\n", G.shbuf->tail);
- }
- #else
- void ipcsyslog_cleanup(void);
- void ipcsyslog_init(void);
- void log_to_shmem(const char *msg);
- #endif
- static void log_locally(time_t now, char *msg, logFile_t *log_file)
- {
- #ifdef SYSLOGD_WRLOCK
- struct flock fl;
- #endif
- int len = strlen(msg);
- if (log_file->fd >= 0) {
-
- if (!now)
- now = time(NULL);
- if (G.last_log_time != now) {
- G.last_log_time = now;
- close(log_file->fd);
- goto reopen;
- }
- } else {
- reopen:
- log_file->fd = open(log_file->path, O_WRONLY | O_CREAT
- | O_NOCTTY | O_APPEND | O_NONBLOCK,
- 0666);
- if (log_file->fd < 0) {
-
- int fd = device_open(DEV_CONSOLE, O_WRONLY | O_NOCTTY | O_NONBLOCK);
- if (fd < 0)
- fd = 2;
- full_write(fd, msg, len);
- if (fd != 2)
- close(fd);
- return;
- }
- #if ENABLE_FEATURE_ROTATE_LOGFILE
- {
- struct stat statf;
- log_file->isRegular = (fstat(log_file->fd, &statf) == 0 && S_ISREG(statf.st_mode));
-
- log_file->size = statf.st_size;
- }
- #endif
- }
- #ifdef SYSLOGD_WRLOCK
- fl.l_whence = SEEK_SET;
- fl.l_start = 0;
- fl.l_len = 1;
- fl.l_type = F_WRLCK;
- fcntl(log_file->fd, F_SETLKW, &fl);
- #endif
- #if ENABLE_FEATURE_ROTATE_LOGFILE
- if (G.logFileSize && log_file->isRegular && log_file->size > G.logFileSize) {
- if (G.logFileRotate) {
- int i = strlen(log_file->path) + 3 + 1;
- char oldFile[i];
- char newFile[i];
- i = G.logFileRotate - 1;
-
- while (1) {
- sprintf(newFile, "%s.%d", log_file->path, i);
- if (i == 0) break;
- sprintf(oldFile, "%s.%d", log_file->path, --i);
-
- rename(oldFile, newFile);
- }
-
- rename(log_file->path, newFile);
-
- unlink(log_file->path);
- #ifdef SYSLOGD_WRLOCK
- fl.l_type = F_UNLCK;
- fcntl(log_file->fd, F_SETLKW, &fl);
- #endif
- close(log_file->fd);
- goto reopen;
- }
- ftruncate(log_file->fd, 0);
- }
- log_file->size +=
- #endif
- full_write(log_file->fd, msg, len);
- #ifdef SYSLOGD_WRLOCK
- fl.l_type = F_UNLCK;
- fcntl(log_file->fd, F_SETLKW, &fl);
- #endif
- }
- static void parse_fac_prio_20(int pri, char *res20)
- {
- const CODE *c_pri, *c_fac;
- c_fac = find_by_val(LOG_FAC(pri) << 3, facilitynames);
- if (c_fac) {
- c_pri = find_by_val(LOG_PRI(pri), prioritynames);
- if (c_pri) {
- snprintf(res20, 20, "%s.%s", c_fac->c_name, c_pri->c_name);
- return;
- }
- }
- snprintf(res20, 20, "<%d>", pri);
- }
- static void timestamp_and_log(int pri, char *msg, int len)
- {
- char *timestamp;
- time_t now;
-
-
- if (len < 16 || msg[3] != ' ' || msg[6] != ' '
- || msg[9] != ':' || msg[12] != ':' || msg[15] != ' '
- ) {
- time(&now);
- timestamp = ctime(&now) + 4;
- } else {
- now = 0;
- timestamp = msg;
- msg += 16;
- }
- timestamp[15] = '\0';
- if (option_mask32 & OPT_small)
- sprintf(G.printbuf, "%s %s\n", timestamp, msg);
- else {
- char res[20];
- parse_fac_prio_20(pri, res);
- sprintf(G.printbuf, "%s %.64s %s %s\n", timestamp, G.hostname, res, msg);
- }
-
- #if ENABLE_FEATURE_SYSLOGD_CFG
- {
- bool match = 0;
- logRule_t *rule;
- uint8_t facility = LOG_FAC(pri);
- uint8_t prio_bit = 1 << LOG_PRI(pri);
- for (rule = G.log_rules; rule; rule = rule->next) {
- if (rule->enabled_facility_priomap[facility] & prio_bit) {
- log_locally(now, G.printbuf, rule->file);
- match = 1;
- }
- }
- if (match)
- return;
- }
- #endif
- if (LOG_PRI(pri) < G.logLevel) {
- #if ENABLE_FEATURE_IPC_SYSLOG
- if ((option_mask32 & OPT_circularlog) && G.shbuf) {
- log_to_shmem(G.printbuf);
- return;
- }
- #endif
- log_locally(now, G.printbuf, &G.logFile);
- }
- }
- static void timestamp_and_log_internal(const char *msg)
- {
-
- if (ENABLE_FEATURE_REMOTE_LOG && !(option_mask32 & OPT_locallog))
- return;
- timestamp_and_log(LOG_SYSLOG | LOG_INFO, (char*)msg, 0);
- }
- static void split_escape_and_log(char *tmpbuf, int len)
- {
- char *p = tmpbuf;
- tmpbuf += len;
- while (p < tmpbuf) {
- char c;
- char *q = G.parsebuf;
- int pri = (LOG_USER | LOG_NOTICE);
- if (*p == '<') {
-
- pri = bb_strtou(p + 1, &p, 10);
- if (*p == '>')
- p++;
- if (pri & ~(LOG_FACMASK | LOG_PRIMASK))
- pri = (LOG_USER | LOG_NOTICE);
- }
- while ((c = *p++)) {
- if (c == '\n')
- c = ' ';
- if (!(c & ~0x1f) && c != '\t') {
- *q++ = '^';
- c += '@';
- }
- *q++ = c;
- }
- *q = '\0';
-
- timestamp_and_log(pri, G.parsebuf, q - G.parsebuf);
- }
- }
- #ifdef SYSLOGD_MARK
- static void do_mark(int sig)
- {
- if (G.markInterval) {
- timestamp_and_log_internal("-- MARK --");
- alarm(G.markInterval);
- }
- }
- #endif
- static NOINLINE int create_socket(void)
- {
- struct sockaddr_un sunx;
- int sock_fd;
- char *dev_log_name;
- #if ENABLE_FEATURE_SYSTEMD
- if (sd_listen_fds() == 1)
- return SD_LISTEN_FDS_START;
- #endif
- memset(&sunx, 0, sizeof(sunx));
- sunx.sun_family = AF_UNIX;
-
-
- strcpy(sunx.sun_path, "/dev/log");
- dev_log_name = xmalloc_follow_symlinks("/dev/log");
- if (dev_log_name) {
- safe_strncpy(sunx.sun_path, dev_log_name, sizeof(sunx.sun_path));
- free(dev_log_name);
- }
- unlink(sunx.sun_path);
- sock_fd = xsocket(AF_UNIX, SOCK_DGRAM, 0);
- xbind(sock_fd, (struct sockaddr *) &sunx, sizeof(sunx));
- chmod("/dev/log", 0666);
- return sock_fd;
- }
- #if ENABLE_FEATURE_REMOTE_LOG
- static int try_to_resolve_remote(remoteHost_t *rh)
- {
- if (!rh->remoteAddr) {
- unsigned now = monotonic_sec();
-
- if ((now - rh->last_dns_resolve) < DNS_WAIT_SEC)
- return -1;
- rh->last_dns_resolve = now;
- rh->remoteAddr = host2sockaddr(rh->remoteHostname, 514);
- if (!rh->remoteAddr)
- return -1;
- }
- return xsocket(rh->remoteAddr->u.sa.sa_family, SOCK_DGRAM, 0);
- }
- #endif
- static void do_syslogd(void) NORETURN;
- static void do_syslogd(void)
- {
- int sock_fd;
- #if ENABLE_FEATURE_REMOTE_LOG
- llist_t *item;
- #endif
- #if ENABLE_FEATURE_SYSLOGD_DUP
- int last_sz = -1;
- char *last_buf;
- char *recvbuf = G.recvbuf;
- #else
- #define recvbuf (G.recvbuf)
- #endif
-
- signal_no_SA_RESTART_empty_mask(SIGTERM, record_signo);
- signal_no_SA_RESTART_empty_mask(SIGINT, record_signo);
-
- signal(SIGHUP, SIG_IGN);
- #ifdef SYSLOGD_MARK
- signal(SIGALRM, do_mark);
- alarm(G.markInterval);
- #endif
- sock_fd = create_socket();
- if (ENABLE_FEATURE_IPC_SYSLOG && (option_mask32 & OPT_circularlog)) {
- ipcsyslog_init();
- }
- timestamp_and_log_internal("syslogd started: BusyBox v" BB_VER);
- while (!bb_got_signal) {
- ssize_t sz;
- #if ENABLE_FEATURE_SYSLOGD_DUP
- last_buf = recvbuf;
- if (recvbuf == G.recvbuf)
- recvbuf = G.recvbuf + MAX_READ;
- else
- recvbuf = G.recvbuf;
- #endif
- read_again:
- sz = read(sock_fd, recvbuf, MAX_READ - 1);
- if (sz < 0) {
- if (!bb_got_signal)
- bb_perror_msg("read from /dev/log");
- break;
- }
-
- while (1) {
- if (sz == 0)
- goto read_again;
-
- if (recvbuf[sz-1] != '\0' && recvbuf[sz-1] != '\n')
- break;
- sz--;
- }
- #if ENABLE_FEATURE_SYSLOGD_DUP
- if ((option_mask32 & OPT_dup) && (sz == last_sz))
- if (memcmp(last_buf, recvbuf, sz) == 0)
- continue;
- last_sz = sz;
- #endif
- #if ENABLE_FEATURE_REMOTE_LOG
-
- recvbuf[sz] = '\n';
-
-
- for (item = G.remoteHosts; item != NULL; item = item->link) {
- remoteHost_t *rh = (remoteHost_t *)item->data;
- if (rh->remoteFD == -1) {
- rh->remoteFD = try_to_resolve_remote(rh);
- if (rh->remoteFD == -1)
- continue;
- }
-
- if (sendto(rh->remoteFD, recvbuf, sz+1,
- MSG_DONTWAIT | MSG_NOSIGNAL,
- &(rh->remoteAddr->u.sa), rh->remoteAddr->len) == -1
- ) {
- switch (errno) {
- case ECONNRESET:
- case ENOTCONN:
- case EPIPE:
- close(rh->remoteFD);
- rh->remoteFD = -1;
- free(rh->remoteAddr);
- rh->remoteAddr = NULL;
- }
- }
- }
- #endif
- if (!ENABLE_FEATURE_REMOTE_LOG || (option_mask32 & OPT_locallog)) {
- recvbuf[sz] = '\0';
- split_escape_and_log(recvbuf, sz);
- }
- }
- timestamp_and_log_internal("syslogd exiting");
- puts("syslogd exiting");
- if (ENABLE_FEATURE_IPC_SYSLOG)
- ipcsyslog_cleanup();
- kill_myself_with_sig(bb_got_signal);
- #undef recvbuf
- }
- int syslogd_main(int argc, char **argv) MAIN_EXTERNALLY_VISIBLE;
- int syslogd_main(int argc UNUSED_PARAM, char **argv)
- {
- int opts;
- char OPTION_DECL;
- #if ENABLE_FEATURE_REMOTE_LOG
- llist_t *remoteAddrList = NULL;
- #endif
- INIT_G();
-
- opt_complementary = "=0" IF_FEATURE_REMOTE_LOG(":R::");
- opts = getopt32(argv, OPTION_STR, OPTION_PARAM);
- #if ENABLE_FEATURE_REMOTE_LOG
- while (remoteAddrList) {
- remoteHost_t *rh = xzalloc(sizeof(*rh));
- rh->remoteHostname = llist_pop(&remoteAddrList);
- rh->remoteFD = -1;
- rh->last_dns_resolve = monotonic_sec() - DNS_WAIT_SEC - 1;
- llist_add_to(&G.remoteHosts, rh);
- }
- #endif
- #ifdef SYSLOGD_MARK
- if (opts & OPT_mark)
- G.markInterval = xatou_range(opt_m, 0, INT_MAX/60) * 60;
- #endif
-
-
- if (opts & OPT_loglevel)
- G.logLevel = xatou_range(opt_l, 1, 8);
-
- #if ENABLE_FEATURE_ROTATE_LOGFILE
- if (opts & OPT_filesize)
- G.logFileSize = xatou_range(opt_s, 0, INT_MAX/1024) * 1024;
- if (opts & OPT_rotatecnt)
- G.logFileRotate = xatou_range(opt_b, 0, 99);
- #endif
- #if ENABLE_FEATURE_IPC_SYSLOG
- if (opt_C)
- G.shm_size = xatoul_range(opt_C, 4, INT_MAX/1024) * 1024;
- #endif
-
- if (ENABLE_FEATURE_REMOTE_LOG && !(opts & OPT_remotelog))
- option_mask32 |= OPT_locallog;
- #if ENABLE_FEATURE_SYSLOGD_CFG
- parse_syslogdcfg(opt_f);
- #endif
-
- G.hostname = safe_gethostname();
- *strchrnul(G.hostname, '.') = '\0';
- if (!(opts & OPT_nofork)) {
- bb_daemonize_or_rexec(DAEMON_CHDIR_ROOT, argv);
- }
-
- write_pidfile("/var/run/syslogd.pid");
- do_syslogd();
-
- }
- #undef DEBUG
- #undef SYSLOGD_MARK
- #undef SYSLOGD_WRLOCK
- #undef G
- #undef GLOBALS
- #undef INIT_G
- #undef OPTION_STR
- #undef OPTION_DECL
- #undef OPTION_PARAM
|