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

cargo fmt

Browse Source
This commit is contained in:
Christian Schwarz
2024-09-14 15:15:31 +00:00
parent 6d73642a93
commit f0668a7a4d
1 changed files with 13 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
pageserver/src/tenant/storage_layer.rs
View File

@@ -118,7 +118,7 @@ pub(crate) async fn convert(
match value {
Value::WalRecord(rec) => {
to.records.push((lsn, rec));
},
}
Value::Image(img) => {
assert!(to.img.is_none());
to.img = Some((lsn, img));
@@ -191,16 +191,19 @@ impl IoConcurrency {
match self {
IoConcurrency::Serial { prev_io } => {
let prev = prev_io.take();
*prev_io = Some((io_id, tokio::spawn(
async move {
if let Some((prev_id, prev_task)) = prev {
debug!(prev_io = prev_id, "Waiting for previous IO to complete");
prev_task.await.unwrap();
*prev_io = Some((
io_id,
tokio::spawn(
async move {
if let Some((prev_id, prev_task)) = prev {
debug!(prev_io = prev_id, "Waiting for previous IO to complete");
prev_task.await.unwrap();
}
fut.await;
}
fut.await;
}
.instrument(span),
)));
.instrument(span),
),
));
}
IoConcurrency::Parallel => {
tokio::spawn(fut);