LCOV - code coverage report

Current view: top level - safekeeper/src - receive_wal.rs (source / functions) Coverage Total Hit Test: 98683a8629f0f7f0031d02e04512998d589d76ea.info Lines: 37.5 % 365 137 Test Date: 2025-04-11 16:58:57 Functions: 38.9 % 36 14

Function Name	Hit count
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_wal_push::<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}>>	0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_wal_push::<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_wal_push_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}>>	0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_wal_push_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}	0
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_wal_push_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#0}	0
<safekeeper::receive_wal::NetworkReader<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}>>>::read_first_message	0
<safekeeper::receive_wal::NetworkReader<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}>>>::read_first_message::{closure#0}	0
<safekeeper::receive_wal::NetworkReader<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	0
<safekeeper::receive_wal::NetworkReader<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::receive_wal::WalReceiverGuard>::get	0
<safekeeper::receive_wal::WalReceivers>::broadcast_pageserver_feedback	0
<safekeeper::receive_wal::WalReceivers>::get_all	0
<safekeeper::receive_wal::WalReceivers>::get_num	0
<safekeeper::receive_wal::WalReceivers>::get_slot	0
<safekeeper::receive_wal::WalReceivers>::get_slot::{closure#0}	0
<safekeeper::receive_wal::WalReceivers>::register::{closure#0}	0
safekeeper::receive_wal::network_write::<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}>>	0
safekeeper::receive_wal::network_write::<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::receive_wal::read_message::<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}>>	0
safekeeper::receive_wal::read_message::<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::receive_wal::read_network_loop::<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}>>	0
safekeeper::receive_wal::read_network_loop::<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::receive_wal::WalAcceptor as core::ops::drop::Drop>::drop	5
<safekeeper::receive_wal::WalAcceptor>::spawn	5
<safekeeper::receive_wal::WalAcceptor>::spawn::{closure#0}	5
<safekeeper::receive_wal::WalReceiverGuard as core::ops::drop::Drop>::drop	5
<safekeeper::receive_wal::WalReceivers>::get_num_rx	5
<safekeeper::receive_wal::WalReceivers>::new	5
<safekeeper::receive_wal::WalReceivers>::register	5
<safekeeper::receive_wal::WalReceivers>::unregister	5
<safekeeper::receive_wal::WalAcceptor>::run	10
::run	5
::run::{closure#0}	5
<safekeeper::receive_wal::WalReceivers>::get_num_streaming::{closure#0}	10
<safekeeper::receive_wal::WalReceivers>::update_num	10
<safekeeper::receive_wal::WalReceiversShared>::get_num	10
<safekeeper::receive_wal::WalReceivers>::get_num_streaming	15

Generated by: LCOV version 2.1-beta