LCOV - code coverage report
Current view: top level - pageserver/src - deletion_queue.rs (source / functions) Coverage Total Hit
Test: 1e20c4f2b28aa592527961bb32170ebbd2c9172f.info Lines: 84.7 % 687 582
Test Date: 2025-07-16 12:29:03 Functions: 64.6 % 99 64

Function Name Sort by function name Hit count Sort by function hit count
<<pageserver::deletion_queue::DeletionHeader as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::visit_map::<serde_json::de::MapAccess<serde_json::read::SliceRead>> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> 0
<<pageserver::deletion_queue::DeletionList as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::visit_map::<serde_json::de::MapAccess<serde_json::read::StrRead>> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> 0
<<pageserver::deletion_queue::TenantDeletionList as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::visit_map::<serde_json::de::MapAccess<serde_json::read::StrRead>> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> 0
<pageserver::deletion_queue::DeletionList as core::fmt::Display>::fmt 0
<pageserver::deletion_queue::DeletionQueue>::shutdown 0
::shutdown 0
::shutdown::{closure#0} 0
<pageserver::deletion_queue::DeletionQueueClient>::flush_advisory 0
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate 0
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate::{closure#0} 0
<pageserver::deletion_queue::DeletionQueueWorkers<pageserver::controller_upcall_client::StorageControllerUpcallClient>>::spawn_with::{closure#0} 0
<pageserver::deletion_queue::DeletionQueueWorkers<pageserver::controller_upcall_client::StorageControllerUpcallClient>>::spawn_with::{closure#1} 0
<pageserver::deletion_queue::DeletionQueueWorkers<pageserver::controller_upcall_client::StorageControllerUpcallClient>>::spawn_with::{closure#2} 0
<pageserver::deletion_queue::DeletionQueueWorkers<pageserver::controller_upcall_client::StorageControllerUpcallClient>>::spawn_with::{closure#3} 0
<pageserver::deletion_queue::VisibleLsnUpdates as core::fmt::Debug>::fmt 0
<pageserver::deletion_queue::test::MockStorageController as pageserver::controller_upcall_client::StorageControllerUpcallApi>::get_timeline_import_status 0
<pageserver::deletion_queue::test::MockStorageController as pageserver::controller_upcall_client::StorageControllerUpcallApi>::get_timeline_import_status::{closure#0} 0
<pageserver::deletion_queue::test::MockStorageController as pageserver::controller_upcall_client::StorageControllerUpcallApi>::put_timeline_import_status 0
<pageserver::deletion_queue::test::MockStorageController as pageserver::controller_upcall_client::StorageControllerUpcallApi>::put_timeline_import_status::{closure#0} 0
<pageserver::deletion_queue::test::MockStorageController as pageserver::controller_upcall_client::StorageControllerUpcallApi>::re_attach 0
<pageserver::deletion_queue::test::MockStorageController as pageserver::controller_upcall_client::StorageControllerUpcallApi>::re_attach::{closure#0} 0
pageserver::deletion_queue::mock::deletion_list_serialization 1
<pageserver::deletion_queue::mock::MockDeletionQueue>::pump 2
::pump 1
::pump::{closure#0} 1
<pageserver::deletion_queue::test::TestSetup>::restart 2
::restart 1
::restart::{closure#0} 1
pageserver::deletion_queue::test::deletion_queue_recovery 2
pageserver::deletion_queue::test::deletion_queue_recovery 1
pageserver::deletion_queue::test::deletion_queue_recovery::{closure#0} 1
pageserver::deletion_queue::test::deletion_queue_smoke 2
pageserver::deletion_queue::test::deletion_queue_smoke 1
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0} 1
pageserver::deletion_queue::test::deletion_queue_validation 2
pageserver::deletion_queue::test::deletion_queue_validation 1
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0} 1
<pageserver::deletion_queue::DeletionList>::into_remote_paths::{closure#0} 3
<pageserver::deletion_queue::test::MockStorageController>::new 3
<pageserver::deletion_queue::test::TestSetup>::set_latest_generation 3
<pageserver::deletion_queue::test::TestSetup>::write_remote_layer 3
<pageserver::deletion_queue::DeletionHeader>::new 4
<pageserver::deletion_queue::DeletionQueue>::new::<_> 4
::new::<_> 0
::new:: 0
::new:: 4
<pageserver::deletion_queue::DeletionQueue>::new_client 4
<pageserver::deletion_queue::DeletionQueueClient>::recover 4
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with 4
>::spawn_with 0
>::spawn_with 0
>::spawn_with 4
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#0} 4
>::spawn_with::{closure#0} 0
>::spawn_with::{closure#0} 4
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#1} 4
>::spawn_with::{closure#1} 0
>::spawn_with::{closure#1} 4
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#2} 4
>::spawn_with::{closure#2} 0
>::spawn_with::{closure#2} 4
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#3} 4
>::spawn_with::{closure#3} 0
>::spawn_with::{closure#3} 4
<pageserver::deletion_queue::test::MockStorageController as pageserver::controller_upcall_client::StorageControllerUpcallApi>::validate 4
<pageserver::deletion_queue::test::MockStorageController as pageserver::controller_upcall_client::StorageControllerUpcallApi>::validate::{closure#0} 4
<pageserver::deletion_queue::DeletionList>::into_remote_paths 5
<pageserver::deletion_queue::TenantDeletionList>::len 5
<pageserver::deletion_queue::TenantDeletionList>::len::{closure#0} 5
pageserver::deletion_queue::test::assert_local_files 5
<pageserver::deletion_queue::DeletionList>::push::{closure#0} 6
<pageserver::deletion_queue::DeletionList>::push::{closure#1} 6
pageserver::deletion_queue::test::setup 6
pageserver::deletion_queue::test::setup 3
pageserver::deletion_queue::test::setup::{closure#0} 3
<pageserver::deletion_queue::DeletionList>::push 7
<pageserver::deletion_queue::DeletionHeader>::save 8
::save 4
::save::{closure#0} 4
pageserver::deletion_queue::test::assert_remote_files::{closure#0} 8
pageserver::deletion_queue::test::assert_remote_files 9
<pageserver::deletion_queue::DeletionList>::new 10
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute 10
::flush_execute 5
::flush_execute::{closure#0} 5
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate 10
::flush_immediate 5
::flush_immediate::{closure#0} 5
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage> 12
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0} 12
<pageserver::deletion_queue::DeletionList>::is_empty 13
<pageserver::deletion_queue::DeletionList>::save 14
::save 7
::save::{closure#0} 7
<pageserver::deletion_queue::DeletionQueueClient>::flush 14
::flush 7
::flush::{closure#0} 7
<pageserver::deletion_queue::FlushOp>::new 21
<pageserver::deletion_queue::FlushOp>::notify 22
<pageserver::deletion_queue::DeletionList>::len 30
<pageserver::deletion_queue::mock::MockDeletionQueue>::new 119
<pageserver::deletion_queue::mock::MockDeletionQueue>::new::{closure#0} 119
<pageserver::deletion_queue::VisibleLsnUpdates>::new 123
<pageserver::deletion_queue::mock::MockDeletionQueue>::new_client 125
<pageserver::deletion_queue::DeletionQueueClient>::push_layers 212
<pageserver::deletion_queue::DeletionQueueClient>::do_push::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage> 228
<pageserver::deletion_queue::mock::ConsumerState>::consume 238
::consume 119
::consume::{closure#0} 119
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn 770
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn::{closure#0} 770

Generated by: LCOV version 2.1-beta