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

now it produces an image layer

Browse Source
This commit is contained in:
Stas Kelvich
2024-09-12 10:57:50 +01:00
parent daedec65ac
commit 0c856443c4
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
pageserver/src/pg_import.rs
View File

@@ -57,6 +57,8 @@ impl PgImportEnv {
let pgdata_lsn = import_datadir::get_lsn_from_controlfile(&pgdata_path)?.align();
println!("Importing {pgdata_path} to {_tenant_path} as lsn {pgdata_lsn}...");
let range = Key::MIN..Key::NON_L0_MAX;
let mut one_big_layer = ImageLayerWriter::new(
&self.conf,
@@ -102,9 +104,12 @@ impl PgImportEnv {
spcnode: u32,
) -> anyhow::Result<()> {
debug!("Importing database (path={path}, tablespace={spcnode}, dboid={dboid})");
// traverse database directory in the same order as our RelKey ordering
let reldirs = WalkDir::new(path)
.max_depth(1)
.min_depth(1)
.max_depth(2)
.into_iter()
.filter_map(|entry| {
entry.ok().and_then(|path| {
@@ -132,13 +137,16 @@ impl PgImportEnv {
async fn import_rel_file(
&mut self,
layer_writer: &mut ImageLayerWriter,
path: &Utf8PathBuf,
db_path: &Utf8PathBuf,
rel_tag: RelTag,
segno: u32,
) -> anyhow::Result<()> {
let path = db_path.join(rel_tag.relnode.to_string());
let mut reader = tokio::fs::File::open(path).await?;
let len = metadata(path)?.len() as usize;
debug!("Importing relation file (path={path}, rel_tag={rel_tag}, segno={segno})");
let mut reader = tokio::fs::File::open(&path).await?;
let len = metadata(&path)?.len() as usize;
let mut buf: [u8; 8192] = [0u8; 8192];