LCOV - code coverage report

Current view: top level - pageserver/src - deletion_queue.rs (source / functions) Coverage Total Hit Test: aca8877be6ceba750c1be359ed71bc1799d52b30.info Lines: 89.3 % 842 752 Test Date: 2024-02-14 18:05:35 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	2
pageserver::deletion_queue::test::deletion_queue_recovery::{closure#0}::{closure#0}	2
pageserver::deletion_queue::test::deletion_queue_smoke	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	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::deletion_queue_recovery::{closure#0}	4
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}	4
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}	4
<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::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	38
<pageserver::deletion_queue::TenantDeletionList>::len	40
<pageserver::deletion_queue::DeletionList>::into_remote_paths	42
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute	54
::flush_execute	27
::flush_execute::{closure#0}	27
<pageserver::deletion_queue::TenantDeletionList>::len::{closure#0}	54
<pageserver::deletion_queue::DeletionHeader>::save	76
::save	38
::save::{closure#0}	38
<pageserver::deletion_queue::mock::MockDeletionQueue>::new	84
<pageserver::deletion_queue::mock::MockDeletionQueue>::new_client	96
<pageserver::deletion_queue::DeletionList>::push::{closure#0}	112
<pageserver::deletion_queue::DeletionList>::save	138
::save	69
::save::{closure#0}	69
<pageserver::deletion_queue::DeletionHeader as core::fmt::Debug>::fmt	146
<::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>>	38
<pageserver::deletion_queue::DeletionQueueClient>::flush_advisory	163
<pageserver::deletion_queue::DeletionQueue as core::clone::Clone>::clone	183
<pageserver::deletion_queue::DeletionQueue>::shutdown::{closure#0}::{closure#0}	183
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>	249
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0}	249
<pageserver::deletion_queue::TenantDeletionList as core::fmt::Debug>::fmt	278
<::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::>	34
::deserialize::<&mut serde_json::de::Deserializer>	34
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	60
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	68
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	72
<pageserver::deletion_queue::DeletionQueue>::shutdown	366
::shutdown	183
::shutdown::{closure#0}	183
<pageserver::deletion_queue::DeletionList as core::fmt::Debug>::fmt	403
<::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::>	31
::deserialize::<&mut serde_json::de::Deserializer>	31
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	71
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	124
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	132
<pageserver::deletion_queue::DeletionQueueClient>::flush	444
::flush	222
::flush::{closure#0}	222
<pageserver::deletion_queue::DeletionQueueClient>::recover	632
<pageserver::deletion_queue::DeletionQueue>::new::<_>	633
::new::<_>	0
::new::	8
::new::	625
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with	633
>::spawn_with	0
>::spawn_with	8
>::spawn_with	625
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#0}	633
>::spawn_with::{closure#0}	0
>::spawn_with::{closure#0}	8
>::spawn_with::{closure#0}	625
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#1}	633
>::spawn_with::{closure#1}	0
>::spawn_with::{closure#1}	8
>::spawn_with::{closure#1}	625
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#2}	633
>::spawn_with::{closure#2}	0
>::spawn_with::{closure#2}	8
>::spawn_with::{closure#2}	625
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#3}	633
>::spawn_with::{closure#3}	0
>::spawn_with::{closure#3}	8
>::spawn_with::{closure#3}	625
<pageserver::deletion_queue::DeletionList>::new	690
<pageserver::deletion_queue::VisibleLsnUpdates>::new	717
<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	812
<pageserver::deletion_queue::DeletionList>::is_empty	835
<pageserver::deletion_queue::FlushOp>::notify	907
<pageserver::deletion_queue::FlushOp>::new	909
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate	914
::flush_immediate	457
::flush_immediate::{closure#0}	457
<pageserver::deletion_queue::DeletionList>::into_remote_paths::{closure#0}	1082
<pageserver::deletion_queue::DeletionQueue>::new_client	1258
<pageserver::deletion_queue::DeletionList>::push::{closure#1}	3675
<pageserver::deletion_queue::DeletionList>::push	4100
<pageserver::deletion_queue::DeletionQueueClient>::push_layers_sync	4259
<pageserver::deletion_queue::DeletionQueueClient>::push_layers	4319
<pageserver::deletion_queue::DeletionQueueClient>::push_layers::{closure#0}	4319
<pageserver::deletion_queue::DeletionQueueClient>::do_push::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>	5140
<pageserver::deletion_queue::DeletionList>::len	5252
<pageserver::deletion_queue::DeletionQueueClient as core::fmt::Debug>::fmt	5513
::fmt	0
::clone	5513
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn	5964
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn::{closure#0}	5964

Generated by: LCOV version 2.1-beta