emo/busybox
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

svlogd: batch writes if !timestamp

Browse Source
This commit is contained in:
Denis Vlasenko 2007-01-27 23:15:50 +00:00
parent ca549c5e69
commit eeafc1a057
1 changed files with 29 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
runit/svlogd.c
View File

@ -55,7 +55,7 @@ static const char *replace = "";
static char repl; static char repl;
static struct logdir { static struct logdir {
////char *btmp; //// char *btmp;
/* pattern list to match, in "aa\0bb\0\cc\0\0" form */ /* pattern list to match, in "aa\0bb\0\cc\0\0" form */
char *inst; char *inst;
char *processor; char *processor;
@ -732,6 +732,7 @@ int svlogd_main(int argc, char **argv)
int i; int i;
unsigned opt; unsigned opt;
unsigned timestamp = 0; unsigned timestamp = 0;
void* (*memRchr)(const void *, int, size_t) = memchr;
#define line bb_common_bufsiz1 #define line bb_common_bufsiz1
@ -748,10 +749,10 @@ int svlogd_main(int argc, char **argv)
if (linemax == 0) linemax = BUFSIZ-26; if (linemax == 0) linemax = BUFSIZ-26;
if (linemax < 256) linemax = 256; if (linemax < 256) linemax = 256;
} }
if (opt & 8) { // -b //// if (opt & 8) { // -b
////buflen = xatoi_u(b); //// buflen = xatoi_u(b);
////if (buflen == 0) buflen = 1024; //// if (buflen == 0) buflen = 1024;
} //// }
//if (opt & 0x10) timestamp++; // -t //if (opt & 0x10) timestamp++; // -t
//if (opt & 0x20) verbose++; // -v //if (opt & 0x20) verbose++; // -v
//if (timestamp > 2) timestamp = 2; //if (timestamp > 2) timestamp = 2;
@ -789,7 +790,13 @@ int svlogd_main(int argc, char **argv)
logdirs_reopen(); logdirs_reopen();
/* Each iteration processes one line */ /* Without timestamps, we don't have to print each line
* separately, so we can look for _last_ newline, not first,
* thus batching writes */
if (!timestamp)
memRchr = memrchr;
/* Each iteration processes one line or more lines */
while (1) { while (1) {
char stamp[FMT_PTIME]; char stamp[FMT_PTIME];
char *lineptr; char *lineptr;
@ -817,15 +824,17 @@ int svlogd_main(int argc, char **argv)
/* (possibly has some unprocessed data from prev loop) */ /* (possibly has some unprocessed data from prev loop) */
/* Refill the buffer if needed */ /* Refill the buffer if needed */
np = memchr(lineptr, '\n', stdin_cnt); np = memRchr(lineptr, '\n', stdin_cnt);
i = linemax - stdin_cnt; /* avail. bytes at tail */ if (!np && !exitasap) {
if (i >= 128 && !exitasap && !np) { i = linemax - stdin_cnt; /* avail. bytes at tail */
int sz = buffer_pread(0, lineptr + stdin_cnt, i); if (i >= 128) {
if (sz <= 0) /* EOF or error on stdin */ i = buffer_pread(0, lineptr + stdin_cnt, i);
exitasap = 1; if (i <= 0) /* EOF or error on stdin */
else { exitasap = 1;
np = memchr(lineptr + stdin_cnt, '\n', sz); else {
stdin_cnt += sz; np = memRchr(lineptr + stdin_cnt, '\n', i);
stdin_cnt += i;
}
} }
} }
if (stdin_cnt <= 0 && exitasap) if (stdin_cnt <= 0 && exitasap)
@ -874,8 +883,9 @@ int svlogd_main(int argc, char **argv)
stdin_cnt = 1; stdin_cnt = 1;
} else { } else {
linelen = stdin_cnt; linelen = stdin_cnt;
np = memchr(lineptr, '\n', stdin_cnt); np = memRchr(lineptr, '\n', stdin_cnt);
if (np) linelen = np - lineptr + 1; if (np)
linelen = np - lineptr + 1;
ch = lineptr[linelen-1]; ch = lineptr[linelen-1];
} }
/* linelen == no of chars incl. '\n' (or == stdin_cnt) */ /* linelen == no of chars incl. '\n' (or == stdin_cnt) */
@ -893,7 +903,7 @@ int svlogd_main(int argc, char **argv)
lineptr += linelen; lineptr += linelen;
/* If we see another '\n', we don't need to read /* If we see another '\n', we don't need to read
* next piece of input: can print what we have */ * next piece of input: can print what we have */
np = memchr(lineptr, '\n', stdin_cnt); np = memRchr(lineptr, '\n', stdin_cnt);
if (np) if (np)
goto print_to_nl; goto print_to_nl;
/* Move unprocessed data to the front of line */ /* Move unprocessed data to the front of line */
@ -907,5 +917,5 @@ int svlogd_main(int argc, char **argv)
/* repeat */; /* repeat */;
logdir_close(&dir[i]); logdir_close(&dir[i]);
} }
_exit(0); return 0;
} }