LCOV - code coverage report
Current view: top level - proxy/src - stream.rs (source / functions) Coverage Total Hit
Test: 5e392a02abbad1ab595f4dba672e219a49f7f539.info Lines: 59.2 % 169 100
Test Date: 2025-04-11 22:43:24 Functions: 29.3 % 133 39

Function Name Sort by function name Hit count Sort by function hit count
<proxy::stream::PqStream<proxy::stream::Stream<proxy::protocol2::ChainRW<tokio::net::tcp::stream::TcpStream>>>>::throw_error::<proxy::compute::PostgresConnection, proxy::compute::ConnectionError> 0
>>>::throw_error::>>, proxy::proxy::ClientRequestError>, proxy::auth::AuthError> 0
>>>::throw_error::, proxy::auth::credentials::ComputeUserInfoParseError> 0
>>>::throw_error:: 0
>>>>::throw_error::>>>, proxy::proxy::ClientRequestError>, proxy::auth::AuthError> 0
>>>>::throw_error::, proxy::auth::credentials::ComputeUserInfoParseError> 0
>>>>::throw_error:: 0
<proxy::stream::PqStream<proxy::stream::Stream<proxy::protocol2::ChainRW<tokio::net::tcp::stream::TcpStream>>>>::throw_error::<proxy::compute::PostgresConnection, proxy::compute::ConnectionError>::{closure#0} 0
>>>::throw_error::>>, proxy::proxy::ClientRequestError>, proxy::auth::AuthError>::{closure#0} 0
>>>::throw_error::, proxy::auth::credentials::ComputeUserInfoParseError>::{closure#0} 0
>>>::throw_error::::{closure#0} 0
>>>>::throw_error::>>>, proxy::proxy::ClientRequestError>, proxy::auth::AuthError>::{closure#0} 0
>>>>::throw_error::, proxy::auth::credentials::ComputeUserInfoParseError>::{closure#0} 0
>>>>::throw_error::::{closure#0} 0
<proxy::stream::PqStream<proxy::stream::Stream<proxy::protocol2::ChainRW<tokio::net::tcp::stream::TcpStream>>>>::throw_error::<proxy::compute::PostgresConnection, proxy::compute::ConnectionError>::{closure#0}::{closure#0} 0
>>>::throw_error::>>, proxy::proxy::ClientRequestError>, proxy::auth::AuthError>::{closure#0}::{closure#0} 0
>>>::throw_error::, proxy::auth::credentials::ComputeUserInfoParseError>::{closure#0}::{closure#0} 0
>>>::throw_error::::{closure#0}::{closure#0} 0
>>>>::throw_error::>>>, proxy::proxy::ClientRequestError>, proxy::auth::AuthError>::{closure#0}::{closure#0} 0
>>>>::throw_error::, proxy::auth::credentials::ComputeUserInfoParseError>::{closure#0}::{closure#0} 0
>>>>::throw_error::::{closure#0}::{closure#0} 0
<proxy::stream::PqStream<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream>>>::into_inner 0
>>>::into_inner 0
>>>>::into_inner 0
>>::into_inner 0
<proxy::stream::PqStream<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream>>>::throw_error_str::<core::result::Result<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream>, anyhow::Error>>::{closure#0}::{closure#0} 0
>>>::throw_error_str::>, proxy::proxy::handshake::HandshakeError>>::{closure#0}::{closure#0} 0
>>>::throw_error_str::>, proxy::proxy::handshake::HandshakeError>>::{closure#0}::{closure#0} 0
>>>>::throw_error_str::>>, proxy::proxy::handshake::HandshakeError>>::{closure#0}::{closure#0} 0
>>::throw_error_str::, proxy::proxy::handshake::HandshakeError>>::{closure#0}::{closure#0} 0
>>::throw_error_str::, anyhow::Error>>::{closure#0}::{closure#0} 0
<proxy::stream::ReportedError as core::error::Error>::source 0
<proxy::stream::ReportedError as proxy::error::ReportableError>::get_error_kind 0
<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream> as tokio::io::async_write::AsyncWrite>::poll_shutdown 0
> as tokio::io::async_write::AsyncWrite>::poll_shutdown 0
>> as tokio::io::async_write::AsyncWrite>::poll_shutdown 0
as tokio::io::async_write::AsyncWrite>::poll_shutdown 0
<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream>>::sni_hostname 0
>>::sni_hostname 0
>>>::sni_hostname 0
>::sni_hostname 0
<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream>>::upgrade 0
<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream>>::upgrade::{closure#0} 0
<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream>>::upgrade::{closure#0}::{closure#0} 0
proxy::stream::err_connection 0
<proxy::stream::PqStream<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream>>>::throw_error_str::<core::result::Result<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream>, anyhow::Error>> 1
>>>::throw_error_str::>, proxy::proxy::handshake::HandshakeError>> 0
>>>>::throw_error_str::>>, proxy::proxy::handshake::HandshakeError>> 0
>>::throw_error_str::, proxy::proxy::handshake::HandshakeError>> 0
>>::throw_error_str::, anyhow::Error>> 0
>>>::throw_error_str::>, proxy::proxy::handshake::HandshakeError>> 1
<proxy::stream::PqStream<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream>>>::throw_error_str::<core::result::Result<proxy::stream::Stream<tokio::net::tcp::stream::TcpStream>, anyhow::Error>>::{closure#0} 1
>>>::throw_error_str::>, proxy::proxy::handshake::HandshakeError>>::{closure#0} 0
>>>>::throw_error_str::>>, proxy::proxy::handshake::HandshakeError>>::{closure#0} 0
>>::throw_error_str::, proxy::proxy::handshake::HandshakeError>>::{closure#0} 0
>>::throw_error_str::, anyhow::Error>>::{closure#0} 0
>>>::throw_error_str::>, proxy::proxy::handshake::HandshakeError>>::{closure#0} 1
<proxy::stream::ReportedError as core::fmt::Display>::fmt 1
<proxy::stream::Stream<tokio::io::util::mem::DuplexStream>>::tls_server_end_point 15
>>::tls_server_end_point 0
>>>::tls_server_end_point 0
>::tls_server_end_point 3
>>::tls_server_end_point 12
<proxy::stream::PqStream<proxy::stream::Stream<tokio::io::util::mem::DuplexStream>>>::new 25
>>>::new 0
>>>>::new 0
>>::new 0
>>::new 10
>>>::new 15
<proxy::stream::Stream<tokio::io::util::mem::DuplexStream>>::from_raw 25
>>::from_raw 0
>>>::from_raw 0
>::from_raw 0
>::from_raw 10
>>::from_raw 15
<proxy::stream::PqStream<proxy::stream::Stream<tokio::io::util::mem::DuplexStream>>>::get_ref 35
>>>::get_ref 0
>>>>::get_ref 0
>>::get_ref 10
>>>::get_ref 25
<proxy::stream::PqStream<proxy::stream::Stream<tokio::io::util::mem::DuplexStream>>>::read_message 52
>>>::read_message 0
>>>::read_message::{closure#0} 0
>>>>::read_message 0
>>>>::read_message::{closure#0} 0
>>::read_message 4
>>::read_message::{closure#0} 4
>>>::read_message 22
>>>::read_message::{closure#0} 22
<proxy::stream::PqStream<proxy::stream::Stream<tokio::io::util::mem::DuplexStream>>>::read_password_message 52
>>>::read_password_message 0
>>>::read_password_message::{closure#0} 0
>>>>::read_password_message 0
>>>>::read_password_message::{closure#0} 0
>>::read_password_message 4
>>::read_password_message::{closure#0} 4
>>>::read_password_message 22
>>>::read_password_message::{closure#0} 22
<proxy::stream::Stream<tokio::io::util::mem::DuplexStream> as tokio::io::async_write::AsyncWrite>::poll_flush 71
> as tokio::io::async_write::AsyncWrite>::poll_flush 0
>> as tokio::io::async_write::AsyncWrite>::poll_flush 0
as tokio::io::async_write::AsyncWrite>::poll_flush 0
as tokio::io::async_write::AsyncWrite>::poll_flush 28
> as tokio::io::async_write::AsyncWrite>::poll_flush 43
<proxy::stream::Stream<tokio::io::util::mem::DuplexStream> as tokio::io::async_write::AsyncWrite>::poll_write 71
> as tokio::io::async_write::AsyncWrite>::poll_write 0
>> as tokio::io::async_write::AsyncWrite>::poll_write 0
as tokio::io::async_write::AsyncWrite>::poll_write 0
as tokio::io::async_write::AsyncWrite>::poll_write 28
> as tokio::io::async_write::AsyncWrite>::poll_write 43
<proxy::stream::PqStream<proxy::stream::Stream<tokio::io::util::mem::DuplexStream>>>::write_message_noflush 77
>>>::write_message_noflush 0
>>>>::write_message_noflush 0
>>::write_message_noflush 0
>>::write_message_noflush 15
>>>::write_message_noflush 62
<proxy::stream::PqStream<proxy::stream::Stream<tokio::io::util::mem::DuplexStream>>>::read_startup_packet 84
>>>::read_startup_packet 0
>>>::read_startup_packet::{closure#0} 0
>>>>::read_startup_packet 0
>>>>::read_startup_packet::{closure#0} 0
>>::read_startup_packet 0
>>::read_startup_packet::{closure#0} 0
>>::read_startup_packet 14
>>::read_startup_packet::{closure#0} 14
>>>::read_startup_packet 28
>>>::read_startup_packet::{closure#0} 28
<proxy::stream::PqStream<proxy::stream::Stream<tokio::io::util::mem::DuplexStream>>>::write_message 108
>>>::write_message 0
>>>::write_message::{closure#0} 0
>>>>::write_message 0
>>>>::write_message::{closure#0} 0
>>::write_message 0
>>::write_message::{closure#0} 0
>>::write_message 11
>>::write_message::{closure#0} 11
>>>::write_message 43
>>>::write_message::{closure#0} 43
<proxy::stream::PqStream<proxy::stream::Stream<tokio::io::util::mem::DuplexStream>>>::flush 110
>>>::flush 0
>>>::flush::{closure#0} 0
>>>>::flush 0
>>>>::flush::{closure#0} 0
>>::flush 0
>>::flush::{closure#0} 0
>>::flush 12
>>::flush::{closure#0} 12
>>>::flush 43
>>>::flush::{closure#0} 43
<proxy::stream::Stream<tokio::io::util::mem::DuplexStream> as tokio::io::async_read::AsyncRead>::poll_read 151
> as tokio::io::async_read::AsyncRead>::poll_read 0
>> as tokio::io::async_read::AsyncRead>::poll_read 0
as tokio::io::async_read::AsyncRead>::poll_read 0
as tokio::io::async_read::AsyncRead>::poll_read 72
> as tokio::io::async_read::AsyncRead>::poll_read 79

Generated by: LCOV version 2.1-beta