Add explicit append and truncate reopen helpers

This commit is contained in:
Nanaloveyuki
2026-05-10 12:55:02 +08:00
parent c779befc23
commit 1a9dfe2397
8 changed files with 62 additions and 19 deletions
+9 -4
View File
@@ -166,19 +166,21 @@ test "file sink reopen and failure counters reflect backend state" {
inspect(sink.append_mode(), content="true")
inspect(sink.open_failures(), content="0")
inspect(sink.close(), content="true")
inspect(sink.reopen(), content="true")
inspect(sink.reopen_append(), content="true")
inspect(sink.is_available(), content="true")
inspect(sink.append_mode(), content="true")
inspect(sink.open_failures(), content="0")
sink.write(record(Level::Info, "reopened"))
inspect(sink.write_failures(), content="0")
inspect(sink.flush_failures(), content="0")
inspect(sink.reopen(append=Some(false)), content="true")
inspect(sink.reopen_truncate(), content="true")
inspect(sink.append_mode(), content="false")
inspect(sink.reopen(), content="true")
inspect(sink.append_mode(), content="false")
inspect(sink.reopen_with_current_policy(), content="true")
inspect(sink.append_mode(), content="false")
inspect(sink.reopen_append(), content="true")
inspect(sink.append_mode(), content="true")
inspect(sink.close(), content="true")
ignore(remove_file_internal("bitlogger-reopen.log"))
} else {
@@ -186,13 +188,16 @@ test "file sink reopen and failure counters reflect backend state" {
inspect(sink.open_failures(), content="1")
sink.write(record(Level::Info, "dropped"))
inspect(sink.write_failures(), content="1")
inspect(sink.reopen(), content="false")
inspect(sink.reopen_append(), content="false")
inspect(sink.open_failures(), content="2")
inspect(sink.flush_failures(), content="0")
inspect(sink.reopen(append=Some(false)), content="false")
inspect(sink.reopen_truncate(), content="false")
inspect(sink.append_mode(), content="false")
inspect(sink.reopen_with_current_policy(), content="false")
inspect(sink.open_failures(), content="3")
inspect(sink.reopen_append(), content="false")
inspect(sink.append_mode(), content="true")
inspect(sink.open_failures(), content="4")
}
}