LCOV - code coverage report
Current view:
top level
-
pageserver/src
- deletion_queue.rs
(
source
/ functions)
Coverage
Total
Hit
Test:
7eb96e224e685167ad85f58f858387d8cf253f63.info
Lines:
87.3 %
829
724
Test Date:
2024-09-23 21:23:07
Functions:
56.8 %
132
75
Function Name
Hit count
<<pageserver::deletion_queue::DeletionHeader as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::expecting
0
<
::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
<<pageserver::deletion_queue::DeletionList as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::expecting
162
<
::deserialize::__Field as serde::de::Deserialize>::deserialize::<_>
0
<
::deserialize::__Field as serde::de::Deserialize>::deserialize::
>
48
<
::deserialize::__Field as serde::de::Deserialize>::deserialize::
>
24
<
::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::
72
<
::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::
>
12
<
::deserialize::__Visitor as serde::de::Visitor>::visit_map::
>
6
<
::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
<<pageserver::deletion_queue::TenantDeletionList as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::expecting
90
<
::deserialize::__Field as serde::de::Deserialize>::deserialize::<_>
0
<
::deserialize::__Field as serde::de::Deserialize>::deserialize::
>
24
<
::deserialize::__Field as serde::de::Deserialize>::deserialize::
>
12
<
::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::
36
<
::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::
>
12
<
::deserialize::__Visitor as serde::de::Visitor>::visit_map::
>
6
<
::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
<pageserver::deletion_queue::DeletionHeader>::new
24
<pageserver::deletion_queue::DeletionHeader>::save
48
::save
24
::save::{closure#0}
24
<pageserver::deletion_queue::DeletionList as core::fmt::Display>::fmt
0
<pageserver::deletion_queue::DeletionList>::into_remote_paths
30
<pageserver::deletion_queue::DeletionList>::into_remote_paths::{closure#0}
18
<pageserver::deletion_queue::DeletionList>::is_empty
83
<pageserver::deletion_queue::DeletionList>::len
180
<pageserver::deletion_queue::DeletionList>::new
60
<pageserver::deletion_queue::DeletionList>::push
42
<pageserver::deletion_queue::DeletionList>::push::{closure#0}
36
<pageserver::deletion_queue::DeletionList>::push::{closure#1}
36
<pageserver::deletion_queue::DeletionList>::save
84
::save
42
::save::{closure#0}
42
<pageserver::deletion_queue::DeletionQueue>::new::<_>
24
::new::<_>
0
::new::
0
::new::
24
<pageserver::deletion_queue::DeletionQueue>::new_client
24
<pageserver::deletion_queue::DeletionQueue>::shutdown
0
::shutdown
0
::shutdown::{closure#0}
0
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>
72
<pageserver::deletion_queue::DeletionQueueClient>::do_flush::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>::{closure#0}
72
<pageserver::deletion_queue::DeletionQueueClient>::do_push::<pageserver::deletion_queue::list_writer::ListWriterQueueMessage>
839
<pageserver::deletion_queue::DeletionQueueClient>::flush
84
::flush
42
::flush::{closure#0}
42
<pageserver::deletion_queue::DeletionQueueClient>::flush_advisory
0
<pageserver::deletion_queue::DeletionQueueClient>::flush_execute
60
::flush_execute
30
::flush_execute::{closure#0}
30
<pageserver::deletion_queue::DeletionQueueClient>::flush_immediate
60
::flush_immediate
30
::flush_immediate::{closure#0}
30
<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
743
<pageserver::deletion_queue::DeletionQueueClient>::push_layers::{closure#0}
743
<pageserver::deletion_queue::DeletionQueueClient>::push_layers_sync
743
<pageserver::deletion_queue::DeletionQueueClient>::recover
24
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn
4216
<pageserver::deletion_queue::DeletionQueueClient>::update_remote_consistent_lsn::{closure#0}
4216
<pageserver::deletion_queue::DeletionQueueError as core::fmt::Display>::fmt
0
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with
24
>::spawn_with
0
>::spawn_with
0
>::spawn_with
24
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#0}
24
>::spawn_with::{closure#0}
0
>::spawn_with::{closure#0}
0
>::spawn_with::{closure#0}
24
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#1}
24
>::spawn_with::{closure#1}
0
>::spawn_with::{closure#1}
0
>::spawn_with::{closure#1}
24
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#2}
24
>::spawn_with::{closure#2}
0
>::spawn_with::{closure#2}
0
>::spawn_with::{closure#2}
24
<pageserver::deletion_queue::DeletionQueueWorkers<_>>::spawn_with::{closure#3}
24
>::spawn_with::{closure#3}
0
>::spawn_with::{closure#3}
0
>::spawn_with::{closure#3}
24
<pageserver::deletion_queue::FlushOp>::new
126
<pageserver::deletion_queue::FlushOp>::notify
126
<pageserver::deletion_queue::TenantDeletionList>::len
30
<pageserver::deletion_queue::TenantDeletionList>::len::{closure#0}
30
<pageserver::deletion_queue::VisibleLsnUpdates as core::fmt::Debug>::fmt
0
<pageserver::deletion_queue::VisibleLsnUpdates>::new
594
<pageserver::deletion_queue::mock::ConsumerState>::consume
12
::consume
6
::consume::{closure#0}
6
<pageserver::deletion_queue::mock::MockDeletionQueue>::new
570
<pageserver::deletion_queue::mock::MockDeletionQueue>::new_client
600
<pageserver::deletion_queue::mock::MockDeletionQueue>::pump
12
::pump
6
::pump::{closure#0}
6
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::re_attach
0
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::re_attach::{closure#0}
0
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::validate
24
<pageserver::deletion_queue::test::MockControlPlane as pageserver::control_plane_client::ControlPlaneGenerationsApi>::validate::{closure#0}
24
<pageserver::deletion_queue::test::MockControlPlane>::new
18
<pageserver::deletion_queue::test::TestSetup>::restart
12
::restart
6
::restart::{closure#0}
6
<pageserver::deletion_queue::test::TestSetup>::set_latest_generation
18
<pageserver::deletion_queue::test::TestSetup>::write_remote_layer
18
pageserver::deletion_queue::mock::deletion_list_serialization
6
pageserver::deletion_queue::test::assert_local_files
30
pageserver::deletion_queue::test::assert_remote_files
54
pageserver::deletion_queue::test::assert_remote_files::{closure#0}
48
pageserver::deletion_queue::test::deletion_queue_recovery
12
pageserver::deletion_queue::test::deletion_queue_recovery
6
pageserver::deletion_queue::test::deletion_queue_recovery::{closure#0}
6
pageserver::deletion_queue::test::deletion_queue_smoke
12
pageserver::deletion_queue::test::deletion_queue_smoke
6
pageserver::deletion_queue::test::deletion_queue_smoke::{closure#0}
6
pageserver::deletion_queue::test::deletion_queue_validation
12
pageserver::deletion_queue::test::deletion_queue_validation
6
pageserver::deletion_queue::test::deletion_queue_validation::{closure#0}
6
pageserver::deletion_queue::test::setup
36
pageserver::deletion_queue::test::setup
18
pageserver::deletion_queue::test::setup::{closure#0}
18
Generated by:
LCOV version 2.1-beta