LCOV - code coverage report
Current view: top level - libs/utils/src - measured_stream.rs (source / functions) Coverage Total Hit
Test: 8ac049b474321fdc72ddcb56d7165153a1a900e8.info Lines: 100.0 % 66 66
Test Date: 2023-09-06 10:18:01 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 654
>::get_byte_count 0
>::get_byte_count 654
<utils::measured_stream::MeasuredReader<_>>::new 656
>::new 0
>::new 656
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_shutdown 3093
as tokio::io::async_write::AsyncWrite>::poll_shutdown 0
, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::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::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_shutdown 1
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_shutdown 27
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_shutdown 27
>, 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 3037
<utils::measured_stream::MeasuredStream<_, _, _>>::new 3783
>::new 0
, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}>>::new 0
>, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}>>::new 0
, proxy::proxy::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}>>::new 1
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}>>::new 27
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}>>::new 27
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::new 3727
<utils::measured_stream::MeasuredReader<_> as std::io::Read>::read 943526
as std::io::Read>::read 0
as std::io::Read>::read 943526
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 2962027
as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 0
, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::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::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::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::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 26
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_write::{closure#0} 53
>, 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} 2961943
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_flush 2967503
as tokio::io::async_write::AsyncWrite>::poll_flush 0
, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::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::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush 3
, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_flush 3
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush 53
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_flush 53
>, 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 2967391
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 2967503
as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 0
, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::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::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 3
, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::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::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 53
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_flush::{closure#0} 53
>, 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} 2967391
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_write 2983808
as tokio::io::async_write::AsyncWrite>::poll_write 0
, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::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::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_write 3
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_write::AsyncWrite>::poll_write 26
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_write::AsyncWrite>::poll_write 53
>, 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 2983724
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 3228791
as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 0
, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::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::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 3
, proxy::proxy::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 53
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_read::AsyncRead>::poll_read::{closure#0} 80
>, 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} 3228651
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_read::AsyncRead>::poll_read 10553722
as tokio::io::async_read::AsyncRead>::poll_read 0
, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_read::AsyncRead>::poll_read 0
, proxy::proxy::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::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::proxy_pass, tokio::net::tcp::stream::TcpStream>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_read::AsyncRead>::poll_read 8
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#0}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}> as tokio::io::async_read::AsyncRead>::poll_read 159
>, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#2}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}> as tokio::io::async_read::AsyncRead>::poll_read 159
>, 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 10553388

Generated by: LCOV version 2.1-beta