LCOV - code coverage report
Current view: top level - libs/pq_proto/src - framed.rs (source / functions) Coverage Total Hit
Test: 8ac049b474321fdc72ddcb56d7165153a1a900e8.info Lines: 86.9 % 130 113
Test Date: 2023-09-06 10:18:01 Functions: 59.9 % 187 112

Function Name Sort by function name Hit count Sort by function hit count
<pq_proto::framed::ConnectionError>::into_io_error 0
<pq_proto::framed::FramedWriter<_>>::shutdown 0
>::shutdown 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<_>>::shutdown::{closure#0} 0
>::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::Framed<_>>::map_stream::<_, _, _, _> 1
>::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}> 1
<pq_proto::framed::Framed<_>>::map_stream::<_, _, _, _>::{closure#0} 1
>::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} 1
<pq_proto::framed::Framed<_>>::into_inner 64
>::into_inner 0
>>::into_inner 0
>>::into_inner 1
>>>::into_inner 5
>>>::into_inner 58
<pq_proto::framed::Framed<_>>::get_ref 67
>::get_ref 0
>>::get_ref 0
>>>::get_ref 5
>>>::get_ref 62
<pq_proto::framed::ConnectionError as core::fmt::Debug>::fmt 1014
>::from 0
::source 0
::fmt 0
>::from 347
::fmt 667
<pq_proto::framed::Framed<_>>::unsplit 2565
>::unsplit 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::unsplit 2565
<pq_proto::framed::Framed<_>>::split 2935
>::split 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::split 2935
<pq_proto::framed::Framed<_>>::shutdown 8620
>::shutdown 0
>>::shutdown 3
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::shutdown 3357
>>>>::shutdown 5260
<pq_proto::framed::Framed<_>>::shutdown::{closure#0} 8620
>::shutdown::{closure#0} 0
>>::shutdown::{closure#0} 3
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::shutdown::{closure#0} 3357
>>>>::shutdown::{closure#0} 5260
pq_proto::framed::shutdown::<_> 8620
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}>>> 3357
pq_proto::framed::shutdown::>>> 5260
pq_proto::framed::shutdown::<_>::{closure#0} 8620
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} 3357
pq_proto::framed::shutdown::>>>::{closure#0} 5260
<pq_proto::framed::Framed<_>>::new 9139
>::new 0
>>::new 0
>>::new 2
>>::new 5
>>>::new 12
>>>::new 66
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::new 3727
>>>>::new 5327
<pq_proto::framed::Framed<_>>::read_startup_message 16000
>::read_startup_message 0
>>::read_startup_message 0
>>::read_startup_message 2
>>::read_startup_message 9
>>>::read_startup_message 12
>>>::read_startup_message 66
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_startup_message 5917
>>>>::read_startup_message 9994
<pq_proto::framed::Framed<_>>::read_startup_message::{closure#0} 16000
>::read_startup_message::{closure#0} 0
>>::read_startup_message::{closure#0} 0
>>::read_startup_message::{closure#0} 2
>>::read_startup_message::{closure#0} 9
>>>::read_startup_message::{closure#0} 12
>>>::read_startup_message::{closure#0} 66
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_startup_message::{closure#0} 5917
>>>>::read_startup_message::{closure#0} 9994
<pq_proto::framed::FramedWriter<_>>::flush 2946727
>::flush 0
>>>>::flush 0
>>::flush 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::flush 2946727
<pq_proto::framed::FramedWriter<_>>::flush::{closure#0} 2946727
>::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} 2946727
<pq_proto::framed::FramedWriter<_>>::write_message_noflush 2946727
>::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 2946727
<pq_proto::framed::FramedReader<_>>::read_message 3387810
>::read_message 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_message 3387810
<pq_proto::framed::FramedReader<_>>::read_message::{closure#0} 3387810
>::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} 3387810
<pq_proto::framed::Framed<_>>::read_message 4653365
>::read_message 0
>>::read_message 0
>>>::read_message 8
>>::read_message 10
>>>::read_message 53
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_message 7607
>>>>::read_message 4645687
<pq_proto::framed::Framed<_>>::read_message::{closure#0} 4653365
>::read_message::{closure#0} 0
>>::read_message::{closure#0} 0
>>>::read_message::{closure#0} 8
>>::read_message::{closure#0} 10
>>>::read_message::{closure#0} 53
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::read_message::{closure#0} 7607
>>>>::read_message::{closure#0} 4645687
<pq_proto::framed::Framed<_>>::write_message 5689032
>::write_message 0
>>::write_message 0
>>::write_message 1
>>>::write_message 32
>>::write_message 49
>>>::write_message 555
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::write_message 32043
>>>>::write_message 5656352
<pq_proto::framed::Framed<_>>::flush 5708291
>::flush 0
>>::flush 0
>>::flush 1
>>::flush 22
>>>::flush 22
>>>::flush 144
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::flush 17967
>>>>::flush 5690135
<pq_proto::framed::Framed<_>>::flush::{closure#0} 5708291
>::flush::{closure#0} 0
>>::flush::{closure#0} 0
>>::flush::{closure#0} 1
>>::flush::{closure#0} 22
>>>::flush::{closure#0} 22
>>>::flush::{closure#0} 144
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::flush::{closure#0} 17967
>>>>::flush::{closure#0} 5690135
pq_proto::framed::read_message::<_, _, _>::{closure#0} 8043332
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} 1
pq_proto::framed::read_message::, pq_proto::FeMessage, ::parse>::{closure#0} 8
pq_proto::framed::read_message::>, pq_proto::FeMessage, ::parse>::{closure#0} 8
pq_proto::framed::read_message::, pq_proto::FeStartupPacket, ::parse>::{closure#0} 9
pq_proto::framed::read_message::>, pq_proto::FeStartupPacket, ::parse>::{closure#0} 12
pq_proto::framed::read_message::>, pq_proto::FeMessage, ::parse>::{closure#0} 53
pq_proto::framed::read_message::>, pq_proto::FeStartupPacket, ::parse>::{closure#0} 66
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} 5518
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} 5917
pq_proto::framed::read_message::>>, pq_proto::FeStartupPacket, ::parse>::{closure#0} 9994
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} 3384960
pq_proto::framed::read_message::>>, pq_proto::FeMessage, ::parse>::{closure#0} 4636786
pq_proto::framed::read_message::<_, _, _> 8057175
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::FeMessage, ::parse> 8
pq_proto::framed::read_message::, pq_proto::FeStartupPacket, ::parse> 9
pq_proto::framed::read_message::, pq_proto::FeMessage, ::parse> 10
pq_proto::framed::read_message::>, pq_proto::FeStartupPacket, ::parse> 12
pq_proto::framed::read_message::>, pq_proto::FeMessage, ::parse> 53
pq_proto::framed::read_message::>, pq_proto::FeStartupPacket, ::parse> 66
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> 5917
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> 7607
pq_proto::framed::read_message::>>, pq_proto::FeStartupPacket, ::parse> 9994
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> 3387810
pq_proto::framed::read_message::>>, pq_proto::FeMessage, ::parse> 4645687
pq_proto::framed::flush::<_> 8663638
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::>> 22
pq_proto::framed::flush::> 25
pq_proto::framed::flush::>> 144
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>> 21324
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>> 2946727
pq_proto::framed::flush::>>> 5695395
pq_proto::framed::flush::<_>::{closure#0} 17261075
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} 2
pq_proto::framed::flush::>::{closure#0} 39
pq_proto::framed::flush::>>::{closure#0} 44
pq_proto::framed::flush::>>::{closure#0} 288
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::{closure#0} 34275
pq_proto::framed::flush::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>>::{closure#0} 5895719
pq_proto::framed::flush::>>>::{closure#0} 11330708

Generated by: LCOV version 2.1-beta