LCOV - code coverage report
Current view: top level - libs/pq_proto/src - framed.rs (source / functions) Coverage Total Hit
Test: c639aa5f7ab62b43d647b10f40d15a15686ce8a9.info Lines: 89.6 % 125 112
Test Date: 2024-02-12 20:26:03 Functions: 62.8 % 199 125

Function Name Sort by function name Hit count Sort by function hit count
<pq_proto::framed::FramedWriter<_>>::shutdown 0
>::shutdown 0
>::shutdown::{closure#0} 0
>>>>::shutdown 0
>>>>::shutdown::{closure#0} 0
>>::shutdown 0
>>::shutdown::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::shutdown 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::ConnectionError>::into_io_error 2
<pq_proto::framed::Framed<_>>::map_stream::<_, _, _, _> 2
>::map_stream::<_, _, _, _> 0
>>>>::map_stream::>>, anyhow::Error, >>>::start_tls::{closure#0}::{closure#0}, >>>::tls_upgrade::{closure#0}> 0
>, 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
>>::map_stream::, anyhow::Error, >::start_tls::{closure#0}::{closure#0}, >::tls_upgrade::{closure#0}> 2
<pq_proto::framed::Framed<_>>::map_stream::<_, _, _, _>::{closure#0} 2
>::map_stream::<_, _, _, _>::{closure#0} 0
>>>>::map_stream::>>, anyhow::Error, >>>::start_tls::{closure#0}::{closure#0}, >>>::tls_upgrade::{closure#0}>::{closure#0} 0
>, 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
>>::map_stream::, anyhow::Error, >::start_tls::{closure#0}::{closure#0}, >::tls_upgrade::{closure#0}>::{closure#0} 2
<pq_proto::framed::Framed<_>>::into_inner 148
>::into_inner 0
>>::into_inner 0
>>::into_inner 1
>>>::into_inner 26
>>::into_inner 28
>>>::into_inner 93
<pq_proto::framed::Framed<_>>::get_ref 210
>::get_ref 0
>>::get_ref 0
>>::get_ref 14
>>>::get_ref 50
>>>::get_ref 146
<pq_proto::framed::ConnectionError as core::fmt::Debug>::fmt 1048
>::from 0
::source 0
::fmt 0
>::from 300
::fmt 748
<pq_proto::framed::Framed<_>>::unsplit 2168
>::unsplit 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::unsplit 2168
<pq_proto::framed::Framed<_>>::split 2604
>::split 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::split 2604
pq_proto::framed::shutdown::<_> 13406
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::> 3
pq_proto::framed::shutdown::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>> 2851
pq_proto::framed::shutdown::>>> 10552
pq_proto::framed::shutdown::<_>::{closure#0} 13406
pq_proto::framed::shutdown::<_>::{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} 3
pq_proto::framed::shutdown::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::{closure#0} 2851
pq_proto::framed::shutdown::>>>::{closure#0} 10552
<pq_proto::framed::Framed<_>>::new 14062
>::new 0
>>::new 0
>>::new 2
>>::new 7
>>::new 28
>>>::new 56
>>>::new 115
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::new 3288
>>>>::new 10566
<pq_proto::framed::Framed<_>>::read_startup_message 25897
>::read_startup_message 0
>>::read_startup_message 0
>>::read_startup_message 2
>>::read_startup_message 12
>>::read_startup_message 28
>>>::read_startup_message 56
>>>::read_startup_message 115
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_startup_message 5179
>>>>::read_startup_message 20505
<pq_proto::framed::Framed<_>>::read_startup_message::{closure#0} 25897
>::read_startup_message::{closure#0} 0
>>::read_startup_message::{closure#0} 0
>>::read_startup_message::{closure#0} 2
>>::read_startup_message::{closure#0} 12
>>::read_startup_message::{closure#0} 28
>>>::read_startup_message::{closure#0} 56
>>>::read_startup_message::{closure#0} 115
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_startup_message::{closure#0} 5179
>>>>::read_startup_message::{closure#0} 20505
<pq_proto::framed::Framed<_>>::shutdown 26812
>::shutdown 0
>::shutdown::{closure#0} 0
>>::shutdown 3
>>::shutdown::{closure#0} 3
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::shutdown 2851
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::shutdown::{closure#0} 2851
>>>>::shutdown 10552
>>>>::shutdown::{closure#0} 10552
<pq_proto::framed::FramedWriter<_>>::write_message_noflush 2466754
>::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 2466754
<pq_proto::framed::FramedWriter<_>>::flush 4933508
>::flush 0
>::flush::{closure#0} 0
>>>>::flush 0
>>>>::flush::{closure#0} 0
>>::flush 0
>>::flush::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::flush 2466754
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::flush::{closure#0} 2466754
<pq_proto::framed::Framed<_>>::write_message 5596960
>::write_message 0
>>::write_message 0
>>::write_message 1
>>::write_message 14
>>::write_message 68
>>>::write_message 124
>>>::write_message 856
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::write_message 28214
>>>>::write_message 5567683
<pq_proto::framed::FramedReader<_>>::read_message 6955526
>::read_message 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 3477763
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_message::{closure#0} 3477763
pq_proto::framed::flush::<_> 8066976
pq_proto::framed::flush::<_> 0
pq_proto::framed::flush::> 0
pq_proto::framed::flush::>>>> 0
pq_proto::framed::flush::>> 0
pq_proto::framed::flush::> 1
pq_proto::framed::flush::> 14
pq_proto::framed::flush::> 25
pq_proto::framed::flush::>> 96
pq_proto::framed::flush::>> 235
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>> 15103
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>> 2466754
pq_proto::framed::flush::>>> 5584748
pq_proto::framed::flush::<_>::{closure#0} 8066976
pq_proto::framed::flush::<_>::{closure#0} 0
pq_proto::framed::flush::>::{closure#0} 0
pq_proto::framed::flush::>>>>::{closure#0} 0
pq_proto::framed::flush::>>::{closure#0} 0
pq_proto::framed::flush::>::{closure#0} 1
pq_proto::framed::flush::>::{closure#0} 14
pq_proto::framed::flush::>::{closure#0} 25
pq_proto::framed::flush::>>::{closure#0} 96
pq_proto::framed::flush::>>::{closure#0} 235
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::{closure#0} 15103
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::{closure#0} 2466754
pq_proto::framed::flush::>>>::{closure#0} 5584748
pq_proto::framed::read_message::<_, _, _> 8148661
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::FeStartupPacket, ::parse> 2
pq_proto::framed::read_message::, pq_proto::FeStartupPacket, ::parse> 12
pq_proto::framed::read_message::, pq_proto::FeMessage, ::parse> 14
pq_proto::framed::read_message::, pq_proto::FeStartupPacket, ::parse> 28
pq_proto::framed::read_message::>, pq_proto::FeMessage, ::parse> 44
pq_proto::framed::read_message::>, pq_proto::FeStartupPacket, ::parse> 56
pq_proto::framed::read_message::>, pq_proto::FeMessage, ::parse> 81
pq_proto::framed::read_message::>, pq_proto::FeStartupPacket, ::parse> 115
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> 5179
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> 6747
pq_proto::framed::read_message::>>, pq_proto::FeStartupPacket, ::parse> 20505
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> 3477763
pq_proto::framed::read_message::>>, pq_proto::FeMessage, ::parse> 4638115
pq_proto::framed::read_message::<_, _, _>::{closure#0} 8148661
pq_proto::framed::read_message::<_, _, _>::{closure#0} 0
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::FeStartupPacket, ::parse>::{closure#0} 2
pq_proto::framed::read_message::, pq_proto::FeStartupPacket, ::parse>::{closure#0} 12
pq_proto::framed::read_message::, pq_proto::FeMessage, ::parse>::{closure#0} 14
pq_proto::framed::read_message::, pq_proto::FeStartupPacket, ::parse>::{closure#0} 28
pq_proto::framed::read_message::>, pq_proto::FeMessage, ::parse>::{closure#0} 44
pq_proto::framed::read_message::>, pq_proto::FeStartupPacket, ::parse>::{closure#0} 56
pq_proto::framed::read_message::>, pq_proto::FeMessage, ::parse>::{closure#0} 81
pq_proto::framed::read_message::>, pq_proto::FeStartupPacket, ::parse>::{closure#0} 115
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} 5179
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} 6747
pq_proto::framed::read_message::>>, pq_proto::FeStartupPacket, ::parse>::{closure#0} 20505
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} 3477763
pq_proto::framed::read_message::>>, pq_proto::FeMessage, ::parse>::{closure#0} 4638115
<pq_proto::framed::Framed<_>>::read_message 9290002
>::read_message 0
>::read_message::{closure#0} 0
>>::read_message 0
>>::read_message::{closure#0} 0
>>::read_message 14
>>::read_message::{closure#0} 14
>>>::read_message 44
>>>::read_message::{closure#0} 44
>>>::read_message 81
>>>::read_message::{closure#0} 81
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_message 6747
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_message::{closure#0} 6747
>>>>::read_message 4638115
>>>>::read_message::{closure#0} 4638115
<pq_proto::framed::Framed<_>>::flush 11173632
>::flush 0
>::flush::{closure#0} 0
>>::flush 0
>>::flush::{closure#0} 0
>>::flush 1
>>::flush::{closure#0} 1
>>::flush 14
>>::flush::{closure#0} 14
>>::flush 22
>>::flush::{closure#0} 22
>>>::flush 96
>>>::flush::{closure#0} 96
>>>::flush 235
>>>::flush::{closure#0} 235
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::flush 12252
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::flush::{closure#0} 12252
>>>>::flush 5574196
>>>>::flush::{closure#0} 5574196

Generated by: LCOV version 2.1-beta