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

enable O_DIRECT for delta and image layers

Browse Source 
Signed-off-by: Yuchen Liang <yuchen@neon.tech>
This commit is contained in:
Yuchen Liang
2024-09-27 16:17:27 +00:00
parent ebfe88a463
commit 14ec379d2b
2 changed files with 20 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
pageserver/src/tenant/storage_layer/delta_layer.rs
View File

@@ -62,7 +62,7 @@ use std::collections::VecDeque;
use std::fs::File;
use std::io::SeekFrom;
use std::ops::Range;
use std::os::unix::fs::FileExt;
use std::os::unix::fs::{FileExt, OpenOptionsExt};
use std::str::FromStr;
use std::sync::Arc;
use tokio::sync::OnceCell;
@@ -790,9 +790,15 @@ impl DeltaLayerInner {
max_vectored_read_bytes: Option<MaxVectoredReadBytes>,
ctx: &RequestContext,
) -> anyhow::Result<Self> {
let file = VirtualFile::open(path, ctx)
.await
.context("open layer file")?;
let file = VirtualFile::open_with_options(
path,
virtual_file::OpenOptions::new()
.read(true)
.custom_flags(nix::libc::O_DIRECT),
ctx,
)
.await
.context("open layer file")?;
let file_id = page_cache::next_file_id();

13
pageserver/src/tenant/storage_layer/image_layer.rs
View File

@@ -58,6 +58,7 @@ use std::collections::VecDeque;
use std::fs::File;
use std::io::SeekFrom;
use std::ops::Range;
use std::os::unix::fs::OpenOptionsExt;
use std::os::unix::prelude::FileExt;
use std::str::FromStr;
use tokio::sync::OnceCell;
@@ -389,9 +390,15 @@ impl ImageLayerInner {
max_vectored_read_bytes: Option<MaxVectoredReadBytes>,
ctx: &RequestContext,
) -> anyhow::Result<Self> {
let file = VirtualFile::open(path, ctx)
.await
.context("open layer file")?;
let file = VirtualFile::open_with_options(
path,
virtual_file::OpenOptions::new()
.read(true)
.custom_flags(nix::libc::O_DIRECT),
ctx,
)
.await
.context("open layer file")?;
let file_id = page_cache::next_file_id();
let block_reader = FileBlockReader::new(&file, file_id);
let summary_blk = block_reader