|
Function Name  |
Hit count  |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_wal_push::<_> |
0 |
| ::handle_start_wal_push::<_> |
0 |
| ::handle_start_wal_push::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_wal_push::<_>::{closure#0} |
0 |
| ::handle_start_wal_push::<_>::{closure#0} |
0 |
| ::handle_start_wal_push::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_wal_push_guts::<_> |
0 |
| ::handle_start_wal_push_guts::<_> |
0 |
| ::handle_start_wal_push_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_wal_push_guts::<_>::{closure#0} |
0 |
| ::handle_start_wal_push_guts::<_>::{closure#0} |
0 |
| ::handle_start_wal_push_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_wal_push_guts::<_>::{closure#0}::{closure#0} |
0 |
| ::handle_start_wal_push_guts::<_>::{closure#0}::{closure#0} |
0 |
| ::handle_start_wal_push_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#0} |
0 |
| <safekeeper::receive_wal::NetworkReader<_>>::read_first_message |
0 |
| >::read_first_message |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::read_first_message |
0 |
| <safekeeper::receive_wal::NetworkReader<_>>::read_first_message::{closure#0} |
0 |
| <safekeeper::receive_wal::NetworkReader<_>>::run |
0 |
| >::run |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run |
0 |
| <safekeeper::receive_wal::NetworkReader<_>>::run::{closure#0} |
0 |
| >::run::{closure#0} |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0} |
0 |
| <safekeeper::receive_wal::NetworkReader<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::read_first_message::{closure#0} |
0 |
| <safekeeper::receive_wal::WalReceiverGuard>::get |
0 |
| <safekeeper::receive_wal::WalReceivers>::broadcast_pageserver_feedback |
0 |
| <safekeeper::receive_wal::WalReceivers>::get_all |
0 |
| <safekeeper::receive_wal::WalReceivers>::get_num |
0 |
| <safekeeper::receive_wal::WalReceivers>::get_num_streaming::{closure#0} |
0 |
| <safekeeper::receive_wal::WalReceivers>::get_slot |
0 |
| <safekeeper::receive_wal::WalReceivers>::get_slot::{closure#0} |
0 |
| <safekeeper::receive_wal::WalReceivers>::register::{closure#0} |
0 |
| safekeeper::receive_wal::network_write::<_> |
0 |
| safekeeper::receive_wal::network_write::<_> |
0 |
| safekeeper::receive_wal::network_write::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> |
0 |
| safekeeper::receive_wal::network_write::<_>::{closure#0} |
0 |
| safekeeper::receive_wal::network_write::<_>::{closure#0} |
0 |
| safekeeper::receive_wal::network_write::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} |
0 |
| safekeeper::receive_wal::read_message::<_> |
0 |
| safekeeper::receive_wal::read_message::<_> |
0 |
| safekeeper::receive_wal::read_message::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> |
0 |
| safekeeper::receive_wal::read_message::<_>::{closure#0} |
0 |
| safekeeper::receive_wal::read_message::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} |
0 |
| safekeeper::receive_wal::read_network_loop::<_> |
0 |
| safekeeper::receive_wal::read_network_loop::<_> |
0 |
| safekeeper::receive_wal::read_network_loop::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> |
0 |
| safekeeper::receive_wal::read_network_loop::<_>::{closure#0} |
0 |
| safekeeper::receive_wal::read_network_loop::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} |
0 |
| <safekeeper::receive_wal::WalAcceptor as core::ops::drop::Drop>::drop |
5 |
| <safekeeper::receive_wal::WalAcceptor>::spawn |
5 |
| <safekeeper::receive_wal::WalAcceptor>::spawn::{closure#0} |
5 |
| <safekeeper::receive_wal::WalReceiverGuard as core::ops::drop::Drop>::drop |
5 |
| <safekeeper::receive_wal::WalReceivers>::get_num_rx |
5 |
| <safekeeper::receive_wal::WalReceivers>::get_num_streaming |
5 |
| <safekeeper::receive_wal::WalReceivers>::new |
5 |
| <safekeeper::receive_wal::WalReceivers>::register |
5 |
| <safekeeper::receive_wal::WalReceivers>::unregister |
5 |
| <safekeeper::receive_wal::WalAcceptor>::run |
10 |
| ::run |
5 |
| ::run::{closure#0} |
5 |
| <safekeeper::receive_wal::WalReceivers>::update_num |
10 |
| <safekeeper::receive_wal::WalReceiversShared>::get_num |
10 |