LCOV - differential code coverage report

Current view: top level - pageserver/src - deletion_queue.rs (source / functions) Coverage Total Hit UBC CBC Current: cd44433dd675caa99df17a61b18949c8387e2242.info Lines: 88.1 % 817 720 97 720 Current Date: 2024-01-09 02:06:09 Functions: 58.9 % 192 113 79 113 Baseline: 66c52a629a0f4a503e193045e0df4c77139e344b.info Baseline Date: 2024-01-08 15:34:46

Function Name	TLA	Hit count
<pageserver::deletion_queue::DeletionHeader>::save::{closure#0}::{closure#0}	UBC	0
<pageserver::deletion_queue::DeletionList as core::fmt::Display>::fmt	UBC	0
<pageserver::deletion_queue::DeletionQueue>::shutdown::{closure#0}::{closure#1}	UBC	0
<pageserver::deletion_queue::DeletionQueue>::shutdown::{closure#0}::{closure#2}	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::broken	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0}::{closure#0}	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::do_push::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0}	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute::{closure#0}::{closure#0}	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute::{closure#0}::{closure#1}	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute::{closure#0}::{closure#2}	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute::{closure#0}::{closure#3}	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute::{closure#0}::{closure#4}	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate::{closure#0}::{closure#0}	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate::{closure#0}::{closure#1}	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate::{closure#0}::{closure#0}	UBC	0
<pageserver::deletion_queue::DeletionQueueClient>::push_layers::{closure#0}::{closure#0}	UBC	0
<pageserver::deletion_queue::DeletionQueueError as core::fmt::Debug>::fmt	UBC	0
::fmt	UBC	0
::fmt	UBC	0
<pageserver::deletion_queue::FlushOp as core::fmt::Debug>::fmt	UBC	0
<pageserver::deletion_queue::FlushOp>::notify::{closure#0}	UBC	0
<pageserver::deletion_queue::VisibleLsnUpdates as core::fmt::Debug>::fmt	UBC	0
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#1}	UBC	0
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#2}	UBC	0
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#4}	UBC	0
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#5}	UBC	0
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::re_attach	UBC	0
::re_attach	UBC	0
::re_attach::{closure#0}	UBC	0
<pageserver::deletion_queue::test::TestSetup>::restart::{closure#0}::{closure#0}	UBC	0
<pageserver::deletion_queue::test::TestSetup>::restart::{closure#0}::{closure#1}	UBC	0
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}::{closure#0}	UBC	0
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}::{closure#1}	UBC	0
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}::{closure#2}	UBC	0
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}::{closure#3}	UBC	0
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#0}	CBC	1
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#3}	CBC	1
<pageserver::deletion_queue::mock::ConsumerState>::consume::{closure#0}::{closure#6}	CBC	1
pageserver::deletion_queue::mock::deletion_list_serialization	CBC	1
pageserver::deletion_queue::mock::deletion_list_serialization::{closure#0}	CBC	1
pageserver::deletion_queue::test::deletion_queue_recovery	CBC	1
pageserver::deletion_queue::test::deletion_queue_recovery::{closure#0}::{closure#0}	CBC	1
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}::{closure#0}	CBC	1
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}::{closure#1}	CBC	1
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}::{closure#2}	CBC	1
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}::{closure#3}	CBC	1
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}::{closure#4}	CBC	1
<pageserver::deletion_queue::mock::ConsumerState>::consume	CBC	2
::consume	CBC	1
::consume::{closure#0}	CBC	1
<pageserver::deletion_queue::mock::MockDeletionQueue>::pump	CBC	2
::pump	CBC	1
::pump::{closure#0}	CBC	1
<pageserver::deletion_queue::test::TestSetup>::restart	CBC	2
::restart	CBC	1
::restart::{closure#0}	CBC	1
pageserver::deletion_queue::test::deletion_queue_recovery::{closure#0}	CBC	2
<pageserver::deletion_queue::test::MockControlPlane>::new	CBC	3
<pageserver::deletion_queue::test::TestSetup>::set_latest_generation	CBC	3
<pageserver::deletion_queue::test::TestSetup>::write_remote_layer	CBC	3
pageserver::deletion_queue::test::deletion_queue_smoke	CBC	3
pageserver::deletion_queue::test::deletion_queue_smoke	CBC	1
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}	CBC	2
pageserver::deletion_queue::test::deletion_queue_validation	CBC	3
pageserver::deletion_queue::test::deletion_queue_validation	CBC	1
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}	CBC	2
pageserver::deletion_queue::test::setup	CBC	3
<pageserver::deletion_queue::test::MockControlPlane as core::fmt::Debug>::fmt	CBC	4
::fmt	UBC	0
::clone	CBC	4
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::validate	CBC	4
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::validate::{closure#0}	CBC	4
pageserver::deletion_queue::test::assert_local_files	CBC	5
pageserver::deletion_queue::test::assert_remote_files::{closure#0}	CBC	8
pageserver::deletion_queue::test::assert_remote_files	CBC	9
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute	CBC	34
::flush_execute	CBC	17
::flush_execute::{closure#0}	CBC	17
<pageserver::deletion_queue::DeletionHeader>::new	CBC	37
<pageserver::deletion_queue::TenantDeletionList>::len	CBC	38
<pageserver::deletion_queue::DeletionList>::into_remote_paths	CBC	40
<pageserver::deletion_queue::mock::MockDeletionQueue>::new	CBC	41
<pageserver::deletion_queue::mock::MockDeletionQueue>::new_client	CBC	47
<pageserver::deletion_queue::TenantDeletionList>::len::{closure#0}	CBC	51
<pageserver::deletion_queue::DeletionHeader>::save	CBC	74
::save	CBC	37
::save::{closure#0}	CBC	37
<pageserver::deletion_queue::DeletionList>::push::{closure#0}	CBC	92
<pageserver::deletion_queue::DeletionQueueClient>::flush_advisory	CBC	104
<pageserver::deletion_queue::DeletionList>::save	CBC	122
::save	CBC	61
::save::{closure#0}	CBC	61
<pageserver::deletion_queue::DeletionQueue as core::clone::Clone>::clone	CBC	159
<pageserver::deletion_queue::DeletionQueue>::shutdown::{closure#0}::{closure#0}	CBC	159
<pageserver::deletion_queue::DeletionHeader as core::fmt::Debug>::fmt	CBC	175
<::deserialize::__Field as serde::de::Deserialize>::deserialize::<_>	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_>	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::<_>	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::expecting	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>	UBC	0
::fmt	UBC	0
::deserialize::<_>	UBC	0
::serialize::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::>	CBC	23
::deserialize::<&mut serde_json::de::Deserializer>	CBC	23
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	CBC	37
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	CBC	46
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	CBC	46
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>	CBC	203
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0}	CBC	203
<pageserver::deletion_queue::TenantDeletionList as core::fmt::Debug>::fmt	CBC	240
<::deserialize::__Field as serde::de::Deserialize>::deserialize::<_>	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_>	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::<_>	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::expecting	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>	UBC	0
::fmt	UBC	0
::deserialize::<_>	UBC	0
::serialize::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::>	CBC	1
::eq	CBC	1
::deserialize::<&mut serde_json::de::Deserializer>	CBC	1
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	CBC	2
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::>	CBC	30
::deserialize::<&mut serde_json::de::Deserializer>	CBC	30
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	CBC	53
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	CBC	60
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	CBC	62
<pageserver::deletion_queue::DeletionQueue>::shutdown	CBC	318
::shutdown	CBC	159
::shutdown::{closure#0}	CBC	159
<pageserver::deletion_queue::DeletionList as core::fmt::Debug>::fmt	CBC	343
<::deserialize::__Field as serde::de::Deserialize>::deserialize::<_>	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_>	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::<_>	UBC	0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::expecting	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>	UBC	0
::fmt	UBC	0
::deserialize::<_>	UBC	0
::serialize::<_>	UBC	0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::>	CBC	1
::eq	CBC	1
::deserialize::<&mut serde_json::de::Deserializer>	CBC	1
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	CBC	4
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::>	CBC	27
::deserialize::<&mut serde_json::de::Deserializer>	CBC	27
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	CBC	62
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	CBC	108
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	CBC	112
<pageserver::deletion_queue::DeletionQueueClient>::flush	CBC	372
::flush	CBC	186
::flush::{closure#0}	CBC	186
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate	CBC	456
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate::{closure#0}	CBC	456
<pageserver::deletion_queue::DeletionQueueClient>::recover	CBC	560
<pageserver::deletion_queue::DeletionQueue>::new::<_>	CBC	561
::new::<_>	UBC	0
::new::	CBC	4
::new::	CBC	557
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with	CBC	561
>::spawn_with	UBC	0
>::spawn_with	CBC	4
>::spawn_with	CBC	557
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#0}	CBC	561
>::spawn_with::{closure#0}	UBC	0
>::spawn_with::{closure#0}	CBC	4
>::spawn_with::{closure#0}	CBC	557
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#1}	CBC	561
>::spawn_with::{closure#1}	UBC	0
>::spawn_with::{closure#1}	CBC	4
>::spawn_with::{closure#1}	CBC	557
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#2}	CBC	561
>::spawn_with::{closure#2}	UBC	0
>::spawn_with::{closure#2}	CBC	4
>::spawn_with::{closure#2}	CBC	557
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#3}	CBC	561
>::spawn_with::{closure#3}	UBC	0
>::spawn_with::{closure#3}	CBC	4
>::spawn_with::{closure#3}	CBC	557
<pageserver::deletion_queue::VisibleLsnUpdates>::new	CBC	602
<pageserver::deletion_queue::DeletionList>::new	CBC	611
<pageserver::deletion_queue::VisibleLsnUpdates as core::default::Default>::default	CBC	659
<pageserver::deletion_queue::DeletionList>::is_empty	CBC	707
<pageserver::deletion_queue::FlushOp>::notify	CBC	719
<pageserver::deletion_queue::FlushOp>::new	CBC	721
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate	CBC	750
::flush_immediate	CBC	375
::flush_immediate::{closure#0}	CBC	375
<pageserver::deletion_queue::DeletionList>::into_remote_paths::{closure#0}	CBC	819
<pageserver::deletion_queue::DeletionQueue>::new_client	CBC	1118
<pageserver::deletion_queue::DeletionList>::push::{closure#1}	CBC	2797
<pageserver::deletion_queue::DeletionList>::push	CBC	3152
<pageserver::deletion_queue::DeletionQueueClient>::push_layers_sync	CBC	3231
<pageserver::deletion_queue::DeletionQueueClient>::push_layers	CBC	3255
<pageserver::deletion_queue::DeletionQueueClient>::push_layers::{closure#0}	CBC	3255
<pageserver::deletion_queue::DeletionQueueClient>::do_push::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>	CBC	3994
<pageserver::deletion_queue::DeletionList>::len	CBC	4115
<pageserver::deletion_queue::DeletionQueueClient as core::fmt::Debug>::fmt	CBC	4635
::fmt	UBC	0
::clone	CBC	4635
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn	CBC	5095
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn::{closure#0}	CBC	5095

Generated by: LCOV version 2.1-beta