naloveyuki/BitLogger
1
0
Fork 0
mirror of https://github.com/Nanaloveyuki/BitLogger.git synced 2026-07-30 15:04:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

✅ cover runtime file reopen helpers

Browse Source
This commit is contained in:
Nanaloveyuki
2026-06-14 02:40:35 +08:00
parent fcac1d7993
commit f7863083d4
1 changed files with 101 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/BitLogger_test.mbt
+101
View File
@@ -631,6 +631,107 @@ test "runtime sink queued file helpers preserve queue-aware file runtime state"
} }
} }
test "runtime sink plain file reopen helpers and failure resets work directly" {
let sink = RuntimeSink::File(file_sink("runtime-reopen-direct.log"))
if sink.file_available() {
inspect(sink.close(), content="true")
inspect(sink.file_reopen_append(), content="true")
inspect(sink.file_available(), content="true")
inspect(sink.file_append_mode(), content="true")
inspect(sink.file_open_failures(), content="0")
Logger::new(sink, min_level=Level::Info, target="runtime.reopen.direct").info("reopened")
inspect(sink.file_write_failures(), content="0")
inspect(sink.file_reopen_truncate(), content="true")
inspect(sink.file_append_mode(), content="false")
inspect(sink.file_reopen(), content="true")
inspect(sink.file_append_mode(), content="false")
inspect(sink.file_reopen_with_current_policy(), content="true")
inspect(sink.file_append_mode(), content="false")
inspect(sink.file_reopen_append(), content="true")
inspect(sink.file_append_mode(), content="true")
inspect(sink.file_reset_failure_counters(), content="true")
inspect(sink.file_open_failures(), content="0")
inspect(sink.file_write_failures(), content="0")
inspect(sink.file_flush_failures(), content="0")
inspect(sink.file_rotation_failures(), content="0")
inspect(sink.close(), content="true")
} else {
inspect(sink.file_append_mode(), content="true")
inspect(sink.file_open_failures(), content="1")
Logger::new(sink, min_level=Level::Info, target="runtime.reopen.direct").info("dropped")
inspect(sink.file_write_failures(), content="1")
inspect(sink.file_reopen_append(), content="false")
inspect(sink.file_open_failures(), content="2")
inspect(sink.file_reopen_truncate(), content="false")
inspect(sink.file_append_mode(), content="false")
inspect(sink.file_reopen_with_current_policy(), content="false")
inspect(sink.file_open_failures(), content="4")
inspect(sink.file_reopen_append(), content="false")
inspect(sink.file_append_mode(), content="true")
inspect(sink.file_open_failures(), content="5")
inspect(sink.file_reset_failure_counters(), content="true")
inspect(sink.file_open_failures(), content="0")
inspect(sink.file_write_failures(), content="0")
inspect(sink.file_flush_failures(), content="0")
inspect(sink.file_rotation_failures(), content="0")
}
}
test "runtime sink queued file reopen helpers and failure resets work directly" {
let sink = RuntimeSink::QueuedFile(
queued_sink(file_sink("runtime-reopen-queued.log"), max_pending=2),
)
if sink.file_available() {
inspect(sink.file_close(), content="true")
inspect(sink.file_reopen_append(), content="true")
inspect(sink.file_available(), content="true")
inspect(sink.file_append_mode(), content="true")
inspect(sink.file_open_failures(), content="0")
let logger = Logger::new(sink, min_level=Level::Info, target="runtime.reopen.queued")
logger.info("one")
logger.info("two")
inspect(sink.pending_count(), content="2")
inspect(sink.file_reopen_truncate(), content="true")
inspect(sink.file_append_mode(), content="false")
inspect(sink.file_reopen(), content="true")
inspect(sink.file_append_mode(), content="false")
inspect(sink.file_reopen_with_current_policy(), content="true")
inspect(sink.file_append_mode(), content="false")
inspect(sink.file_reopen_append(), content="true")
inspect(sink.file_append_mode(), content="true")
inspect(sink.file_reset_failure_counters(), content="true")
inspect(sink.file_open_failures(), content="0")
inspect(sink.file_write_failures(), content="0")
inspect(sink.file_flush_failures(), content="0")
inspect(sink.file_rotation_failures(), content="0")
inspect(sink.file_close(), content="true")
} else {
inspect(sink.file_append_mode(), content="true")
inspect(sink.file_open_failures(), content="1")
let logger = Logger::new(sink, min_level=Level::Info, target="runtime.reopen.queued")
logger.info("one")
inspect(sink.pending_count(), content="1")
inspect(sink.file_write_failures(), content="0")
inspect(sink.file_flush(), content="false")
inspect(sink.pending_count(), content="0")
inspect(sink.file_write_failures(), content="1")
inspect(sink.file_reopen_append(), content="false")
inspect(sink.file_open_failures(), content="2")
inspect(sink.file_reopen_truncate(), content="false")
inspect(sink.file_append_mode(), content="false")
inspect(sink.file_reopen_with_current_policy(), content="false")
inspect(sink.file_open_failures(), content="4")
inspect(sink.file_reopen_append(), content="false")
inspect(sink.file_append_mode(), content="true")
inspect(sink.file_open_failures(), content="5")
inspect(sink.file_reset_failure_counters(), content="true")
inspect(sink.file_open_failures(), content="0")
inspect(sink.file_write_failures(), content="0")
inspect(sink.file_flush_failures(), content="0")
inspect(sink.file_rotation_failures(), content="0")
}
}
test "configured logger exposes file sink observability helpers" { test "configured logger exposes file sink observability helpers" {
let logger = build_logger( let logger = build_logger(
LoggerConfig::new( LoggerConfig::new(