|
Function Name  |
Hit count  |
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<_> |
768 |
::handle_start_replication::<_> |
0 |
::handle_start_replication::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> |
768 |
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<_>::{closure#0} |
768 |
::handle_start_replication::<_>::{closure#0} |
0 |
::handle_start_replication::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} |
768 |
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_> |
768 |
::handle_start_replication_guts::<_> |
0 |
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> |
768 |
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0} |
768 |
::handle_start_replication_guts::<_>::{closure#0} |
0 |
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} |
768 |
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#0} |
0 |
::handle_start_replication_guts::<_>::{closure#0}::{closure#0} |
0 |
::handle_start_replication_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::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#1} |
14 |
::handle_start_replication_guts::<_>::{closure#0}::{closure#1} |
0 |
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#1} |
14 |
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#2} |
768 |
::handle_start_replication_guts::<_>::{closure#0}::{closure#2} |
0 |
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#2} |
768 |
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#3} |
3214474 |
::handle_start_replication_guts::<_>::{closure#0}::{closure#3} |
0 |
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#3} |
3214474 |
<safekeeper::send_wal::EndWatch>::changed |
3712316 |
::changed |
1856158 |
::changed::{closure#0} |
1856158 |
<safekeeper::send_wal::EndWatch>::get |
3395561 |
<safekeeper::send_wal::HotStandbyFeedback as core::fmt::Debug>::fmt |
45 |
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::expecting |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<<&mut bincode::de::Deserializer<_, _> as serde::de::Deserializer>::deserialize_tuple::Access, bincode::config::int::FixintEncoding>, bincode::config::limit::Infinite>>> |
21 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> |
0 |
::clone |
0 |
::fmt |
0 |
::deserialize::<&mut bincode::de::Deserializer, bincode::config::int::FixintEncoding>, bincode::config::limit::Infinite>>> |
21 |
::deserialize::<&mut serde_json::de::Deserializer> |
0 |
::deserialize::> |
0 |
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> |
3 |
::serialize::<&mut serde_json::ser::Serializer<&mut utils::http::endpoint::ChannelWriter>> |
0 |
::serialize::, serde_json::ser::CompactFormatter>> |
0 |
::serialize::> |
0 |
<safekeeper::send_wal::HotStandbyFeedback>::empty |
1644387 |
<safekeeper::send_wal::ReplicationFeedback as core::fmt::Debug>::fmt |
278 |
<::deserialize::__Field as serde::de::Deserialize>::deserialize::<&mut serde_json::de::Deserializer> |
1 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: |
1 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::expecting |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_enum::> |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_enum::> |
1 |
::clone |
137 |
::fmt |
0 |
::deserialize::<&mut serde_json::de::Deserializer> |
1 |
::deserialize::> |
0 |
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> |
134 |
::serialize::<&mut serde_json::ser::Serializer<&mut utils::http::endpoint::ChannelWriter>> |
3 |
::serialize::, serde_json::ser::CompactFormatter>> |
0 |
::serialize::> |
0 |
<safekeeper::send_wal::ReplyReader<_>>::handle_feedback |
1689208 |
>::handle_feedback |
0 |
>::handle_feedback::{closure#0} |
0 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback |
844604 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback::{closure#0} |
844604 |
<safekeeper::send_wal::ReplyReader<_>>::handle_feedback::{closure#0}::{closure#0} |
0 |
>::handle_feedback::{closure#0}::{closure#0} |
0 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback::{closure#0}::{closure#0} |
0 |
<safekeeper::send_wal::ReplyReader<_>>::handle_feedback::{closure#0}::{closure#1} |
0 |
>::handle_feedback::{closure#0}::{closure#1} |
0 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback::{closure#0}::{closure#1} |
0 |
<safekeeper::send_wal::ReplyReader<_>>::run |
1536 |
>::run |
0 |
>::run::{closure#0} |
0 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run |
768 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0} |
768 |
<safekeeper::send_wal::StandbyFeedback as core::fmt::Debug>::fmt |
0 |
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::expecting |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> |
0 |
::clone |
0 |
::fmt |
0 |
::deserialize::<&mut serde_json::de::Deserializer> |
0 |
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> |
0 |
::serialize::<&mut serde_json::ser::Serializer<&mut utils::http::endpoint::ChannelWriter>> |
0 |
<safekeeper::send_wal::StandbyFeedback>::empty |
622 |
<safekeeper::send_wal::StandbyReply as core::fmt::Debug>::fmt |
98318 |
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::expecting |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<<&mut bincode::de::Deserializer<_, _> as serde::de::Deserializer>::deserialize_tuple::Access, bincode::config::int::FixintEncoding>, bincode::config::limit::Infinite>>> |
49159 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> |
0 |
::clone |
0 |
::fmt |
0 |
::deserialize::<&mut bincode::de::Deserializer, bincode::config::int::FixintEncoding>, bincode::config::limit::Infinite>>> |
49159 |
::deserialize::<&mut serde_json::de::Deserializer> |
0 |
::deserialize::> |
0 |
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> |
0 |
::serialize::<&mut serde_json::ser::Serializer<&mut utils::http::endpoint::ChannelWriter>> |
0 |
::serialize::, serde_json::ser::CompactFormatter>> |
0 |
::serialize::> |
0 |
<safekeeper::send_wal::StandbyReply>::empty |
1068 |
<safekeeper::send_wal::WalSender<_>>::run |
1536 |
>::run |
0 |
>::run::{closure#0} |
0 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run |
768 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0} |
768 |
<safekeeper::send_wal::WalSender<_>>::run::{closure#0}::{closure#0}::{closure#0} |
0 |
>::run::{closure#0}::{closure#0}::{closure#0} |
0 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0}::{closure#0}::{closure#0} |
0 |
<safekeeper::send_wal::WalSender<_>>::run::{closure#0}::{closure#1} |
0 |
>::run::{closure#0}::{closure#1} |
0 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0}::{closure#1} |
0 |
<safekeeper::send_wal::WalSender<_>>::wait_wal |
1637876 |
>::wait_wal |
0 |
>::wait_wal::{closure#0} |
0 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal |
818938 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal::{closure#0} |
818938 |
<safekeeper::send_wal::WalSender<_>>::wait_wal::{closure#0}::{closure#0} |
0 |
>::wait_wal::{closure#0}::{closure#0} |
0 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal::{closure#0}::{closure#0} |
0 |
<safekeeper::send_wal::WalSender<_>>::wait_wal::{closure#0}::{closure#1} |
0 |
>::wait_wal::{closure#0}::{closure#1} |
0 |
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal::{closure#0}::{closure#1} |
0 |
<safekeeper::send_wal::WalSenderGuard as core::ops::drop::Drop>::drop |
413 |
<safekeeper::send_wal::WalSenderState as core::fmt::Debug>::fmt |
286 |
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> |
5 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> |
0 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: |
5 |
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::expecting |
0 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> |
1 |
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> |
0 |
::clone |
137 |
::fmt |
0 |
::deserialize::<&mut serde_json::de::Deserializer> |
1 |
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> |
134 |
::serialize::<&mut serde_json::ser::Serializer<&mut utils::http::endpoint::ChannelWriter>> |
3 |
<safekeeper::send_wal::WalSenders>::get_all |
257 |
<safekeeper::send_wal::WalSenders>::get_feedbacks |
1643317 |
<safekeeper::send_wal::WalSenders>::get_ps_feedback |
51 |
<safekeeper::send_wal::WalSenders>::get_ws_remote_consistent_lsn |
3356 |
<safekeeper::send_wal::WalSenders>::new |
616 |
<safekeeper::send_wal::WalSenders>::record_hs_feedback |
21 |
<safekeeper::send_wal::WalSenders>::record_ps_feedback |
795424 |
<safekeeper::send_wal::WalSenders>::record_standby_reply |
49159 |
<safekeeper::send_wal::WalSenders>::record_standby_reply::{closure#0} |
49159 |
<safekeeper::send_wal::WalSenders>::register |
768 |
<safekeeper::send_wal::WalSenders>::register::{closure#0} |
365 |
<safekeeper::send_wal::WalSenders>::unregister |
413 |
<safekeeper::send_wal::WalSendersShared>::get_slot |
3356 |
<safekeeper::send_wal::WalSendersShared>::get_slot_mut |
844604 |
<safekeeper::send_wal::WalSendersShared>::new |
622 |
<safekeeper::send_wal::WalSendersShared>::update_ps_feedback |
795426 |
<safekeeper::send_wal::WalSendersShared>::update_ps_feedback::{closure#0} |
1173112 |
<safekeeper::send_wal::WalSendersShared>::update_reply_feedback |
438 |
safekeeper::send_wal::tests::hs_feedback |
8 |
safekeeper::send_wal::tests::mock_addr |
12 |
safekeeper::send_wal::tests::mock_ttid |
12 |
safekeeper::send_wal::tests::ps_feedback |
4 |
safekeeper::send_wal::tests::push_feedback |
12 |
safekeeper::send_wal::tests::test_hs_feedback |
2 |
safekeeper::send_wal::tests::test_hs_feedback::{closure#0} |
2 |
safekeeper::send_wal::tests::test_hs_feedback_no_valid |
2 |
safekeeper::send_wal::tests::test_hs_feedback_no_valid::{closure#0} |
2 |
safekeeper::send_wal::tests::test_ps_feedback |
2 |
safekeeper::send_wal::tests::test_ps_feedback::{closure#0} |
2 |
safekeeper::send_wal::wait_for_lsn |
720442 |
safekeeper::send_wal::wait_for_lsn::{closure#0} |
720442 |
safekeeper::send_wal::wait_for_lsn::{closure#0}::{closure#0} |
720442 |