LCOV - code coverage report
Current view: top level - libs/utils/src - measured_stream.rs (source / functions) Coverage Total Hit
Test: c639aa5f7ab62b43d647b10f40d15a15686ce8a9.info Lines: 98.5 % 66 65
Test Date: 2024-02-12 20:26:03 Functions: 61.4 % 70 43

Function Name Sort by function name Hit count Sort by function hit count
<utils::measured_stream::MeasuredReader<_>>::get_byte_count 572
>::get_byte_count 0
>::get_byte_count 572
<utils::measured_stream::MeasuredReader<_>>::new 572
>::new 0
>::new 572
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_shutdown 2687
as tokio::io::async_write::AsyncWrite>::poll_shutdown 0
, 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_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
, 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#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#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
>, 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 2603
<utils::measured_stream::MeasuredStream<_, _, _>>::new 3372
>::new 0
, 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_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
, 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#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#2}, proxy::proxy::passthrough::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}>>::new 41
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::new 3288
<utils::measured_stream::MeasuredReader<_> as std::io::Read>::read 857369
as std::io::Read>::read 0
as std::io::Read>::read 857369
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 2480619
as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 0
, 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_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
, 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#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#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
>, 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} 2480493
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_flush 2481465
as tokio::io::async_write::AsyncWrite>::poll_flush 0
, 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_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
, 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#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#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
>, 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 2481339
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 2481465
as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 0
, 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_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
, 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#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#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
>, 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} 2481339
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_write 2503958
as tokio::io::async_write::AsyncWrite>::poll_write 0
, 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_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
, 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#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#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
>, 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 2503832
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 2939974
as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 0
, 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_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
, 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::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
>, 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#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
>, 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} 2939806
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_read::AsyncRead>::poll_read 9496370
as tokio::io::async_read::AsyncRead>::poll_read 0
, 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_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
, 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::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
>, 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#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
>, 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 9495910

Generated by: LCOV version 2.1-beta