LCOV - differential code coverage report
Current view: top level - pageserver/src - deletion_queue.rs (source / functions) Coverage Total Hit UBC GIC CBC ECB
Current: f6946e90941b557c917ac98cd5a7e9506d180f3e.info Lines: 87.4 % 818 715 103 715
Current Date: 2023-10-19 02:04:12 Functions: 52.3 % 220 115 105 3 112 3
Baseline: c8637f37369098875162f194f92736355783b050.info
Baseline Date: 2023-10-18 20:25:20

Function Name Sort by function name TLA Hit count Sort by function hit count
<pageserver::deletion_queue::DeletionHeader>::save::{closure#0} UBC 0
::save::{closure#0} UBC 0
::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} UBC 0
::flush_execute::{closure#0} UBC 0
::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::from_hex_map::<_, _, _>::{closure#0}::{closure#1} UBC 0
pageserver::deletion_queue::from_hex_map::<&mut serde_json::de::Deserializer, alloc::vec::Vec, utils::id::TimelineId>::{closure#0}::{closure#1} UBC 0
pageserver::deletion_queue::from_hex_map::<&mut serde_json::de::Deserializer, pageserver::deletion_queue::TenantDeletionList, utils::id::TenantId>::{closure#0}::{closure#1} UBC 0
pageserver::deletion_queue::from_hex_map::<_, _, _>::{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::MockDeletionQueue>::pump CBC 1
<pageserver::deletion_queue::mock::MockDeletionQueue>::pump::{closure#0} CBC 1
pageserver::deletion_queue::test::deletion_queue_recovery CBC 1
pageserver::deletion_queue::test::deletion_queue_recovery CBC 1
pageserver::deletion_queue::test::deletion_queue_recovery::{closure#0} ECB 2
pageserver::deletion_queue::test::deletion_queue_recovery::{closure#0}::{closure#0} CBC 1
pageserver::deletion_queue::test::deletion_queue_smoke CBC 1
pageserver::deletion_queue::test::deletion_queue_smoke CBC 1
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0} ECB 2
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::test::TestSetup>::restart CBC 2
::restart CBC 1
::restart::{closure#0} CBC 1
pageserver::deletion_queue::test::deletion_queue_recovery::{closure#0} GIC 2
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0} GIC 2
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0} ECB 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_validation CBC 3
pageserver::deletion_queue::test::deletion_queue_validation CBC 1
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0} GIC 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::DeletionHeader>::new CBC 13
<pageserver::deletion_queue::DeletionHeader>::save CBC 13
<pageserver::deletion_queue::TenantDeletionList>::len CBC 14
<pageserver::deletion_queue::TenantDeletionList>::len::{closure#0} CBC 14
<pageserver::deletion_queue::DeletionList>::into_remote_paths CBC 16
<pageserver::deletion_queue::DeletionList>::push::{closure#0} CBC 16
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute CBC 16
pageserver::deletion_queue::from_hex_map::<_, _, _> CBC 16
pageserver::deletion_queue::from_hex_map::<_, _, _> UBC 0
pageserver::deletion_queue::from_hex_map::<&mut serde_json::de::Deserializer, alloc::vec::Vec, utils::id::TimelineId> CBC 8
pageserver::deletion_queue::from_hex_map::<&mut serde_json::de::Deserializer, pageserver::deletion_queue::TenantDeletionList, utils::id::TenantId> CBC 8
pageserver::deletion_queue::from_hex_map::<_, _, _>::{closure#0} CBC 16
pageserver::deletion_queue::from_hex_map::<_, _, _>::{closure#0} UBC 0
pageserver::deletion_queue::from_hex_map::<&mut serde_json::de::Deserializer, alloc::vec::Vec, utils::id::TimelineId>::{closure#0} CBC 8
pageserver::deletion_queue::from_hex_map::<&mut serde_json::de::Deserializer, pageserver::deletion_queue::TenantDeletionList, utils::id::TenantId>::{closure#0} CBC 8
pageserver::deletion_queue::from_hex_map::<_, _, _>::{closure#0}::{closure#0} CBC 16
pageserver::deletion_queue::from_hex_map::<_, _, _>::{closure#0}::{closure#0} UBC 0
pageserver::deletion_queue::from_hex_map::<&mut serde_json::de::Deserializer, alloc::vec::Vec, utils::id::TimelineId>::{closure#0}::{closure#0} CBC 8
pageserver::deletion_queue::from_hex_map::<&mut serde_json::de::Deserializer, pageserver::deletion_queue::TenantDeletionList, utils::id::TenantId>::{closure#0}::{closure#0} CBC 8
pageserver::deletion_queue::to_hex_map::<_, _, _>::{closure#0} CBC 30
pageserver::deletion_queue::to_hex_map::<_, _, _>::{closure#0} UBC 0
pageserver::deletion_queue::to_hex_map::, serde_json::ser::CompactFormatter>, alloc::vec::Vec, utils::id::TimelineId>::{closure#0} UBC 0
pageserver::deletion_queue::to_hex_map::, serde_json::ser::CompactFormatter>, pageserver::deletion_queue::TenantDeletionList, utils::id::TenantId>::{closure#0} UBC 0
pageserver::deletion_queue::to_hex_map::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>, alloc::vec::Vec, utils::id::TimelineId>::{closure#0} CBC 15
pageserver::deletion_queue::to_hex_map::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>, pageserver::deletion_queue::TenantDeletionList, utils::id::TenantId>::{closure#0} CBC 15
pageserver::deletion_queue::to_hex_map::<_, _, _> CBC 34
pageserver::deletion_queue::to_hex_map::<_, _, _> UBC 0
pageserver::deletion_queue::to_hex_map::, serde_json::ser::CompactFormatter>, alloc::vec::Vec, utils::id::TimelineId> UBC 0
pageserver::deletion_queue::to_hex_map::, serde_json::ser::CompactFormatter>, pageserver::deletion_queue::TenantDeletionList, utils::id::TenantId> UBC 0
pageserver::deletion_queue::to_hex_map::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>, alloc::vec::Vec, utils::id::TimelineId> CBC 15
pageserver::deletion_queue::to_hex_map::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>, pageserver::deletion_queue::TenantDeletionList, utils::id::TenantId> CBC 19
<pageserver::deletion_queue::DeletionQueueClient>::recover CBC 35
<pageserver::deletion_queue::DeletionList>::save CBC 38
::save CBC 19
::save::{closure#0} CBC 19
<pageserver::deletion_queue::DeletionQueueClient>::flush_advisory CBC 38
<pageserver::deletion_queue::mock::MockDeletionQueue>::new CBC 41
<pageserver::deletion_queue::mock::MockDeletionQueue>::new_client CBC 47
<pageserver::deletion_queue::DeletionHeader as core::fmt::Debug>::fmt CBC 55
<::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 7
::deserialize::<&mut serde_json::de::Deserializer> CBC 7
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 13
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> CBC 14
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: CBC 14
<pageserver::deletion_queue::DeletionList>::push CBC 62
<pageserver::deletion_queue::DeletionQueueClient>::push_layers_sync CBC 73
<pageserver::deletion_queue::TenantDeletionList as core::fmt::Debug>::fmt CBC 86
<<::deserialize::__Visitor as serde::de::Visitor>::visit_map::__DeserializeWith as serde::de::Deserialize>::deserialize::<_> UBC 0
<<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::__DeserializeWith as serde::de::Deserialize>::deserialize::<&mut serde_json::de::Deserializer> UBC 0
<<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::__DeserializeWith as serde::de::Deserialize>::deserialize::<_> UBC 0
<::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::<_>::{closure#0} UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>::{closure#0} UBC 0
<::serialize::__SerializeWith as serde::ser::Serialize>::serialize::<_> UBC 0
<::serialize::__SerializeWith as serde::ser::Serialize>::serialize::, serde_json::ser::CompactFormatter>> UBC 0
::fmt UBC 0
::deserialize::<_> UBC 0
::serialize::<_> UBC 0
<<::deserialize::__Visitor as serde::de::Visitor>::visit_map::__DeserializeWith as serde::de::Deserialize>::deserialize::<&mut serde_json::de::Deserializer> CBC 8
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> CBC 8
::deserialize::<&mut serde_json::de::Deserializer> CBC 8
<::serialize::__SerializeWith as serde::ser::Serialize>::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 15
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 15
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> CBC 16
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: CBC 16
<pageserver::deletion_queue::DeletionList as core::fmt::Debug>::fmt CBC 126
<<::deserialize::__Visitor as serde::de::Visitor>::visit_map::__DeserializeWith as serde::de::Deserialize>::deserialize::<_> UBC 0
<<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::__DeserializeWith as serde::de::Deserialize>::deserialize::<&mut serde_json::de::Deserializer> UBC 0
<<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::__DeserializeWith as serde::de::Deserialize>::deserialize::<_> UBC 0
<::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::<_>::{closure#0} UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>::{closure#0} UBC 0
<::serialize::__SerializeWith as serde::ser::Serialize>::serialize::<_> UBC 0
<::serialize::__SerializeWith as serde::ser::Serialize>::serialize::, serde_json::ser::CompactFormatter>> UBC 0
::fmt UBC 0
::deserialize::<_> UBC 0
::serialize::<_> UBC 0
<<::deserialize::__Visitor as serde::de::Visitor>::visit_map::__DeserializeWith as serde::de::Deserialize>::deserialize::<&mut serde_json::de::Deserializer> CBC 8
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> CBC 8
::deserialize::<&mut serde_json::de::Deserializer> CBC 8
<::serialize::__SerializeWith as serde::ser::Serialize>::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 19
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 19
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> CBC 32
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: CBC 32
<pageserver::deletion_queue::DeletionQueue as core::clone::Clone>::clone CBC 144
<pageserver::deletion_queue::DeletionQueue>::shutdown::{closure#0}::{closure#0} CBC 144
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage> CBC 186
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0} CBC 186
<pageserver::deletion_queue::DeletionQueue>::shutdown CBC 288
::shutdown CBC 144
::shutdown::{closure#0} CBC 144
<pageserver::deletion_queue::DeletionQueueClient>::do_push::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage> CBC 294
<pageserver::deletion_queue::DeletionQueueClient>::flush CBC 340
::flush CBC 170
::flush::{closure#0} CBC 170
<pageserver::deletion_queue::DeletionList>::len CBC 349
<pageserver::deletion_queue::VisibleLsnUpdates as core::default::Default>::default CBC 381
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn CBC 428
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn::{closure#0} CBC 428
<pageserver::deletion_queue::DeletionList>::is_empty CBC 511
<pageserver::deletion_queue::DeletionQueue>::new::<_> CBC 564
::new::<_> UBC 0
::new:: CBC 4
::new:: CBC 560
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with CBC 564
>::spawn_with UBC 0
>::spawn_with CBC 4
>::spawn_with CBC 560
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#0} CBC 564
>::spawn_with::{closure#0} UBC 0
>::spawn_with::{closure#0} CBC 4
>::spawn_with::{closure#0} CBC 560
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#1} CBC 564
>::spawn_with::{closure#1} UBC 0
>::spawn_with::{closure#1} CBC 4
>::spawn_with::{closure#1} CBC 560
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#2} CBC 564
>::spawn_with::{closure#2} UBC 0
>::spawn_with::{closure#2} CBC 4
>::spawn_with::{closure#2} CBC 560
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#3} CBC 564
>::spawn_with::{closure#3} UBC 0
>::spawn_with::{closure#3} CBC 4
>::spawn_with::{closure#3} CBC 560
<pageserver::deletion_queue::DeletionList>::new CBC 579
<pageserver::deletion_queue::DeletionQueueClient>::push_layers CBC 591
<pageserver::deletion_queue::DeletionQueueClient>::push_layers::{closure#0} CBC 591
<pageserver::deletion_queue::VisibleLsnUpdates>::new CBC 605
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate CBC 986
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate::{closure#0} CBC 986
<pageserver::deletion_queue::DeletionQueue>::new_client CBC 1124
<pageserver::deletion_queue::FlushOp>::notify CBC 1187
<pageserver::deletion_queue::FlushOp>::new CBC 1189
<pageserver::deletion_queue::DeletionList>::into_remote_paths::{closure#0} CBC 1636
<pageserver::deletion_queue::DeletionList>::push::{closure#1} CBC 1672
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate CBC 1900
::flush_immediate CBC 950
::flush_immediate::{closure#0} CBC 950
<pageserver::deletion_queue::DeletionQueueClient as core::fmt::Debug>::fmt CBC 5566
::fmt UBC 0
::clone CBC 5566

Generated by: LCOV version 2.1-beta