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

pageserver: fix records_committed metric

Browse Source
This commit is contained in:
John Spray
2023-12-19 17:09:12 +00:00
parent da2f4879bf
commit 22c0351c20
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pageserver/src/import_datadir.rs
+5
View File
@@ -21,6 +21,7 @@ use tracing::*;
use walkdir::WalkDir;
use crate::context::RequestContext;
use crate::metrics::WAL_INGEST;
use crate::pgdatadir_mapping::*;
use crate::tenant::remote_timeline_client::INITDB_PATH;
use crate::tenant::Timeline;
@@ -319,7 +320,10 @@ async fn import_wal(
walingest
.ingest_record(recdata, lsn, &mut modification, &mut decoded, ctx)
.await?;
modification.commit(ctx).await?;
WAL_INGEST.records_committed.inc();
last_lsn = lsn;
nrecords += 1;
@@ -457,6 +461,7 @@ pub async fn import_wal_from_tar(
.ingest_record(recdata, lsn, &mut modification, &mut decoded, ctx)
.await?;
modification.commit(ctx).await?;
WAL_INGEST.records_committed.inc();
last_lsn = lsn;
debug!("imported record at {} (end {})", lsn, end_lsn);