LCOV - code coverage report
Current view:
top level
-
pageserver/src/tenant/timeline/walreceiver
- connection_manager.rs
(
source
/ functions)
Coverage
Total
Hit
Test:
c639aa5f7ab62b43d647b10f40d15a15686ce8a9.info
Lines:
94.8 %
1062
1007
Test Date:
2024-02-12 20:26:03
Functions:
76.9 %
104
80
Function Name
Hit count
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::applicable_connection_candidates::{closure#2}::{closure#0}
0
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::next_connection_candidate::{closure#2}
0
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::next_connection_candidate::{closure#3}
0
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::next_connection_candidate::{closure#4}
0
<pageserver::tenant::timeline::walreceiver::connection_manager::NewCommittedWAL as core::fmt::Debug>::fmt
0
::clone
0
::fmt
0
<pageserver::tenant::timeline::walreceiver::connection_manager::RetryInfo as core::fmt::Debug>::fmt
0
::clone
0
::fmt
0
<pageserver::tenant::timeline::walreceiver::connection_manager::WalConnection as core::fmt::Debug>::fmt
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#0}
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#10}
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#11}
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#12}
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#13}
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#2}
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#4}::{closure#0}
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#4}::{closure#1}
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#4}::{closure#2}
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#5}::{closure#0}
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#7}
0
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#9}
0
pageserver::tenant::timeline::walreceiver::connection_manager::subscribe_for_timeline_updates::{closure#0}::{closure#0}
0
pageserver::tenant::timeline::walreceiver::connection_manager::tests::candidate_with_many_connection_failures
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::connection_no_candidate
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::connection_no_candidate::{closure#0}::{closure#0}
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::connection_no_candidate::{closure#0}::{closure#0}::{closure#0}
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::lsn_wal_over_threshold_current_candidate::{closure#0}::{closure#0}
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::lsn_wal_over_threshold_current_candidate::{closure#0}::{closure#0}::{closure#0}
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::no_connection_no_candidate
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::switch_to_same_availability_zone
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::switch_to_same_availability_zone::{closure#0}::{closure#0}
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::switch_to_same_availability_zone::{closure#0}::{closure#0}::{closure#0}
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_connection_threshold_current_candidate
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_connection_threshold_current_candidate::{closure#0}::{closure#0}
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_connection_threshold_current_candidate::{closure#0}::{closure#0}::{closure#0}
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::candidate_with_many_connection_failures::{closure#0}
4
pageserver::tenant::timeline::walreceiver::connection_manager::tests::connection_no_candidate::{closure#0}
4
pageserver::tenant::timeline::walreceiver::connection_manager::tests::no_connection_no_candidate::{closure#0}
4
pageserver::tenant::timeline::walreceiver::connection_manager::tests::switch_to_same_availability_zone::{closure#0}
4
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_connection_threshold_current_candidate::{closure#0}
4
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_wal_over_threshold_current_candidate::{closure#0}::{closure#0}
4
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_wal_over_threshold_current_candidate::{closure#0}::{closure#0}
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_wal_over_threshold_current_candidate::{closure#0}::{closure#0}::{closure#0}
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::lsn_wal_over_threshold_current_candidate
6
pageserver::tenant::timeline::walreceiver::connection_manager::tests::lsn_wal_over_threshold_current_candidate
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::lsn_wal_over_threshold_current_candidate::{closure#0}
4
pageserver::tenant::timeline::walreceiver::connection_manager::tests::no_connection_candidate
6
pageserver::tenant::timeline::walreceiver::connection_manager::tests::no_connection_candidate
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::no_connection_candidate::{closure#0}
4
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_wal_over_threshold_current_candidate
6
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_wal_over_threshold_current_candidate
2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_wal_over_threshold_current_candidate::{closure#0}
4
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::cleanup_old_candidates::{closure#1}
11
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#8}
13
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::change_connection::{closure#0}::{closure#0}::{closure#0}::{closure#0}
27
pageserver::tenant::timeline::walreceiver::connection_manager::tests::dummy_state
32
pageserver::tenant::timeline::walreceiver::connection_manager::tests::dummy_state
16
pageserver::tenant::timeline::walreceiver::connection_manager::tests::dummy_state::{closure#0}
16
pageserver::tenant::timeline::walreceiver::connection_manager::tests::dummy_broker_sk_timeline
38
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#1}
559
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::register_timeline_update::{closure#0}
687
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::drop_old_connection::{closure#0}::{closure#0}
994
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::next_connection_candidate::{closure#1}
1008
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::shutdown
1120
::shutdown
560
::shutdown::{closure#0}
560
pageserver::tenant::timeline::walreceiver::connection_manager::subscribe_for_timeline_updates
1256
pageserver::tenant::timeline::walreceiver::connection_manager::subscribe_for_timeline_updates::{closure#0}
1256
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::new
1257
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step
1257
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}
1257
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::change_connection::{closure#0}::{closure#0}::{closure#0}::{closure#1}
1394
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::change_connection::{closure#0}::{closure#0}
1703
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::change_connection::{closure#0}::{closure#0}::{closure#0}
1703
<pageserver::tenant::timeline::walreceiver::connection_manager::NewWalConnectionCandidate as core::fmt::Debug>::fmt
1703
<pageserver::tenant::timeline::walreceiver::connection_manager::ReconnectReason>::name
1703
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#14}
1703
<pageserver::tenant::timeline::walreceiver::connection_manager::ReconnectReason as core::fmt::Debug>::fmt
1711
::eq
8
::fmt
1703
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerStatus as core::fmt::Debug>::fmt
1865
::fmt
0
::clone
1865
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerStatus>::to_human_readable_string
1865
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::change_connection
3406
::change_connection
1703
::change_connection::{closure#0}
1703
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::next_connection_candidate::{closure#0}
4389
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::drop_old_connection
6152
::drop_old_connection
3076
::drop_old_connection::{closure#0}
3076
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::register_timeline_update
8263
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::applicable_connection_candidates::{closure#1}::{closure#0}
206682
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::time_until_next_retry::{closure#0}
206694
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::time_until_next_retry::{closure#1}
206694
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::select_connection_candidate::{closure#1}
427517
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#4}
726333
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#5}
731320
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::manager_status::{closure#0}
734222
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::manager_status
735131
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::applicable_connection_candidates
735149
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::cleanup_old_candidates
735149
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::next_connection_candidate
735149
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::select_connection_candidate
735149
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#3}
736218
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::time_until_next_retry
736370
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::select_connection_candidate::{closure#0}
1160056
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::applicable_connection_candidates::{closure#2}
1160060
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::applicable_connection_candidates::{closure#1}
1161891
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::applicable_connection_candidates::{closure#0}
1161895
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::cleanup_old_candidates::{closure#0}
1161906
<pageserver::tenant::timeline::walreceiver::connection_manager::BrokerSkTimeline as core::fmt::Debug>::fmt
1163869
::fmt
0
::clone
1163869
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#6}
1450465
Generated by:
LCOV version 2.1-beta