LCOV - code coverage report

Current view: top level - pageserver/src - deletion_queue.rs (source / functions) Coverage Total Hit Test: 32f4a56327bc9da697706839ed4836b2a00a408f.info Lines: 88.4 % 816 721 Test Date: 2024-02-07 07:37:29 Functions: 58.9 % 192 113

Function Name	Hit count
<pageserver::deletion_queue::DeletionHeader>::save::{closure#0}::{closure#0}	0
<pageserver::deletion_queue::DeletionList as core::fmt::Display>::fmt	0
<pageserver::deletion_queue::DeletionQueue>::shutdown::{closure#0}::{closure#1}	0
<pageserver::deletion_queue::DeletionQueue>::shutdown::{closure#0}::{closure#2}	0
<pageserver::deletion_queue::DeletionQueueClient>::broken	0
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0}::{closure#0}	0
<pageserver::deletion_queue::DeletionQueueClient>::do_push::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0}	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute::{closure#0}::{closure#0}	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute::{closure#0}::{closure#1}	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute::{closure#0}::{closure#2}	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute::{closure#0}::{closure#3}	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute::{closure#0}::{closure#4}	0
<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::{closure#0}::{closure#0}	0
<pageserver::deletion_queue::DeletionQueueClient>::push_layers::{closure#0}::{closure#0}	0
<pageserver::deletion_queue::DeletionQueueError as core::fmt::Debug>::fmt	0
::fmt	0
::fmt	0
<pageserver::deletion_queue::FlushOp as core::fmt::Debug>::fmt	0
<pageserver::deletion_queue::FlushOp>::notify::{closure#0}	0
<pageserver::deletion_queue::VisibleLsnUpdates as core::fmt::Debug>::fmt	0
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#1}	0
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#2}	0
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#4}	0
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#5}	0
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::re_attach	0
::re_attach	0
::re_attach::{closure#0}	0
<pageserver::deletion_queue::test::TestSetup>::restart::{closure#0}::{closure#0}	0
<pageserver::deletion_queue::test::TestSetup>::restart::{closure#0}::{closure#1}	0
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}::{closure#0}	0
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}::{closure#1}	0
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}::{closure#2}	0
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}::{closure#3}	0
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#0}	2
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#3}	2
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#6}	2
pageserver::deletion_queue::mock::deletion_list_serialization	2
pageserver::deletion_queue::mock::deletion_list_serialization::{closure#0}	2
pageserver::deletion_queue::test::deletion_queue_recovery::{closure#0}::{closure#0}	2
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}::{closure#0}	2
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}::{closure#1}	2
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}::{closure#2}	2
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}::{closure#3}	2
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}::{closure#4}	2
<pageserver::deletion_queue::mock::ConsumerState>::consume	4
::consume	2
::consume::{closure#0}	2
<pageserver::deletion_queue::mock::MockDeletionQueue>::pump	4
::pump	2
::pump::{closure#0}	2
<pageserver::deletion_queue::test::TestSetup>::restart	4
::restart	2
::restart::{closure#0}	2
<pageserver::deletion_queue::test::MockControlPlane>::new	6
<pageserver::deletion_queue::test::TestSetup>::set_latest_generation	6
<pageserver::deletion_queue::test::TestSetup>::write_remote_layer	6
pageserver::deletion_queue::test::deletion_queue_recovery	6
pageserver::deletion_queue::test::deletion_queue_recovery	2
pageserver::deletion_queue::test::deletion_queue_recovery::{closure#0}	4
pageserver::deletion_queue::test::deletion_queue_smoke	6
pageserver::deletion_queue::test::deletion_queue_smoke	2
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}	4
pageserver::deletion_queue::test::deletion_queue_validation	6
pageserver::deletion_queue::test::deletion_queue_validation	2
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}	4
pageserver::deletion_queue::test::setup	6
<pageserver::deletion_queue::test::MockControlPlane as core::fmt::Debug>::fmt	8
::fmt	0
::clone	8
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::validate	8
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::validate::{closure#0}	8
pageserver::deletion_queue::test::assert_local_files	10
pageserver::deletion_queue::test::assert_remote_files::{closure#0}	16
pageserver::deletion_queue::test::assert_remote_files	18
<pageserver::deletion_queue::DeletionHeader>::new	41
<pageserver::deletion_queue::TenantDeletionList>::len	43
<pageserver::deletion_queue::DeletionList>::into_remote_paths	45
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute	46
::flush_execute	23
::flush_execute::{closure#0}	23
<pageserver::deletion_queue::TenantDeletionList>::len::{closure#0}	58
<pageserver::deletion_queue::DeletionHeader>::save	82
::save	41
::save::{closure#0}	41
<pageserver::deletion_queue::mock::MockDeletionQueue>::new	82
<pageserver::deletion_queue::mock::MockDeletionQueue>::new_client	94
<pageserver::deletion_queue::DeletionList>::push::{closure#0}	105
<pageserver::deletion_queue::DeletionList>::save	136
::save	68
::save::{closure#0}	68
<pageserver::deletion_queue::DeletionHeader as core::fmt::Debug>::fmt	149
<::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_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_seq::<_>	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>	0
::fmt	0
::deserialize::<_>	0
::serialize::<_>	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::>	18
::deserialize::<&mut serde_json::de::Deserializer>	18
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	36
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	36
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	41
<pageserver::deletion_queue::DeletionQueueClient>::flush_advisory	158
<pageserver::deletion_queue::DeletionQueue as core::clone::Clone>::clone	172
<pageserver::deletion_queue::DeletionQueue>::shutdown::{closure#0}::{closure#0}	172
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>	230
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0}	230
<pageserver::deletion_queue::TenantDeletionList as core::fmt::Debug>::fmt	260
<::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_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_seq::<_>	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>	0
::fmt	0
::deserialize::<_>	0
::serialize::<_>	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::>	2
::eq	2
::deserialize::<&mut serde_json::de::Deserializer>	2
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	4
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::>	31
::deserialize::<&mut serde_json::de::Deserializer>	31
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	60
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	62
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	66
<pageserver::deletion_queue::DeletionQueue>::shutdown	344
::shutdown	172
::shutdown::{closure#0}	172
<pageserver::deletion_queue::DeletionList as core::fmt::Debug>::fmt	372
<::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_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_seq::<_>	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>	0
::fmt	0
::deserialize::<_>	0
::serialize::<_>	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::>	2
::eq	2
::deserialize::<&mut serde_json::de::Deserializer>	2
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	8
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::>	28
::deserialize::<&mut serde_json::de::Deserializer>	28
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	70
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	112
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	120
<pageserver::deletion_queue::DeletionQueueClient>::flush	414
::flush	207
::flush::{closure#0}	207
<pageserver::deletion_queue::DeletionQueueClient>::recover	611
<pageserver::deletion_queue::DeletionQueue>::new::<_>	612
::new::<_>	0
::new::	8
::new::	604
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with	612
>::spawn_with	0
>::spawn_with	8
>::spawn_with	604
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#0}	612
>::spawn_with::{closure#0}	0
>::spawn_with::{closure#0}	8
>::spawn_with::{closure#0}	604
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#1}	612
>::spawn_with::{closure#1}	0
>::spawn_with::{closure#1}	8
>::spawn_with::{closure#1}	604
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#2}	612
>::spawn_with::{closure#2}	0
>::spawn_with::{closure#2}	8
>::spawn_with::{closure#2}	604
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#3}	612
>::spawn_with::{closure#3}	0
>::spawn_with::{closure#3}	8
>::spawn_with::{closure#3}	604
<pageserver::deletion_queue::DeletionList>::new	669
<pageserver::deletion_queue::VisibleLsnUpdates>::new	694
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate	722
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate::{closure#0}	722
<pageserver::deletion_queue::VisibleLsnUpdates as core::default::Default>::default	734
<pageserver::deletion_queue::DeletionList>::is_empty	765
<pageserver::deletion_queue::FlushOp>::notify	882
<pageserver::deletion_queue::FlushOp>::new	884
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate	906
::flush_immediate	453
::flush_immediate::{closure#0}	453
<pageserver::deletion_queue::DeletionQueue>::new_client	1216
<pageserver::deletion_queue::DeletionList>::into_remote_paths::{closure#0}	1414
<pageserver::deletion_queue::DeletionList>::push::{closure#1}	3696
<pageserver::deletion_queue::DeletionList>::push	4104
<pageserver::deletion_queue::DeletionQueueClient>::push_layers_sync	4262
<pageserver::deletion_queue::DeletionQueueClient>::push_layers	4322
<pageserver::deletion_queue::DeletionQueueClient>::push_layers::{closure#0}	4322
<pageserver::deletion_queue::DeletionQueueClient>::do_push::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>	5103
<pageserver::deletion_queue::DeletionList>::len	5207
<pageserver::deletion_queue::DeletionQueueClient as core::fmt::Debug>::fmt	5386
::fmt	0
::clone	5386
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn	6042
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn::{closure#0}	6042

Generated by: LCOV version 2.1-beta