From a4256b325032ccb42e1b4e4b2876295b0dde31ca Mon Sep 17 00:00:00 2001 From: Christian Schwarz Date: Wed, 8 Feb 2023 17:50:22 +0100 Subject: [PATCH] allow on-demand downloads in walreceiver connection handler Without this patch, basebackup fails if we evict all layers before that. This slipped in as part of commit 01b4b0c2f3731f16f4b9b1cfcb5e7937c76df989 Author: Christian Schwarz Date: Fri Jan 13 17:02:22 2023 +0100 Introduce RequestContext --- .../src/tenant/timeline/walreceiver/connection_manager.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pageserver/src/tenant/timeline/walreceiver/connection_manager.rs b/pageserver/src/tenant/timeline/walreceiver/connection_manager.rs index cd7c7c51d2..64a79b6d1b 100644 --- a/pageserver/src/tenant/timeline/walreceiver/connection_manager.rs +++ b/pageserver/src/tenant/timeline/walreceiver/connection_manager.rs @@ -13,7 +13,7 @@ use std::{collections::HashMap, num::NonZeroU64, ops::ControlFlow, sync::Arc, ti use super::TaskStateUpdate; use crate::broker_client::get_broker_client; -use crate::context::RequestContext; +use crate::context::{DownloadBehavior, RequestContext}; use crate::task_mgr::WALRECEIVER_RUNTIME; use crate::task_mgr::{self, TaskKind}; use crate::tenant::Timeline; @@ -413,7 +413,7 @@ impl WalreceiverState { let timeline = Arc::clone(&self.timeline); let ctx = ctx.detached_child( TaskKind::WalReceiverConnectionHandler, - ctx.download_behavior(), + DownloadBehavior::Download, ); let connection_handle = TaskHandle::spawn(move |events_sender, cancellation| { async move {