LCOV - code coverage report
Current view: top level - safekeeper/src - send_wal.rs (source / functions) Coverage Total Hit
Test: 1b0a6a0c05cee5a7de360813c8034804e105ce1c.info Lines: 17.2 % 696 120
Test Date: 2025-03-12 00:01:28 Functions: 17.6 % 91 16

Function Name Sort by function name Hit count Sort by function hit count
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<_> 0
::handle_start_replication::<_> 0
::handle_start_replication::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> 0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<_>::{closure#0} 0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<_>::{closure#0}::{closure#0} 0
::handle_start_replication::<_>::{closure#0}::{closure#0} 0
::handle_start_replication::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#0} 0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} 0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_> 0
::handle_start_replication_guts::<_> 0
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> 0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0} 0
::handle_start_replication_guts::<_>::{closure#0} 0
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} 0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#0} 0
::handle_start_replication_guts::<_>::{closure#0}::{closure#0} 0
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#0} 0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#0}::{closure#0} 0
::handle_start_replication_guts::<_>::{closure#0}::{closure#0}::{closure#0} 0
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#0}::{closure#0} 0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#1} 0
::handle_start_replication_guts::<_>::{closure#0}::{closure#1} 0
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#1} 0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#2} 0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#2}::{closure#0} 0
::handle_start_replication_guts::<_>::{closure#0}::{closure#2}::{closure#0} 0
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#2}::{closure#0} 0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#2} 0
<safekeeper::send_wal::EndWatch>::changed 14
::changed 7
::changed::{closure#0} 7
<safekeeper::send_wal::EndWatch>::get 12
<safekeeper::send_wal::EndWatch>::view 0
<safekeeper::send_wal::EndWatch>::wait_for_lsn 4
<safekeeper::send_wal::EndWatch>::wait_for_lsn::{closure#0} 4
<safekeeper::send_wal::EndWatchView>::get 0
<safekeeper::send_wal::ReplyReader<_>>::handle_feedback 0
>::handle_feedback 0
>::handle_feedback::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback::{closure#0} 0
<safekeeper::send_wal::ReplyReader<_>>::run 0
>::run 0
>::run::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run 0
<safekeeper::send_wal::ReplyReader<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0} 0
<safekeeper::send_wal::WalSender<_>>::run 0
>::run 0
>::run::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0} 0
<safekeeper::send_wal::WalSender<_>>::wait_for_lsn 0
>::wait_for_lsn 0
>::wait_for_lsn::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_for_lsn 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_for_lsn::{closure#0} 0
<safekeeper::send_wal::WalSender<_>>::wait_for_lsn::{closure#0}::{closure#0} 0
<safekeeper::send_wal::WalSender<_>>::wait_for_lsn::{closure#0}::{closure#0}::{closure#0} 0
>::wait_for_lsn::{closure#0}::{closure#0}::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_for_lsn::{closure#0}::{closure#0}::{closure#0} 0
<safekeeper::send_wal::WalSender<_>>::wait_for_lsn::{closure#0}::{closure#1} 0
<safekeeper::send_wal::WalSender<_>>::wait_wal 0
>::wait_wal 0
>::wait_wal::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal 0
<safekeeper::send_wal::WalSender<_>>::wait_wal::{closure#0}::{closure#0} 0
<safekeeper::send_wal::WalSender<_>>::wait_wal::{closure#0}::{closure#0}::{closure#0} 0
>::wait_wal::{closure#0}::{closure#0}::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal::{closure#0}::{closure#0}::{closure#0} 0
<safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_for_lsn::{closure#0}::{closure#0} 0
<safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_for_lsn::{closure#0}::{closure#1} 0
<safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal::{closure#0} 0
<safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal::{closure#0}::{closure#0} 0
<safekeeper::send_wal::WalSenderGuard as core::ops::drop::Drop>::drop 0
<safekeeper::send_wal::WalSenderGuard>::id 0
<safekeeper::send_wal::WalSenderGuard>::walsenders 0
<safekeeper::send_wal::WalSenderState>::get_addr 0
<safekeeper::send_wal::WalSenderState>::get_feedback 4
<safekeeper::send_wal::WalSenderState>::get_mut_feedback 0
<safekeeper::send_wal::WalSenders>::create_or_update_interpreted_reader::<_, _> 0
::create_or_update_interpreted_reader::<::handle_start_replication_guts>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#0}, ::handle_start_replication_guts>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#1}> 0
::create_or_update_interpreted_reader::<_, _> 0
<safekeeper::send_wal::WalSenders>::get_all_public 0
<safekeeper::send_wal::WalSenders>::get_all_public::{closure#0} 0
<safekeeper::send_wal::WalSenders>::get_hotstandby 620
<safekeeper::send_wal::WalSenders>::get_ws_remote_consistent_lsn 0
<safekeeper::send_wal::WalSenders>::info_for_metrics 0
<safekeeper::send_wal::WalSenders>::info_for_metrics::{closure#0} 0
<safekeeper::send_wal::WalSenders>::info_for_metrics::{closure#1} 0
<safekeeper::send_wal::WalSenders>::laggard_lsn 0
<safekeeper::send_wal::WalSenders>::laggard_lsn::{closure#0} 0
<safekeeper::send_wal::WalSenders>::new 5
<safekeeper::send_wal::WalSenders>::record_hs_feedback 0
<safekeeper::send_wal::WalSenders>::record_ps_feedback 0
<safekeeper::send_wal::WalSenders>::record_standby_reply 0
<safekeeper::send_wal::WalSenders>::register 0
<safekeeper::send_wal::WalSenders>::register::{closure#0} 0
<safekeeper::send_wal::WalSenders>::unregister 0
<safekeeper::send_wal::WalSendersShared>::get_slot 0
<safekeeper::send_wal::WalSendersShared>::get_slot_mut 0
<safekeeper::send_wal::WalSendersShared>::new 7
<safekeeper::send_wal::WalSendersShared>::update_reply_feedback 2
safekeeper::send_wal::tests::hs_feedback 4
safekeeper::send_wal::tests::mock_addr 4
safekeeper::send_wal::tests::mock_ttid 4
safekeeper::send_wal::tests::push_feedback 4
safekeeper::send_wal::tests::test_hs_feedback 1
safekeeper::send_wal::tests::test_hs_feedback_no_valid 1

Generated by: LCOV version 2.1-beta