diff options
| author | Jan Tuomi <jan@jantuomi.fi> | 2024-10-05 12:58:35 +0200 |
|---|---|---|
| committer | Jan Tuomi <jan@jantuomi.fi> | 2024-10-05 12:58:35 +0200 |
| commit | 9f59bf5c621d36fb956ea8a8602b0c37ceaadfe6 (patch) | |
| tree | a7f394048919c94fc758c3e683e449f95c47a700 /src/reverse_log_reader.rs | |
| parent | 6532e4f4a94ada35c958cf53e1f98aaf175188c6 (diff) | |
Make write durability configurable
Diffstat (limited to 'src/reverse_log_reader.rs')
| -rw-r--r-- | src/reverse_log_reader.rs | 7 |
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 |
