LCOV - code coverage report
Current view: top level - pageserver/src - page_service.rs (source / functions) Coverage Total Hit
Test: 4f58e98c51285c7fa348e0b410c88a10caf68ad2.info Lines: 25.6 % 1108 284
Test Date: 2025-01-07 20:58:07 Functions: 7.3 % 109 8

Function Name Sort by function name Hit count Sort by function hit count
<alloc::sync::Arc<pageserver::tenant::timeline::Timeline> as pageserver::tenant::timeline::handle::ArcTimeline<pageserver::page_service::TenantManagerTypes>>::gate 0
<alloc::sync::Arc<pageserver::tenant::timeline::Timeline> as pageserver::tenant::timeline::handle::ArcTimeline<pageserver::page_service::TenantManagerTypes>>::get_shard_identity 0
<alloc::sync::Arc<pageserver::tenant::timeline::Timeline> as pageserver::tenant::timeline::handle::ArcTimeline<pageserver::page_service::TenantManagerTypes>>::per_timeline_state 0
<alloc::sync::Arc<pageserver::tenant::timeline::Timeline> as pageserver::tenant::timeline::handle::ArcTimeline<pageserver::page_service::TenantManagerTypes>>::shard_timeline_id 0
<pageserver::page_service::BaseBackupCmd>::parse::{closure#0} 0
<pageserver::page_service::BaseBackupCmd>::parse::{closure#1} 0
<pageserver::page_service::BaseBackupCmd>::parse::{closure#2} 0
<pageserver::page_service::BatchedFeMessage>::throttle_and_record_start_processing 0
<pageserver::page_service::BatchedFeMessage>::throttle_and_record_start_processing::{closure#0} 0
<pageserver::page_service::BatchedFeMessage>::throttle_and_record_start_processing::{closure#0}::{closure#0} 0
<pageserver::page_service::Connections>::handle_connection_completion 0
<pageserver::page_service::Connections>::shutdown 0
::shutdown 0
::shutdown::{closure#0} 0
<pageserver::page_service::FullBackupCmd>::parse::{closure#0} 0
<pageserver::page_service::FullBackupCmd>::parse::{closure#1} 0
<pageserver::page_service::FullBackupCmd>::parse::{closure#2} 0
<pageserver::page_service::FullBackupCmd>::parse::{closure#3} 0
<pageserver::page_service::LeaseLsnCmd>::parse::{closure#0} 0
<pageserver::page_service::LeaseLsnCmd>::parse::{closure#1} 0
<pageserver::page_service::LeaseLsnCmd>::parse::{closure#2} 0
<pageserver::page_service::Listener>::stop_accepting 0
::stop_accepting 0
::stop_accepting::{closure#0} 0
<pageserver::page_service::PageServerHandler as postgres_backend::Handler<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>>::check_auth_jwt 0
<pageserver::page_service::PageServerHandler as postgres_backend::Handler<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>>::check_auth_jwt::{closure#0} 0
<pageserver::page_service::PageServerHandler as postgres_backend::Handler<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>>::process_query::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler as postgres_backend::Handler<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>>::process_query::{closure#0}::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler as postgres_backend::Handler<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>>::process_query::{closure#0}::{closure#0}::{closure#1} 0
<pageserver::page_service::PageServerHandler as postgres_backend::Handler<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>>::startup 0
<pageserver::page_service::PageServerHandler>::check_permission 0
<pageserver::page_service::PageServerHandler>::check_permission::{closure#0} 0
<pageserver::page_service::PageServerHandler>::flush_cancellable::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>> 0
<pageserver::page_service::PageServerHandler>::flush_cancellable::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_basebackup_request::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_basebackup_request::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_basebackup_request::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#1} 0
<pageserver::page_service::PageServerHandler>::handle_basebackup_request::{closure#0}::{closure#0}::map_basebackup_error 0
<pageserver::page_service::PageServerHandler>::handle_db_size_request::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_get_nblocks_request::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_get_page_at_lsn_request_batched::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_get_page_at_lsn_request_batched::{closure#0}::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_get_page_at_lsn_request_batched::{closure#0}::{closure#0}::{closure#1} 0
<pageserver::page_service::PageServerHandler>::handle_get_page_at_lsn_request_batched::{closure#0}::{closure#0}::{closure#1}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_get_rel_exists_request::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_get_slru_segment_request::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_make_lsn_lease::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_make_lsn_lease::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_make_lsn_lease::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#1} 0
<pageserver::page_service::PageServerHandler>::handle_make_lsn_lease::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#2} 0
<pageserver::page_service::PageServerHandler>::handle_pagerequests::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_pagerequests_pipelined::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>> 0
<pageserver::page_service::PageServerHandler>::handle_pagerequests_pipelined::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_pagerequests_pipelined::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_pagerequests_pipelined::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_pagerequests_pipelined::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_pagerequests_pipelined::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#1} 0
::handle_pagerequests_pipelined::>>>::{closure#0}::{closure#1} 0
::handle_pagerequests_pipelined::>>>::{closure#0}::{closure#3} 0
<pageserver::page_service::PageServerHandler>::handle_pagerequests_pipelined::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#2} 0
<pageserver::page_service::PageServerHandler>::handle_pagerequests_pipelined::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#2}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::handle_pagerequests_serial::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>> 0
<pageserver::page_service::PageServerHandler>::handle_pagerequests_serial::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0} 0
<pageserver::page_service::PageServerHandler>::new 0
<pageserver::page_service::PageServerHandler>::pagesteam_handle_batched_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0} 0
::pagesteam_handle_batched_message::>>>::{closure#0} 0
::pagesteam_handle_batched_message::>>>::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::pagesteam_handle_batched_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#0} 0
<pageserver::page_service::PageServerHandler>::pagesteam_handle_batched_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#12} 0
<pageserver::page_service::PageServerHandler>::pagesteam_handle_batched_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#14} 0
<pageserver::page_service::PageServerHandler>::pagesteam_handle_batched_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#1} 0
<pageserver::page_service::PageServerHandler>::pagesteam_handle_batched_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#2} 0
<pageserver::page_service::PageServerHandler>::pagesteam_handle_batched_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#3} 0
<pageserver::page_service::PageServerHandler>::pagesteam_handle_batched_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#4} 0
<pageserver::page_service::PageServerHandler>::pagesteam_handle_batched_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#6} 0
<pageserver::page_service::PageServerHandler>::pagesteam_handle_batched_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0}::{closure#0}::{closure#8} 0
<pageserver::page_service::PageServerHandler>::pagestream_do_batch 0
<pageserver::page_service::PageServerHandler>::pagestream_do_batch::{closure#0} 0
<pageserver::page_service::PageServerHandler>::pagestream_read_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>> 0
<pageserver::page_service::PageServerHandler>::pagestream_read_message::<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>::{closure#0} 0
<pageserver::page_service::PageServerHandler>::wait_or_get_last_lsn 0
<pageserver::page_service::PageServerHandler>::wait_or_get_last_lsn::{closure#0} 0
<pageserver::page_service::PageStreamCmd>::parse::{closure#1} 0
<pageserver::page_service::PageStreamError as core::convert::From<pageserver::page_service::GetActiveTimelineError>>::from 0
<pageserver::page_service::PageStreamError as core::convert::From<pageserver::tenant::timeline::PageReconstructError>>::from 0
<pageserver::page_service::PageStreamError as core::convert::From<pageserver::tenant::timeline::WaitLsnError>>::from 0
<pageserver::page_service::TenantManagerWrapper as pageserver::tenant::timeline::handle::TenantManager<pageserver::page_service::TenantManagerTypes>>::resolve 0
<pageserver::page_service::TenantManagerWrapper as pageserver::tenant::timeline::handle::TenantManager<pageserver::page_service::TenantManagerTypes>>::resolve::{closure#0} 0
<pageserver::page_service::TimelineHandles>::get 0
<pageserver::page_service::TimelineHandles>::get::{closure#0} 0
<pageserver::page_service::TimelineHandles>::get::{closure#0}::{closure#0} 0
<pageserver::page_service::TimelineHandles>::get::{closure#0}::{closure#1} 0
<pageserver::page_service::TimelineHandles>::new 0
<pageserver::page_service::TimelineHandles>::tenant_id 0
<postgres_backend::QueryError as core::convert::From<pageserver::page_service::GetActiveTimelineError>>::from 0
<postgres_backend::QueryError as core::convert::From<pageserver::tenant::mgr::GetActiveTenantError>>::from 0
<postgres_backend::QueryError as core::convert::From<pageserver::tenant::timeline::WaitLsnError>>::from 0
<utils::lsn::Lsn as core::convert::From<pageserver::page_service::WaitedForLsn>>::from 0
pageserver::page_service::libpq_listener_main 0
pageserver::page_service::libpq_listener_main::{closure#0} 0
pageserver::page_service::page_service_conn_main::{closure#0}::{closure#0} 0
pageserver::page_service::page_service_conn_main::{closure#0}::{closure#0}::{closure#0} 0
pageserver::page_service::page_service_conn_main::{closure#0}::{closure#0}::{closure#0}::{closure#0} 0
pageserver::page_service::set_tracing_field_shard_id 0
pageserver::page_service::spawn 0
<pageserver::page_service::PageStreamCmd>::parse::{closure#0} 2
pageserver::page_service::tests::pageservice_cmd_err_handling 2
pageserver::page_service::tests::pageservice_cmd_parse 2
<pageserver::page_service::FullBackupCmd>::parse 4
<pageserver::page_service::LeaseLsnCmd>::parse 4
<pageserver::page_service::PageStreamCmd>::parse 6
<pageserver::page_service::BaseBackupCmd>::parse 18
<pageserver::page_service::PageServiceCmd>::parse 42

Generated by: LCOV version 2.1-beta