LCOV - code coverage report
Current view: top level - libs/utils/src - measured_stream.rs (source / functions) Coverage Total Hit
Test: aca8877be6ceba750c1be359ed71bc1799d52b30.info Lines: 98.5 % 66 65
Test Date: 2024-02-14 18:05:35 Functions: 61.4 % 70 43

Function Name Sort by function name Hit count Sort by function hit count
<utils::measured_stream::MeasuredReader<_> as std::io::Read>::read 859372
as std::io::Read>::read 0
as std::io::Read>::read 859372
<utils::measured_stream::MeasuredReader<_>>::get_byte_count 571
>::get_byte_count 0
>::get_byte_count 571
<utils::measured_stream::MeasuredReader<_>>::new 571
>::new 0
>::new 571
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_read::AsyncRead>::poll_read 8717941
as tokio::io::async_read::AsyncRead>::poll_read 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}> as tokio::io::async_read::AsyncRead>::poll_read 8717481
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_read::AsyncRead>::poll_read 243
, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_read::AsyncRead>::poll_read 0
, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_read::AsyncRead>::poll_read 8
, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_read::AsyncRead>::poll_read 7
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_read::AsyncRead>::poll_read 202
>, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_read::AsyncRead>::poll_read 0
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 2672980
as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 2672812
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 122
, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 0
, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 4
, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 2
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 40
>, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 0
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_flush 2297674
as tokio::io::async_write::AsyncWrite>::poll_flush 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush 2297548
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush 40
, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush 0
, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush 2
, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_flush 3
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_flush 81
>, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_flush 0
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 2297674
as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 2297548
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 40
, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 0
, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 2
, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 3
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 81
>, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 0
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_shutdown 2709
as tokio::io::async_write::AsyncWrite>::poll_shutdown 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_shutdown 2625
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_shutdown 41
, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_shutdown 0
, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_shutdown 1
, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_shutdown 1
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_shutdown 41
>, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_shutdown 0
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_write 2319344
as tokio::io::async_write::AsyncWrite>::poll_write 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_write 2319218
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_write 40
, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_write 0
, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_write 2
, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_write 3
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_write 81
>, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_write 0
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 2296706
as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 2296580
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 40
, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 0
, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 2
, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 3
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 81
>, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 0
<utils::measured_stream::MeasuredStream<_, _, _>>::new 3396
>::new 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::new 3312
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}>>::new 41
, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}>>::new 0
, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#1}>>::new 1
, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}>>::new 1
>, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}>>::new 41
>, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::passthrough::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}>>::new 0

Generated by: LCOV version 2.1-beta