rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-10-15 16:22:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix writer creation in reconstruct_level0

Browse Source
This commit is contained in:
Konstantin Knizhnik
2022-10-06 10:05:35 +03:00
parent 885033ad42
commit 2359106a9d
1 changed files with 15 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pageserver/src/tenant/timeline.rs
+15 -17
View File
@@ -1538,25 +1538,23 @@ impl Timeline {
let mut last_key: Option<Key> = None;
if let Some(last_delta_layer) = latest_delta_layer {
for (key, lsn, _) in last_delta_layer.key_iter(true) {
match &writer {
Some(curr_writer) => {
if curr_writer.size() > target_file_size {
new_layers.push(writer.take().unwrap().finish(key)?);
writer = None;
}
}
_ => {
// Create writer if not initiaized yet
writer = Some(DeltaLayerWriter::new(
self.conf,
self.timeline_id,
self.tenant_id,
key,
last_delta_layer.get_lsn_range().clone(),
)?);
let value = self.get(key, lsn)?;
if let Some(curr_writer) = &writer {
if curr_writer.size() > target_file_size {
new_layers.push(writer.take().unwrap().finish(key)?);
writer = None;
}
}
let value = self.get(key, lsn)?;
// Create writer if not initiaized yet
if writer.is_none() {
writer = Some(DeltaLayerWriter::new(
self.conf,
self.timeline_id,
self.tenant_id,
key,
last_delta_layer.get_lsn_range().clone(),
)?);
}
writer
.as_mut()
.unwrap()