aboutsummaryrefslogtreecommitdiffstats
path: root/src/reverse_log_reader.rs
diff options
context:
space:
mode:
authorJan Tuomi <jan@jantuomi.fi>2024-10-05 12:58:35 +0200
committerJan Tuomi <jan@jantuomi.fi>2024-10-05 12:58:35 +0200
commit9f59bf5c621d36fb956ea8a8602b0c37ceaadfe6 (patch)
treea7f394048919c94fc758c3e683e449f95c47a700 /src/reverse_log_reader.rs
parent6532e4f4a94ada35c958cf53e1f98aaf175188c6 (diff)
Make write durability configurable
Diffstat (limited to 'src/reverse_log_reader.rs')
-rw-r--r--src/reverse_log_reader.rs7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/reverse_log_reader.rs b/src/reverse_log_reader.rs
index 778d1b4..d8021ba 100644
--- a/src/reverse_log_reader.rs
+++ b/src/reverse_log_reader.rs
@@ -61,11 +61,12 @@ impl<'a> ReverseLogReader<'a> {
self.consumed_record_sep = false;
let mut result_buf: Vec<u8> = vec![];
+ let mut read_buf = Vec::with_capacity(INTERNAL_BUF_SIZE);
loop {
- let mut read_buf = vec![];
- let _read = self.read_until(ESCAPE_CHARACTER, &mut read_buf)?;
+ read_buf.clear();
+ let read = self.read_until(ESCAPE_CHARACTER, &mut read_buf)?;
- result_buf.extend(&read_buf);
+ result_buf.extend(&read_buf[..read]);
if self.file.stream_position()? == 0 && self.internal_pos == 0 {
// We read until the start of the file, we are done