LCOV - code coverage report
Current view: top level - libs/pq_proto/src - framed.rs (source / functions) Coverage Total Hit
Test: 1e20c4f2b28aa592527961bb32170ebbd2c9172f.info Lines: 37.2 % 121 45
Test Date: 2025-07-16 12:29:03 Functions: 12.4 % 129 16

Function Name Sort by function name Hit count Sort by function hit count
<pq_proto::framed::ConnectionError>::into_io_error 0
<pq_proto::framed::Framed<_>>::flush 5
>::flush 0
>::flush::{closure#0} 0
>>>>>::flush 0
>>::flush 5
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::flush 0
<pq_proto::framed::Framed<_>>::get_ref 0
<pq_proto::framed::Framed<_>>::into_inner 0
<pq_proto::framed::Framed<_>>::map_stream::<_, _, _, _> 1
>::map_stream::<_, _, _, _> 0
>>>>>::map_stream::>>>, anyhow::Error, >>>>::start_tls::{closure#0}::{closure#0}, >>>>::tls_upgrade::{closure#0}> 0
>>::map_stream::, anyhow::Error, >::start_tls::{closure#0}::{closure#0}, >::tls_upgrade::{closure#0}> 1
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::map_stream::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>, anyhow::Error, >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::start_tls::{closure#0}::{closure#0}, >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::tls_upgrade::{closure#0}> 0
<pq_proto::framed::Framed<_>>::map_stream::<_, _, _, _>::{closure#0} 0
<pq_proto::framed::Framed<_>>::new 2
>::new 0
>>>>>::new 0
>>::new 2
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::new 0
<pq_proto::framed::Framed<_>>::read_message 4
>::read_message 0
>::read_message::{closure#0} 0
>>>>>::read_message 0
>>::read_message 4
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_message 0
<pq_proto::framed::Framed<_>>::read_startup_message 3
>::read_startup_message 0
>>>>>::read_startup_message 0
>>::read_startup_message 3
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_startup_message 0
<pq_proto::framed::Framed<_>>::read_startup_message::{closure#0} 0
<pq_proto::framed::Framed<_>>::shutdown 0
>::shutdown 0
>::shutdown::{closure#0} 0
>>>>>::shutdown 0
>>::shutdown 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::shutdown 0
<pq_proto::framed::Framed<_>>::split 0
>::split 0
>>>>>::split 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::split 0
<pq_proto::framed::Framed<_>>::unsplit 0
>::unsplit 0
>>>>>::unsplit 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::unsplit 0
<pq_proto::framed::Framed<_>>::write_message 19
>::write_message 0
>>>>>::write_message 0
>>::write_message 19
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::write_message 0
<pq_proto::framed::Framed<postgres_backend::MaybeTlsStream<tokio::net::tcp::stream::TcpStream>>>::flush::{closure#0} 5
>>>>>::flush::{closure#0} 0
>>::flush::{closure#0} 5
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::flush::{closure#0} 0
<pq_proto::framed::Framed<postgres_backend::MaybeTlsStream<tokio::net::tcp::stream::TcpStream>>>::map_stream::<postgres_backend::MaybeTlsStream<tokio::net::tcp::stream::TcpStream>, anyhow::Error, <postgres_backend::PostgresBackend<tokio::net::tcp::stream::TcpStream>>::start_tls::{closure#0}::{closure#0}, <postgres_backend::PostgresBackend<tokio::net::tcp::stream::TcpStream>>::tls_upgrade::{closure#0}>::{closure#0} 1
>>>>>::map_stream::>>>, anyhow::Error, >>>>::start_tls::{closure#0}::{closure#0}, >>>>::tls_upgrade::{closure#0}>::{closure#0} 0
>>::map_stream::, anyhow::Error, >::start_tls::{closure#0}::{closure#0}, >::tls_upgrade::{closure#0}>::{closure#0} 1
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::map_stream::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>, anyhow::Error, >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::start_tls::{closure#0}::{closure#0}, >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::tls_upgrade::{closure#0}>::{closure#0} 0
<pq_proto::framed::Framed<postgres_backend::MaybeTlsStream<tokio::net::tcp::stream::TcpStream>>>::read_message::{closure#0} 4
>>>>>::read_message::{closure#0} 0
>>::read_message::{closure#0} 4
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_message::{closure#0} 0
<pq_proto::framed::Framed<postgres_backend::MaybeTlsStream<tokio::net::tcp::stream::TcpStream>>>::read_startup_message::{closure#0} 3
>>>>>::read_startup_message::{closure#0} 0
>>::read_startup_message::{closure#0} 3
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_startup_message::{closure#0} 0
<pq_proto::framed::Framed<postgres_backend::MaybeTlsStream<tokio::net::tcp::stream::TcpStream>>>::shutdown::{closure#0} 0
>>>>>::shutdown::{closure#0} 0
>>::shutdown::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::shutdown::{closure#0} 0
<pq_proto::framed::FramedReader<_>>::read_message 0
>::read_message 0
>::read_message::{closure#0} 0
>>>>>::read_message 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_message 0
<pq_proto::framed::FramedReader<postgres_backend::MaybeTlsStream<core::pin::Pin<alloc::boxed::Box<tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>>>>>::read_message::{closure#0} 0
>>>>>::read_message::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_message::{closure#0} 0
<pq_proto::framed::FramedWriter<_>>::flush 0
>::flush 0
>::flush::{closure#0} 0
>>>>>::flush 0
>>::flush 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::flush 0
<pq_proto::framed::FramedWriter<_>>::shutdown 0
>::shutdown 0
>::shutdown::{closure#0} 0
>>>>>::shutdown 0
>>::shutdown 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::shutdown 0
<pq_proto::framed::FramedWriter<_>>::write_message_noflush 0
>::write_message_noflush 0
>>>>>::write_message_noflush 0
>>::write_message_noflush 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::write_message_noflush 0
<pq_proto::framed::FramedWriter<postgres_backend::MaybeTlsStream<tokio::net::tcp::stream::TcpStream>>>::flush::{closure#0} 0
>>>>>::flush::{closure#0} 0
>>::flush::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::flush::{closure#0} 0
<pq_proto::framed::FramedWriter<postgres_backend::MaybeTlsStream<tokio::net::tcp::stream::TcpStream>>>::shutdown::{closure#0} 0
>>>>>::shutdown::{closure#0} 0
>>::shutdown::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::shutdown::{closure#0} 0
pq_proto::framed::flush::<_> 5
pq_proto::framed::flush::<_> 0
pq_proto::framed::flush::>>>> 0
pq_proto::framed::flush::> 5
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>> 0
pq_proto::framed::flush::>>>>> 0
pq_proto::framed::flush::>> 0
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>> 0
pq_proto::framed::flush::<_>::{closure#0} 0
pq_proto::framed::flush::<postgres_backend::MaybeTlsStream<tokio::net::tcp::stream::TcpStream>>::{closure#0} 10
pq_proto::framed::flush::>>>>::{closure#0} 0
pq_proto::framed::flush::>::{closure#0} 10
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::{closure#0} 0
pq_proto::framed::flush::>>>>>::{closure#0} 0
pq_proto::framed::flush::>>::{closure#0} 0
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::{closure#0} 0
pq_proto::framed::read_message::<_, _, _> 7
pq_proto::framed::read_message::<_, _, _> 0
pq_proto::framed::read_message::>>>, pq_proto::FeMessage, ::parse> 0
pq_proto::framed::read_message::>>>, pq_proto::FeStartupPacket, ::parse> 0
pq_proto::framed::read_message::, pq_proto::FeMessage, ::parse> 4
pq_proto::framed::read_message::, pq_proto::FeStartupPacket, ::parse> 3
pq_proto::framed::read_message::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>, pq_proto::FeMessage, ::parse> 0
pq_proto::framed::read_message::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>, pq_proto::FeStartupPacket, ::parse> 0
pq_proto::framed::read_message::>>>>, pq_proto::FeMessage, ::parse> 0
pq_proto::framed::read_message::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>, pq_proto::FeMessage, ::parse> 0
pq_proto::framed::read_message::<_, _, _>::{closure#0} 0
pq_proto::framed::read_message::<postgres_backend::MaybeTlsStream<tokio::net::tcp::stream::TcpStream>, pq_proto::FeMessage, <pq_proto::FeMessage>::parse>::{closure#0} 5
pq_proto::framed::read_message::>>>, pq_proto::FeMessage, ::parse>::{closure#0} 0
pq_proto::framed::read_message::>>>, pq_proto::FeStartupPacket, ::parse>::{closure#0} 0
pq_proto::framed::read_message::, pq_proto::FeMessage, ::parse>::{closure#0} 2
pq_proto::framed::read_message::, pq_proto::FeStartupPacket, ::parse>::{closure#0} 3
pq_proto::framed::read_message::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>, pq_proto::FeMessage, ::parse>::{closure#0} 0
pq_proto::framed::read_message::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>, pq_proto::FeStartupPacket, ::parse>::{closure#0} 0
pq_proto::framed::read_message::>>>>, pq_proto::FeMessage, ::parse>::{closure#0} 0
pq_proto::framed::read_message::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>, pq_proto::FeMessage, ::parse>::{closure#0} 0
pq_proto::framed::shutdown::<_> 0
pq_proto::framed::shutdown::<_> 0
pq_proto::framed::shutdown::>>>> 0
pq_proto::framed::shutdown::> 0
pq_proto::framed::shutdown::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>> 0
pq_proto::framed::shutdown::>>>>> 0
pq_proto::framed::shutdown::>> 0
pq_proto::framed::shutdown::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>> 0
pq_proto::framed::shutdown::<_>::{closure#0} 0
pq_proto::framed::shutdown::<postgres_backend::MaybeTlsStream<tokio::net::tcp::stream::TcpStream>>::{closure#0} 0
pq_proto::framed::shutdown::>>>>::{closure#0} 0
pq_proto::framed::shutdown::>::{closure#0} 0
pq_proto::framed::shutdown::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::{closure#0} 0
pq_proto::framed::shutdown::>>>>>::{closure#0} 0
pq_proto::framed::shutdown::>>::{closure#0} 0
pq_proto::framed::shutdown::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::{closure#0} 0

Generated by: LCOV version 2.1-beta