structured JSON logging - #2968
Conversation
|
This pull request has conflicts, please resolve those before we can evaluate the pull request. |
fd254be to
9aa0525
Compare
|
Conflicts have been resolved. |
9aa0525 to
bac2c17
Compare
bac2c17 to
3dab9f0
Compare
|
This pull request has conflicts, please resolve those before we can evaluate the pull request. |
|
Following up on the allocation point from #2897, with more detail on why it matters here.
The schema is six fixed keys, so please emit it directly into a stack buffer. Only // Escape into a caller-supplied buffer so the log path needs no allocation.
// Never splits an escape, so a short buffer truncates to valid JSON.
static size_t json_escape(char *out, const size_t outlen, const char *in)
{
static const char hex[] = "0123456789abcdef";
size_t o = 0;
for(const unsigned char *p = (const unsigned char *)in; *p != '\0'; p++)
{
// Widest form is \u00XX, and every escape starts with a backslash
char esc[6] = { '\\' };
size_t len = 2;
switch(*p)
{
case '"': esc[1] = '"'; break;
case '\\': esc[1] = '\\'; break;
case '\b': esc[1] = 'b'; break;
case '\f': esc[1] = 'f'; break;
case '\n': esc[1] = 'n'; break;
case '\r': esc[1] = 'r'; break;
case '\t': esc[1] = 't'; break;
default:
// Printable and UTF-8 bytes pass through
if(*p >= 0x20)
{
esc[0] = (char)*p;
len = 1;
break;
}
// Other control characters have no short form
esc[1] = 'u';
esc[2] = '0';
esc[3] = '0';
esc[4] = hex[*p >> 4];
esc[5] = hex[*p & 0x0f];
len = 6;
break;
}
// Stop on the last character that fits, keeping room for the NUL
if(o + len >= outlen)
break;
memcpy(out + o, esc, len);
o += len;
}
out[o] = '\0';
return o;
}Valid UTF-8 survives as is. Also, |
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
the embedded dnsmasq already does a fd cleanup on startup, so this is not strictly necessary, but still good practice Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
message Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
The fd == -1 fast path in write_log_line() sat before the reopen_needed check, so SIGUSR2 could not revive a log whose initial open failed: a missing /var/log/pihole or a transient EACCES disabled that log for the lifetime of the process. Move the reopen before the fd test and access both fields only under the lock (flush_dnsmasq_log() reassigns the descriptor under the lock, so the unlocked fast path was racy). Also drop the fd == -1 early return in FTL_write_dnsmasq_log() which would have bypassed the reopen for pihole.log entirely. Code Review: **2. `write_log_line()` can never recover a log whose initial open failed.** The `if(log->fd == -1) return false;` fast path sits before the `reopen_needed` check, so `SIGUSR2` cannot revive it. A missing `/var/log/pihole` at first start, or a transient `EACCES`, disables that log for the lifetime of the process. Testing the reopen flag first fixes it. **Smaller:** `log->fd` is read outside the lock as a fast path while `flush_dnsmasq_log()` reassigns it under the lock Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
strftime("%b %e %H:%M:%S") into a 16 byte buffer overflows in
non-English locales: init_locale() calls setlocale(LC_ALL, ""), so %b
is the localized month abbreviation (six bytes for ru_RU, more
elsewhere). When it does not fit, strftime() returns 0 and leaves the
buffer contents unspecified, so pihole.log gets garbage. Use dnsmasq's
own idiom instead: ctime(&now) + 4 truncated to 15 characters. ctime()
renders the weekday/month in the C locale regardless of the process
locale, so this cannot overflow and keeps the on-disk format
byte-identical to what we write today.
Code Review:
**3. The dnsmasq timestamp buffer is too small for non-English locales.** `char ts_buf[16]` fits `"Jan 1 12:00:00"` exactly in the C locale, but `init_locale()` calls `setlocale(LC_ALL, "")`, so `%b` is the localized abbreviation - six bytes for `ru_RU`, more elsewhere. When it does not fit, `strftime()` returns 0 and leaves the buffer contents *unspecified*, so `pihole.log` gets garbage. dnsmasq itself sidesteps this with `ctime(&time_now) + 4` and `%.15s`, which is locale-independent and keeps the on-disk format byte-identical to what we write today.
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
open_log_fds() warned when webserver.log could not be opened but said nothing for pihole.log. A failed open therefore silently disabled every dnsmasq log line for the lifetime of the process. Add the matching warning so the missing log is visible in FTL.log at startup. Code Review: **4. dnsmasq messages have no fallback left.** `my_syslog()` returns before dnsmasq's own syslog path and `FTL_write_dnsmasq_log()` returns silently when the descriptor is -1, so if `pihole.log` cannot be opened every dnsmasq message is lost. `_FTL_log()` and `_log_web()` both fall back, and `open_log_fds()` warns for `webserver.log` but says nothing for `pihole.log`. Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
dnsmasq forks per TCP query while FTL threads are running. If a fork happens while another thread holds dnsmasq_log.lock, the child inherits it locked and the first my_syslog() there blocks forever, hanging that query. Register pthread_atfork() handlers that take all three per-file mutexes before fork() and release them in both parent and child, so a fork can never observe a locked log mutex. Code Review: **5. The per-file mutex is not fork-safe.** dnsmasq forks per TCP query while our threads are running. If a fork happens while another thread holds `dnsmasq_log.lock`, the child inherits it locked and the first `my_syslog()` there blocks forever, hanging that query. Our SHM lock is process-shared and robust for exactly this reason. Since every write is `O_APPEND`, and a single `write()` to a regular file is atomic, the lock only guards the reopen - `pthread_atfork()` handlers or an atomic descriptor swap would be enough. Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
open_log_fds(false) runs before FTL drops privileges, so a fresh install now gets root-owned webserver.log and pihole.log; dnsmasq used to create pihole.log after dropping to pihole, and webserver.log was created on the first request. FTL_fork_and_bind_sockets() chowned only files.log.ftl. Chown the webserver and dnsmasq log files alongside it when actually dropping from root. Code Review: **6. New root-owned log files.** `open_log_fds(false)` runs before we drop privileges, so a fresh install now gets root-owned `webserver.log` and `pihole.log`; dnsmasq used to create `pihole.log` after dropping to `pihole`, and `webserver.log` was created on the first request. `FTL_fork_and_bind_sockets()` chowns only `files.log.ftl` and should cover the other two. Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
my_syslog() bypasses dnsmasq's own logging path and FTL writes every pihole.log line synchronously through a cached descriptor, so the log-async queue is never populated. Emitting log-async in the generated config is misleading dead configuration. Code Review: **7. `log-async` is now dead code in the generated config.** With `my_syslog()` bypassed, dnsmasq's async queue is never used, so query logging became a blocking `write()` in the DNS thread - which is the stall that queue exists to prevent. Either drop the `log-async` lines or say why the synchronous write is acceptable for us. Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
The rest of the tree is ASCII; replace the em dashes introduced in the recent log comments with plain hyphens. Code Review: **Smaller:** five of the new comments contain em dashes while the rest of the tree is ASCII Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
The clamp that protects the writes into the 2048 byte line buffer ran after off had already been used as an offset into line and as the size argument (sizeof(line) - off would underflow if the first snprintf() ever truncated). Clamp off between the two formatting calls in FTL_write_dnsmasq_log(), _FTL_log() and _log_web(). Code Review: **Smaller:** `off` is used as an offset into `line` before it is clamped Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
The open failure warning is shown regardless of the hide_dnsmasq_warn setting, but the message now notes whether dnsmasq warnings are hidden by it, so the notice reflects the actual behaviour instead of always claiming warnings are relayed to the FTL log. Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
is_log_fd() was incorrectly stripped of __attribute__((pure)) in an earlier review-fix pass. The attribute is correct: pure means no side effects and may depend on global state (unlike const which is a pure function). GCC only caches the result when it can prove the read state hasn't changed, which it cannot for struct members accessed through pointers that other threads may modify. The compiler itself warns suggest-attribute=pure when the attribute is missing, confirming it belongs here. Also fix the ctime_r() return type: use const char* to match the fallback string literal and avoid -Wdiscarded-qualifiers. Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
free(log->path) is called before path has been set on the first invocation, triggering a spurious WARNING from the custom FTLfree() wrapper. Add a NULL check to avoid the noise. Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
3dab9f0 to
af94cf4
Compare
|
Conflicts have been resolved. |
log_to_json() runs on every log line when structured JSON logging is active. The cJSON path allocates an object, two cJSON_strdup()s per field, and cJSON_PrintUnformatted() with its growing buffer - roughly fifteen malloc/free pairs per line. The schema is six fixed keys, so emit it directly into a stack buffer with snprintf(). Only the message field needs JSON escaping; the other five are controlled by the code. A new json_escape() helper writes into a caller-supplied buffer so the log path needs no allocation. Valid UTF-8 passes through unchanged. Also use write(STDOUT_FILENO, ...) instead of printf() to avoid stdio buffering. Code Review: pi-hole#2968 (comment) Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
4db6e76 to
f8bb56e
Compare
|
Three things left.
Small one: the
|
Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
This has already been addressed in f4b1477
Part of #2960 and already addressed in 91c3ed2
Part of #2960 and now addressed in b8c1697 (I have not yet rebased this branch onto that commit)
Do you think injecting |
|
You are right on all three, and my point about One thing on the new On Dropping |
Code review: One thing on the new log_to_json(). escaped_msg and line are both 8192, but line also carries the timestamp, level, component, pid and about 90 bytes of framing, and msg arrives from a json_buffer[8192] where escaping can grow it up to sixfold. A long or escape-heavy message therefore overflows line, and snprintf() cuts it mid-string - no closing quote, no brace, no newline. That is the one outcome the escaper's careful truncation is meant to avoid, so line should be big enough for escaped_msg plus the framing, or truncation should be detected and a shorter valid record emitted instead. pi-hole#2968 (comment) Signed-off-by: darkexplosiveqwx <101737077+darkexplosiveqwx@users.noreply.github.com>
|
This pull request has conflicts, please resolve those before we can evaluate the pull request. |
Thank you for your contribution to the Pi-hole Community!
Please read the comments below to help us consider your Pull Request.
We are all volunteers and completing the process outlined will help us review your commits quicker.
Please make sure you
What does this PR aim to accomplish?:
Builds upon #2958 and #2960
Discussed in #2897
Todo: possibly upstream the don't redirect stdout patch to dnsmasq
How does this PR accomplish the above?:
Link documentation PRs if any are needed to support this PR:
By submitting this pull request, I confirm the following:
git rebase)