diff --git a/pageserver/src/basebackup.rs b/pageserver/src/basebackup.rs index 207f781e1b..15c89d3557 100644 --- a/pageserver/src/basebackup.rs +++ b/pageserver/src/basebackup.rs @@ -413,6 +413,10 @@ where let mut content = Vec::with_capacity(n_origins * 16 + 8); content.extend_from_slice(&pg_constants::REPLICATION_STATE_MAGIC.to_le_bytes()); for (origin_id, origin_lsn) in repl_origins { + info!( + "Include origin_id={}, origin_lsn={} in basebackup", + origin_id, origin_lsn + ); content.extend_from_slice(&origin_id.to_le_bytes()); content.extend_from_slice(&[0u8; 6]); // align to 8 bytes content.extend_from_slice(&origin_lsn.0.to_le_bytes()); diff --git a/pageserver/src/walingest.rs b/pageserver/src/walingest.rs index 8425528740..623870c59f 100644 --- a/pageserver/src/walingest.rs +++ b/pageserver/src/walingest.rs @@ -408,11 +408,16 @@ impl WalIngest { let info = decoded.xl_info & pg_constants::XLR_RMGR_INFO_MASK; if info == pg_constants::XLOG_REPLORIGIN_SET { let xlrec = crate::walrecord::XlReploriginSet::decode(&mut buf); + info!( + "Set replication origin_id={}, origin_lsn={}", + xlrec.node_id, xlrec.remote_lsn + ); modification .set_replorigin(xlrec.node_id, xlrec.remote_lsn) .await? } else if info == pg_constants::XLOG_REPLORIGIN_DROP { let xlrec = crate::walrecord::XlReploriginDrop::decode(&mut buf); + info!("Drop replication origin_id={}", xlrec.node_id); modification.drop_replorigin(xlrec.node_id).await? } } @@ -1286,6 +1291,10 @@ impl WalIngest { } } if origin_id != 0 { + info!( + "Commit origin_id={}, origin_lsn={}", + origin_id, parsed.origin_lsn + ); modification .set_replorigin(origin_id, parsed.origin_lsn) .await?;