LCOV - code coverage report
Current view: top level - safekeeper/src - send_wal.rs (source / functions) Coverage Total Hit
Test: 32f4a56327bc9da697706839ed4836b2a00a408f.info Lines: 93.5 % 507 474
Test Date: 2024-02-07 07:37:29 Functions: 45.3 % 161 73

Function Name Sort by function name Hit count Sort by function 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

Generated by: LCOV version 2.1-beta