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

review: rename to commit LSN to commit_lsn

Browse Source
This commit is contained in:
Vlad Lazar
2024-11-18 12:06:12 +01:00
parent dc220e3f18
commit 1c8f4938cb
4 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
libs/pq_proto/src/lib.rs
View File

@@ -680,7 +680,7 @@ pub struct InterpretedWalRecordsBody<'a> {
/// End of raw WAL in [`Self::data`]
pub streaming_lsn: u64,
/// Current end of WAL on the server
pub safekeeper_wal_end_lsn: u64,
pub commit_lsn: u64,
/// Start LSN of the next record in PG WAL.
/// Is 0 if the portion of PG WAL did not contain any records.
pub next_record_lsn: u64,
@@ -1020,7 +1020,7 @@ impl BeMessage<'_> {
buf.put_u8(b'0'); // matches INTERPRETED_WAL_RECORD_TAG in postgres-protocol
// dependency
buf.put_u64(rec.streaming_lsn);
buf.put_u64(rec.safekeeper_wal_end_lsn);
buf.put_u64(rec.commit_lsn);
buf.put_u64(rec.next_record_lsn);
buf.put_slice(rec.data);
});

2
pageserver/src/tenant/timeline/walreceiver/walreceiver_connection.rs
View File

@@ -297,7 +297,7 @@ pub(super) async fn handle_walreceiver_connection(
connection_status.latest_wal_update = now;
}
connection_status.commit_lsn = Some(Lsn::from(raw.wal_end()));
connection_status.commit_lsn = Some(Lsn::from(raw.commit_lsn()));
connection_status.streaming_lsn = Some(Lsn::from(raw.streaming_lsn()));
}
&_ => {}

4
safekeeper/src/send_interpreted_wal.rs
View File

@@ -49,7 +49,7 @@ impl<IO: AsyncRead + AsyncWrite + Unpin> InterpretedWalSender<'_, IO> {
tokio::select! {
// Get some WAL from the stream and then: decode, interpret and send it
wal = stream.next() => {
let WalBytes { wal, wal_start_lsn, wal_end_lsn, available_wal_end_lsn } = match wal {
let WalBytes { wal, wal_start_lsn, wal_end_lsn, commit_lsn } = match wal {
Some(some) => some?,
None => { break; }
};
@@ -92,7 +92,7 @@ impl<IO: AsyncRead + AsyncWrite + Unpin> InterpretedWalSender<'_, IO> {
self.pgb
.write_message(&BeMessage::InterpretedWalRecords(InterpretedWalRecordsBody {
streaming_lsn: wal_end_lsn.0,
safekeeper_wal_end_lsn: available_wal_end_lsn.0,
commit_lsn: commit_lsn.0,
next_record_lsn: max_next_record_lsn.unwrap_or(Lsn::INVALID).0,
data: buf.as_slice(),
})).await?;

4
safekeeper/src/wal_reader_stream.rs
View File

@@ -38,7 +38,7 @@ pub(crate) struct WalBytes {
/// End LSN of [`Self::wal`]
pub(crate) wal_end_lsn: Lsn,
/// End LSN of WAL available on the safekeeper
pub(crate) available_wal_end_lsn: Lsn,
pub(crate) commit_lsn: Lsn,
}
impl WalReaderStreamBuilder {
@@ -135,7 +135,7 @@ impl WalReaderStreamBuilder {
wal,
wal_start_lsn: start_pos,
wal_end_lsn: start_pos + send_size as u64,
available_wal_end_lsn: end_pos
commit_lsn: end_pos
};
start_pos += send_size as u64;