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

wip: more logs

Browse Source
This commit is contained in:
Vlad Lazar
2025-06-23 13:51:53 +02:00
parent 57edf217b7
commit 74d2d233e4
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pageserver/src/tenant/timeline/walreceiver.rs
View File

@@ -106,11 +106,12 @@ impl WalReceiver {
match loop_step_result {
Ok(()) => continue,
Err(_cancelled) => {
trace!("Connection manager loop ended, shutting down");
info!("Connection manager loop ended, shutting down");
break;
}
}
}
info!("Awaiting connection manager state shutdown ...");
connection_manager_state.shutdown().await;
*loop_status.write().unwrap() = None;
info!("task exits");
@@ -128,7 +129,7 @@ impl WalReceiver {
#[instrument(skip_all, level = tracing::Level::DEBUG)]
pub async fn shutdown(self) {
debug_assert_current_span_has_tenant_and_timeline_id();
debug!("cancelling walreceiver tasks");
info!("cancelling walreceiver tasks");
self.cancel.cancel();
match self.task.await {
Ok(()) => debug!("Shutdown success"),

4
pageserver/src/tenant/timeline/walreceiver/connection_manager.rs
View File

@@ -66,7 +66,7 @@ pub(super) async fn connection_manager_loop_step(
} {
Ok(()) => {}
Err(new_state) => {
debug!(
info!(
?new_state,
"state changed, stopping wal connection manager loop"
);
@@ -145,7 +145,7 @@ pub(super) async fn connection_manager_loop_step(
}
TaskEvent::End(walreceiver_task_result) => {
match walreceiver_task_result {
Ok(()) => debug!("WAL receiving task finished"),
Ok(()) => info!("WAL receiving task finished"),
Err(e) => error!("wal receiver task finished with an error: {e:?}"),
}
connection_manager_state.drop_old_connection(false).await;