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<_> as std::io::Read>::read 943526
as std::io::Read>::read 0
as std::io::Read>::read 943526
<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_read::AsyncRead>::poll_read 10553722
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 10553388
, 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#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::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#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_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
<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
>, 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
, 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#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
, 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
, 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_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
>, 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
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_flush 2967503
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 2967391
, 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#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::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#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_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
<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
>, 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
, 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#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::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#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_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
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_shutdown 3093
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 3037
, 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#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::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#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_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
<utils::measured_stream::MeasuredStream<_, _, _> as tokio::io::async_write::AsyncWrite>::poll_write 2983808
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 2983724
, 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#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::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#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_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
<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
>, 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
, 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#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::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#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_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
<utils::measured_stream::MeasuredStream<_, _, _>>::new 3783
>::new 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::new 3727
, 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#0}, proxy::proxy::proxy_pass>, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#1}>>::new 27
, 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#2}, proxy::proxy::proxy_pass, tokio_postgres::maybe_tls_stream::MaybeTlsStream>>::{closure#0}::{closure#0}::{closure#3}>>::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 27

Generated by: LCOV version 2.1-beta