LCOV - code coverage report

Current view: top level - pageserver/src - deletion_queue.rs (source / functions) Coverage Total Hit Test: c639aa5f7ab62b43d647b10f40d15a15686ce8a9.info Lines: 89.3 % 841 751 Test Date: 2024-02-12 20:26:03 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::TenantDeletionList>::len::{closure#0}	52
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute	54
::flush_execute	27
::flush_execute::{closure#0}	27
<pageserver::deletion_queue::DeletionHeader>::save	76
::save	38
::save::{closure#0}	38
<pageserver::deletion_queue::mock::MockDeletionQueue>::new	82
<pageserver::deletion_queue::mock::MockDeletionQueue>::new_client	94
<pageserver::deletion_queue::DeletionList>::push::{closure#0}	116
<pageserver::deletion_queue::DeletionList>::save	144
::save	72
::save::{closure#0}	72
<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	166
<pageserver::deletion_queue::DeletionQueue as core::clone::Clone>::clone	182
<pageserver::deletion_queue::DeletionQueue>::shutdown::{closure#0}::{closure#0}	182
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>	248
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0}	248
<pageserver::deletion_queue::TenantDeletionList as core::fmt::Debug>::fmt	305
<::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::>	38
::deserialize::<&mut serde_json::de::Deserializer>	38
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	63
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	76
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	80
<pageserver::deletion_queue::DeletionQueue>::shutdown	364
::shutdown	182
::shutdown::{closure#0}	182
<pageserver::deletion_queue::DeletionQueueClient>::flush	442
::flush	221
::flush::{closure#0}	221
<pageserver::deletion_queue::DeletionList as core::fmt::Debug>::fmt	446
<::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::>	35
::deserialize::<&mut serde_json::de::Deserializer>	35
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>>	74
<::deserialize::__Field as serde::de::Deserialize>::deserialize::>	140
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str::	148
<pageserver::deletion_queue::DeletionQueueClient>::recover	631
<pageserver::deletion_queue::DeletionQueue>::new::<_>	632
::new::<_>	0
::new::	8
::new::	624
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with	632
>::spawn_with	0
>::spawn_with	8
>::spawn_with	624
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#0}	632
>::spawn_with::{closure#0}	0
>::spawn_with::{closure#0}	8
>::spawn_with::{closure#0}	624
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#1}	632
>::spawn_with::{closure#1}	0
>::spawn_with::{closure#1}	8
>::spawn_with::{closure#1}	624
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#2}	632
>::spawn_with::{closure#2}	0
>::spawn_with::{closure#2}	8
>::spawn_with::{closure#2}	624
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#3}	632
>::spawn_with::{closure#3}	0
>::spawn_with::{closure#3}	8
>::spawn_with::{closure#3}	624
<pageserver::deletion_queue::DeletionList>::new	692
<pageserver::deletion_queue::VisibleLsnUpdates>::new	714
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate	718
<pageserver::deletion_queue::DeletionQueueClient>::push_immediate::{closure#0}	718
<pageserver::deletion_queue::VisibleLsnUpdates as core::default::Default>::default	757
<pageserver::deletion_queue::DeletionList>::is_empty	804
<pageserver::deletion_queue::FlushOp>::notify	907
<pageserver::deletion_queue::FlushOp>::new	909
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate	910
::flush_immediate	455
::flush_immediate::{closure#0}	455
<pageserver::deletion_queue::DeletionList>::into_remote_paths::{closure#0}	1068
<pageserver::deletion_queue::DeletionQueue>::new_client	1256
<pageserver::deletion_queue::DeletionList>::push::{closure#1}	3841
<pageserver::deletion_queue::DeletionList>::push	4270
<pageserver::deletion_queue::DeletionQueueClient>::push_layers_sync	4428
<pageserver::deletion_queue::DeletionQueueClient>::push_layers	4488
<pageserver::deletion_queue::DeletionQueueClient>::push_layers::{closure#0}	4488
<pageserver::deletion_queue::DeletionQueueClient>::do_push::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>	5307
<pageserver::deletion_queue::DeletionList>::len	5436
<pageserver::deletion_queue::DeletionQueueClient as core::fmt::Debug>::fmt	5506
::fmt	0
::clone	5506
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn	6026
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn::{closure#0}	6026

Generated by: LCOV version 2.1-beta