LCOV - code coverage report
Current view: top level - pageserver/src - deletion_queue.rs (source / functions) Coverage Total Hit
Test: fc67f8dc6087a0b4f4f0bcd74f6e1dc25fab8cf3.info Lines: 87.3 % 829 724
Test Date: 2024-09-24 13:57:57 Functions: 56.8 % 132 75

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>::expecting 0
<::deserialize::__Field as serde::de::Deserialize>::deserialize::<_> 0
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::<_> 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> 0
<::deserialize::__Visitor as serde::de::Visitor>::expecting 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 serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::expecting 162
<::deserialize::__Field as serde::de::Deserialize>::deserialize::<_> 0
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> 48
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> 24
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::<_> 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: 72
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> 0
<::deserialize::__Visitor as serde::de::Visitor>::expecting 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> 12
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> 6
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<_> 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>::expecting 90
<::deserialize::__Field as serde::de::Deserialize>::deserialize::<_> 0
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> 24
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> 12
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::<_> 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: 36
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> 0
<::deserialize::__Visitor as serde::de::Visitor>::expecting 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> 12
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> 6
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<_> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> 0
<pageserver::deletion_queue::DeletionHeader>::new 24
<pageserver::deletion_queue::DeletionHeader>::save 48
::save 24
::save::{closure#0} 24
<pageserver::deletion_queue::DeletionList as core::fmt::Display>::fmt 0
<pageserver::deletion_queue::DeletionList>::into_remote_paths 30
<pageserver::deletion_queue::DeletionList>::into_remote_paths::{closure#0} 18
<pageserver::deletion_queue::DeletionList>::is_empty 82
<pageserver::deletion_queue::DeletionList>::len 180
<pageserver::deletion_queue::DeletionList>::new 60
<pageserver::deletion_queue::DeletionList>::push 42
<pageserver::deletion_queue::DeletionList>::push::{closure#0} 36
<pageserver::deletion_queue::DeletionList>::push::{closure#1} 36
<pageserver::deletion_queue::DeletionList>::save 84
::save 42
::save::{closure#0} 42
<pageserver::deletion_queue::DeletionQueue>::new::<_> 24
::new::<_> 0
::new:: 0
::new:: 24
<pageserver::deletion_queue::DeletionQueue>::new_client 24
<pageserver::deletion_queue::DeletionQueue>::shutdown 0
::shutdown 0
::shutdown::{closure#0} 0
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage> 72
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0} 72
<pageserver::deletion_queue::DeletionQueueClient>::do_push::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage> 839
<pageserver::deletion_queue::DeletionQueueClient>::flush 84
::flush 42
::flush::{closure#0} 42
<pageserver::deletion_queue::DeletionQueueClient>::flush_advisory 0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute 60
::flush_execute 30
::flush_execute::{closure#0} 30
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate 60
::flush_immediate 30
::flush_immediate::{closure#0} 30
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate::{closure#0}::{closure#0} 0
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate::{closure#0}::{closure#1} 0
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate 0
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate::{closure#0} 0
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate::{closure#0}::{closure#0} 0
<pageserver::deletion_queue::DeletionQueueClient>::push_layers 743
<pageserver::deletion_queue::DeletionQueueClient>::push_layers::{closure#0} 743
<pageserver::deletion_queue::DeletionQueueClient>::push_layers_sync 743
<pageserver::deletion_queue::DeletionQueueClient>::recover 24
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn 4223
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn::{closure#0} 4223
<pageserver::deletion_queue::DeletionQueueError as core::fmt::Display>::fmt 0
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with 24
>::spawn_with 0
>::spawn_with 0
>::spawn_with 24
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#0} 24
>::spawn_with::{closure#0} 0
>::spawn_with::{closure#0} 0
>::spawn_with::{closure#0} 24
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#1} 24
>::spawn_with::{closure#1} 0
>::spawn_with::{closure#1} 0
>::spawn_with::{closure#1} 24
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#2} 24
>::spawn_with::{closure#2} 0
>::spawn_with::{closure#2} 0
>::spawn_with::{closure#2} 24
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#3} 24
>::spawn_with::{closure#3} 0
>::spawn_with::{closure#3} 0
>::spawn_with::{closure#3} 24
<pageserver::deletion_queue::FlushOp>::new 126
<pageserver::deletion_queue::FlushOp>::notify 126
<pageserver::deletion_queue::TenantDeletionList>::len 30
<pageserver::deletion_queue::TenantDeletionList>::len::{closure#0} 30
<pageserver::deletion_queue::VisibleLsnUpdates as core::fmt::Debug>::fmt 0
<pageserver::deletion_queue::VisibleLsnUpdates>::new 600
<pageserver::deletion_queue::mock::ConsumerState>::consume 12
::consume 6
::consume::{closure#0} 6
<pageserver::deletion_queue::mock::MockDeletionQueue>::new 576
<pageserver::deletion_queue::mock::MockDeletionQueue>::new_client 606
<pageserver::deletion_queue::mock::MockDeletionQueue>::pump 12
::pump 6
::pump::{closure#0} 6
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::re_attach 0
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::re_attach::{closure#0} 0
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::validate 24
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::validate::{closure#0} 24
<pageserver::deletion_queue::test::MockControlPlane>::new 18
<pageserver::deletion_queue::test::TestSetup>::restart 12
::restart 6
::restart::{closure#0} 6
<pageserver::deletion_queue::test::TestSetup>::set_latest_generation 18
<pageserver::deletion_queue::test::TestSetup>::write_remote_layer 18
pageserver::deletion_queue::mock::deletion_list_serialization 6
pageserver::deletion_queue::test::assert_local_files 30
pageserver::deletion_queue::test::assert_remote_files 54
pageserver::deletion_queue::test::assert_remote_files::{closure#0} 48
pageserver::deletion_queue::test::deletion_queue_recovery 12
pageserver::deletion_queue::test::deletion_queue_recovery 6
pageserver::deletion_queue::test::deletion_queue_recovery::{closure#0} 6
pageserver::deletion_queue::test::deletion_queue_smoke 12
pageserver::deletion_queue::test::deletion_queue_smoke 6
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0} 6
pageserver::deletion_queue::test::deletion_queue_validation 12
pageserver::deletion_queue::test::deletion_queue_validation 6
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0} 6
pageserver::deletion_queue::test::setup 36
pageserver::deletion_queue::test::setup 18
pageserver::deletion_queue::test::setup::{closure#0} 18

Generated by: LCOV version 2.1-beta