LCOV - code coverage report

Current view: top level - pageserver/src - deletion_queue.rs (source / functions) Coverage Total Hit Test: 322b88762cba8ea666f63cda880cccab6936bf37.info Lines: 84.3 % 847 714 Test Date: 2024-02-29 11:57:12 Functions: 50.0 % 192 96

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 as core::clone::Clone>::clone	0
<pageserver::deletion_queue::DeletionQueue>::shutdown	0
::shutdown	0
::shutdown::{closure#0}	0
<pageserver::deletion_queue::DeletionQueue>::shutdown::{closure#0}::{closure#0}	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_advisory	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	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::{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	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::test::deletion_queue_validation	3
<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::deletion_queue_recovery::{closure#0}	4
<pageserver::deletion_queue::DeletionList>::into_remote_paths::{closure#0}	6
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::{closure#0}	6
<pageserver::deletion_queue::test::MockControlPlane>::new	7
<pageserver::deletion_queue::test::TestSetup>::set_latest_generation	7
<pageserver::deletion_queue::test::TestSetup>::write_remote_layer	7
pageserver::deletion_queue::test::setup	7
<pageserver::deletion_queue::DeletionHeader as core::fmt::Debug>::fmt	8
<::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
::fmt	0
::deserialize::<&mut serde_json::de::Deserializer>	0
::deserialize::<_>	0
::serialize::<_>	0
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	8
<pageserver::deletion_queue::DeletionHeader>::new	8
<pageserver::deletion_queue::DeletionQueue>::new::<_>	9
::new::<_>	0
::new::	0
::new::	9
<pageserver::deletion_queue::DeletionQueue>::new_client	9
<pageserver::deletion_queue::DeletionQueueClient>::recover	9
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with	9
>::spawn_with	0
>::spawn_with	0
>::spawn_with	9
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#0}	9
>::spawn_with::{closure#0}	0
>::spawn_with::{closure#0}	0
>::spawn_with::{closure#0}	9
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#1}	9
>::spawn_with::{closure#1}	0
>::spawn_with::{closure#1}	0
>::spawn_with::{closure#1}	9
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#2}	9
>::spawn_with::{closure#2}	0
>::spawn_with::{closure#2}	0
>::spawn_with::{closure#2}	9
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#3}	9
>::spawn_with::{closure#3}	0
>::spawn_with::{closure#3}	0
>::spawn_with::{closure#3}	9
<pageserver::deletion_queue::test::MockControlPlane as core::fmt::Debug>::fmt	9
::fmt	0
::clone	9
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::validate	9
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::validate::{closure#0}	9
<pageserver::deletion_queue::DeletionList>::into_remote_paths	10
pageserver::deletion_queue::test::assert_local_files	10
<pageserver::deletion_queue::TenantDeletionList>::len	11
<pageserver::deletion_queue::TenantDeletionList>::len::{closure#0}	11
<pageserver::deletion_queue::DeletionList>::push::{closure#0}	13
<pageserver::deletion_queue::DeletionList>::push::{closure#1}	13
<pageserver::deletion_queue::VisibleLsnUpdates as core::default::Default>::default	13
<pageserver::deletion_queue::DeletionList>::push	15
<pageserver::deletion_queue::DeletionHeader>::save	16
::save	8
::save::{closure#0}	8
pageserver::deletion_queue::test::assert_remote_files::{closure#0}	17
pageserver::deletion_queue::test::assert_remote_files	19
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate	20
::flush_immediate	10
::flush_immediate::{closure#0}	10
<pageserver::deletion_queue::DeletionList>::new	22
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute	22
::flush_execute	11
::flush_execute::{closure#0}	11
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>	26
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0}	26
<pageserver::deletion_queue::DeletionList>::is_empty	30
<pageserver::deletion_queue::DeletionQueueClient>::flush	30
::flush	15
::flush::{closure#0}	15
<pageserver::deletion_queue::DeletionList>::save	32
::save	16
::save::{closure#0}	16
<pageserver::deletion_queue::FlushOp>::notify	43
<pageserver::deletion_queue::FlushOp>::new	44
<pageserver::deletion_queue::TenantDeletionList as core::fmt::Debug>::fmt	51
<::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::>	4
::deserialize::<&mut serde_json::de::Deserializer>	4
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	8
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	12
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	13
<pageserver::deletion_queue::DeletionList>::len	65
<pageserver::deletion_queue::DeletionList as core::fmt::Debug>::fmt	80
<::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::__Visitor as serde::de::Visitor>::visit_map::>	4
::deserialize::<&mut serde_json::de::Deserializer>	4
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	8
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	16
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	18
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	24
<pageserver::deletion_queue::mock::MockDeletionQueue>::new	89
<pageserver::deletion_queue::VisibleLsnUpdates>::new	98
<pageserver::deletion_queue::mock::MockDeletionQueue>::new_client	98
<pageserver::deletion_queue::DeletionQueueClient>::push_layers	255
<pageserver::deletion_queue::DeletionQueueClient>::push_layers::{closure#0}	255
<pageserver::deletion_queue::DeletionQueueClient>::push_layers_sync	255
<pageserver::deletion_queue::DeletionQueueClient>::do_push::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>	290
<pageserver::deletion_queue::DeletionQueueClient as core::fmt::Debug>::fmt	601
::fmt	0
::clone	601
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn	745
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn::{closure#0}	745

Generated by: LCOV version 2.1-beta