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

use the same context

Browse Source
This commit is contained in:
Christian Schwarz
2024-11-29 19:18:48 +01:00
parent 61d0c8ea2c
commit 60818dfdc9
1 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
pageserver/src/page_service.rs
View File

@@ -1283,12 +1283,6 @@ impl PageServerHandler {
//
// Batcher
//
let batcher_ctx = ctx.attached_child();
let batcher_ctx_ref = &batcher_ctx;
let executor_ctx = ctx.attached_child();
let executor_ctx_ref = &executor_ctx;
let cancel_batcher = self.cancel.child_token();
let (mut batch_tx, mut batch_rx) = spsc_fold::channel();
let read_messages = pipeline_stage!(
@@ -1305,7 +1299,7 @@ impl PageServerHandler {
timeline_id,
&mut timeline_handles,
&cancel_batcher,
batcher_ctx_ref,
ctx,
request_span.clone(),
)
.await;
@@ -1347,7 +1341,7 @@ impl PageServerHandler {
return Err(e);
}
};
self.pagesteam_handle_batched_message(pgb_writer, batch, &cancel, executor_ctx_ref)
self.pagesteam_handle_batched_message(pgb_writer, batch, &cancel, ctx)
.await?;
}
});