LCOV - code coverage report

Current view: top level - pageserver/src/tenant/timeline/walreceiver - connection_manager.rs (source / functions) Coverage Total Hit Test: 8ac049b474321fdc72ddcb56d7165153a1a900e8.info Lines: 92.5 % 1004 929 Test Date: 2023-09-06 10:18:01 Functions: 76.5 % 98 75

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#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::connection_no_candidate::{closure#0}::{closure#0}::{closure#0}	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::lsn_wal_over_threshold_current_candidate	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::lsn_wal_over_threshold_current_candidate::{closure#0}::{closure#0}::{closure#0}	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::no_connection_candidate	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::switch_to_same_availability_zone::{closure#0}::{closure#0}::{closure#0}	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_connection_threshold_current_candidate::{closure#0}::{closure#0}::{closure#0}	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_wal_over_threshold_current_candidate::{closure#0}::{closure#0}::{closure#0}	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::lsn_wal_over_threshold_current_candidate::{closure#0}	2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::no_connection_candidate::{closure#0}	2
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerStatus as core::fmt::Debug>::fmt	3
::fmt	0
::clone	3
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerStatus>::to_human_readable_string	3
pageserver::tenant::timeline::walreceiver::connection_manager::tests::candidate_with_many_connection_failures	3
pageserver::tenant::timeline::walreceiver::connection_manager::tests::candidate_with_many_connection_failures	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::candidate_with_many_connection_failures::{closure#0}	2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::connection_no_candidate	3
pageserver::tenant::timeline::walreceiver::connection_manager::tests::connection_no_candidate	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::connection_no_candidate::{closure#0}	2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::no_connection_no_candidate	3
pageserver::tenant::timeline::walreceiver::connection_manager::tests::no_connection_no_candidate	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::no_connection_no_candidate::{closure#0}	2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::switch_to_same_availability_zone	3
pageserver::tenant::timeline::walreceiver::connection_manager::tests::switch_to_same_availability_zone	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::switch_to_same_availability_zone::{closure#0}	2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_connection_threshold_current_candidate	3
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_connection_threshold_current_candidate	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_connection_threshold_current_candidate::{closure#0}	2
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_wal_over_threshold_current_candidate	3
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_wal_over_threshold_current_candidate	1
pageserver::tenant::timeline::walreceiver::connection_manager::tests::timeout_wal_over_threshold_current_candidate::{closure#0}	2
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::cleanup_old_candidates::{closure#1}	8
pageserver::tenant::timeline::walreceiver::connection_manager::tests::dummy_state	8
pageserver::tenant::timeline::walreceiver::connection_manager::tests::dummy_state::{closure#0}	8
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#8}	10
pageserver::tenant::timeline::walreceiver::connection_manager::tests::dummy_broker_sk_timeline	19
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::change_connection::{closure#0}::{closure#0}::{closure#0}::{closure#0}	129
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::next_connection_candidate::{closure#1}	137
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::shutdown::{closure#0}	241
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::shutdown	493
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#1}	493
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::drop_old_connection::{closure#0}::{closure#0}	500
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::register_timeline_update::{closure#0}	611
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::change_connection::{closure#0}::{closure#0}::{closure#0}::{closure#1}	817
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::new	1190
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step	1190
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}	1190
pageserver::tenant::timeline::walreceiver::connection_manager::subscribe_for_timeline_updates	1190
pageserver::tenant::timeline::walreceiver::connection_manager::subscribe_for_timeline_updates::{closure#0}	1190
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::change_connection::{closure#0}::{closure#0}	1222
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::change_connection::{closure#0}::{closure#0}::{closure#0}	1222
<pageserver::tenant::timeline::walreceiver::connection_manager::NewWalConnectionCandidate as core::fmt::Debug>::fmt	1222
<pageserver::tenant::timeline::walreceiver::connection_manager::ReconnectReason>::name	1222
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#13}	1222
<pageserver::tenant::timeline::walreceiver::connection_manager::ReconnectReason as core::fmt::Debug>::fmt	1226
::eq	4
::fmt	1222
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::change_connection	2444
::change_connection	1222
::change_connection::{closure#0}	1222
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::next_connection_candidate::{closure#0}	3200
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::drop_old_connection	4256
::drop_old_connection	2128
::drop_old_connection::{closure#0}	2128
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::register_timeline_update	5714
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::applicable_connection_candidates::{closure#1}::{closure#0}	244214
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::time_until_next_retry::{closure#0}	244226
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::time_until_next_retry::{closure#1}	244226
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::select_connection_candidate::{closure#1}	652474
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#4}	705461
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#5}	710876
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::manager_status::{closure#0}	714768
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::manager_status	715188
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::applicable_connection_candidates	715197
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::cleanup_old_candidates	715197
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::next_connection_candidate	715197
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::select_connection_candidate	715197
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#3}	716320
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::time_until_next_retry	716370
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::select_connection_candidate::{closure#0}	1366038
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::applicable_connection_candidates::{closure#2}	1366040
<pageserver::tenant::timeline::walreceiver::connection_manager::BrokerSkTimeline as core::fmt::Debug>::fmt	1367192
::fmt	0
::clone	1367192
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::applicable_connection_candidates::{closure#1}	1367198
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::applicable_connection_candidates::{closure#0}	1367203
<pageserver::tenant::timeline::walreceiver::connection_manager::ConnectionManagerState>::cleanup_old_candidates::{closure#0}	1367211
pageserver::tenant::timeline::walreceiver::connection_manager::connection_manager_loop_step::{closure#0}::{closure#6}	1408852

Generated by: LCOV version 2.1-beta