LCOV - differential code coverage report
Current view: top level - safekeeper/src - send_wal.rs (source / functions) Coverage Total Hit UBC CBC
Current: f6946e90941b557c917ac98cd5a7e9506d180f3e.info Lines: 93.3 % 449 419 30 419
Current Date: 2023-10-19 02:04:12 Functions: 46.8 % 154 72 82 72
Baseline: c8637f37369098875162f194f92736355783b050.info
Baseline Date: 2023-10-18 20:25:20

Function Name Sort by function name TLA Hit count Sort by function hit count
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#0} UBC 0
::handle_start_replication_guts::<_>::{closure#0}::{closure#0} UBC 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} UBC 0
<safekeeper::send_wal::ReplyReader<_>>::handle_feedback::{closure#0} UBC 0
>::handle_feedback::{closure#0} UBC 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback::{closure#0} UBC 0
<safekeeper::send_wal::ReplyReader<_>>::handle_feedback::{closure#1} UBC 0
>::handle_feedback::{closure#1} UBC 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback::{closure#1} UBC 0
<safekeeper::send_wal::StandbyFeedback as core::fmt::Debug>::fmt UBC 0
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::expecting UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> UBC 0
::clone UBC 0
::fmt UBC 0
::deserialize::<&mut serde_json::de::Deserializer> UBC 0
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> UBC 0
<safekeeper::send_wal::WalSender<_>>::run::{closure#0}::{closure#0} UBC 0
>::run::{closure#0}::{closure#0} UBC 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0}::{closure#0} UBC 0
<safekeeper::send_wal::WalSender<_>>::wait_wal::{closure#0}::{closure#0} UBC 0
>::wait_wal::{closure#0}::{closure#0} UBC 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} UBC 0
<safekeeper::send_wal::WalSender<_>>::wait_wal::{closure#0}::{closure#1} UBC 0
>::wait_wal::{closure#0}::{closure#1} UBC 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} UBC 0
<safekeeper::send_wal::WalSenders>::record_hs_feedback CBC 1
safekeeper::send_wal::tests::test_hs_feedback CBC 1
safekeeper::send_wal::tests::test_hs_feedback::{closure#0} CBC 1
safekeeper::send_wal::tests::test_hs_feedback_no_valid CBC 1
safekeeper::send_wal::tests::test_hs_feedback_no_valid::{closure#0} CBC 1
safekeeper::send_wal::tests::test_ps_feedback CBC 1
safekeeper::send_wal::tests::test_ps_feedback::{closure#0} CBC 1
safekeeper::send_wal::tests::ps_feedback CBC 2
<safekeeper::send_wal::StandbyReply>::empty CBC 4
safekeeper::send_wal::tests::hs_feedback CBC 4
<safekeeper::send_wal::HotStandbyFeedback as core::fmt::Debug>::fmt CBC 5
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::expecting UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> UBC 0
::clone UBC 0
::fmt UBC 0
::deserialize::<&mut serde_json::de::Deserializer> UBC 0
::deserialize::> UBC 0
::serialize::, serde_json::ser::CompactFormatter>> UBC 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>>> CBC 1
::deserialize::<&mut bincode::de::Deserializer, bincode::config::int::FixintEncoding>, bincode::config::limit::Infinite>>> CBC 1
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 3
safekeeper::send_wal::tests::mock_addr CBC 6
safekeeper::send_wal::tests::mock_ttid CBC 6
safekeeper::send_wal::tests::push_feedback CBC 6
<safekeeper::send_wal::WalSenders>::record_standby_reply CBC 12
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#1} CBC 17
::handle_start_replication_guts::<_>::{closure#0}::{closure#1} UBC 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} CBC 17
<safekeeper::send_wal::StandbyReply as core::fmt::Debug>::fmt CBC 24
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::expecting UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> UBC 0
::clone UBC 0
::fmt UBC 0
::deserialize::<&mut serde_json::de::Deserializer> UBC 0
::deserialize::> UBC 0
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> UBC 0
::serialize::, serde_json::ser::CompactFormatter>> UBC 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>>> CBC 12
::deserialize::<&mut bincode::de::Deserializer, bincode::config::int::FixintEncoding>, bincode::config::limit::Infinite>>> CBC 12
<safekeeper::send_wal::WalSenders>::get_ps_feedback CBC 51
<safekeeper::send_wal::ReplicationFeedback as core::fmt::Debug>::fmt CBC 192
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::expecting UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_enum::> UBC 0
::fmt UBC 0
::deserialize::> UBC 0
::serialize::, serde_json::ser::CompactFormatter>> UBC 0
<::deserialize::__Field as serde::de::Deserialize>::deserialize::<&mut serde_json::de::Deserializer> CBC 1
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: CBC 1
<::deserialize::__Visitor as serde::de::Visitor>::visit_enum::> CBC 1
::deserialize::<&mut serde_json::de::Deserializer> CBC 1
::clone CBC 94
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 94
<safekeeper::send_wal::WalSenders>::get_all CBC 217
<safekeeper::send_wal::WalSenderState as core::fmt::Debug>::fmt CBC 295
<<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::__DeserializeWith as serde::de::Deserialize>::deserialize::<&mut serde_json::de::Deserializer> UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::expecting UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_bytes::<_> UBC 0
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_u64::<_> UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::expecting UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> UBC 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::>::{closure#0} UBC 0
<::serialize::__SerializeWith as serde::ser::Serialize>::serialize::, serde_json::ser::CompactFormatter>> UBC 0
::fmt UBC 0
<<::deserialize::__Visitor as serde::de::Visitor>::visit_map::__DeserializeWith as serde::de::Deserialize>::deserialize::<&mut serde_json::de::Deserializer> CBC 1
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::> CBC 1
::deserialize::<&mut serde_json::de::Deserializer> CBC 1
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> CBC 5
<::deserialize::__FieldVisitor as serde::de::Visitor>::visit_str:: CBC 5
<::serialize::__SerializeWith as serde::ser::Serialize>::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 94
::clone CBC 94
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 94
<safekeeper::send_wal::WalSenders>::register::{closure#0} CBC 325
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<_>::{closure#0} CBC 463
::handle_start_replication::<_>::{closure#0} UBC 0
::handle_start_replication::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} CBC 463
<safekeeper::send_wal::WalSenderGuard as core::ops::drop::Drop>::drop CBC 463
<safekeeper::send_wal::WalSenders>::unregister CBC 463
<safekeeper::send_wal::WalSendersShared>::update_hs_feedback CBC 466
<safekeeper::send_wal::WalSenders>::new CBC 565
<safekeeper::send_wal::WalSendersShared>::new CBC 568
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<_> CBC 783
::handle_start_replication::<_> UBC 0
::handle_start_replication::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> CBC 783
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_> CBC 783
::handle_start_replication_guts::<_> UBC 0
::handle_start_replication_guts::>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> CBC 783
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0} CBC 783
::handle_start_replication_guts::<_>::{closure#0} UBC 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} CBC 783
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#2} CBC 783
::handle_start_replication_guts::<_>::{closure#0}::{closure#2} UBC 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} CBC 783
<safekeeper::send_wal::ReplyReader<_>>::run CBC 783
>::run UBC 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run CBC 783
<safekeeper::send_wal::WalSenders>::register CBC 783
<safekeeper::send_wal::WalSender<_>>::run CBC 1565
>::run UBC 0
>::run::{closure#0} UBC 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0} CBC 782
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run CBC 783
<safekeeper::send_wal::WalSenders>::get_ws_remote_consistent_lsn CBC 1999
<safekeeper::send_wal::WalSendersShared>::get_slot CBC 1999
<safekeeper::send_wal::WalSenders>::get_remote_consistent_lsn CBC 22544
safekeeper::send_wal::wait_for_lsn CBC 689634
<safekeeper::send_wal::WalSenders>::record_ps_feedback CBC 779441
<safekeeper::send_wal::WalSendersShared>::update_ps_feedback CBC 779442
<safekeeper::send_wal::ReplyReader<_>>::handle_feedback CBC 779454
>::handle_feedback UBC 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback CBC 779454
<safekeeper::send_wal::ReplyReader<_>>::run::{closure#0} CBC 779454
>::run::{closure#0} UBC 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0} CBC 779454
<safekeeper::send_wal::WalSendersShared>::get_slot_mut CBC 779454
<safekeeper::send_wal::WalSender<_>>::wait_wal CBC 784396
>::wait_wal UBC 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal CBC 784396
<safekeeper::send_wal::WalSendersShared>::update_ps_feedback::{closure#0} CBC 784580
<safekeeper::send_wal::WalSender<_>>::wait_wal::{closure#0} CBC 786338
>::wait_wal::{closure#0} UBC 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal::{closure#0} CBC 786338
<safekeeper::send_wal::WalSenders>::update_remote_consistent_lsn CBC 789183
safekeeper::send_wal::wait_for_lsn::{closure#0} CBC 1378569
safekeeper::send_wal::wait_for_lsn::{closure#0} CBC 688935
safekeeper::send_wal::wait_for_lsn::{closure#0}::{closure#0} CBC 689634
<safekeeper::send_wal::WalSenders>::get_feedbacks CBC 2459760
<safekeeper::send_wal::HotStandbyFeedback>::empty CBC 2460797
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#3} CBC 2948536
::handle_start_replication_guts::<_>::{closure#0}::{closure#3} UBC 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} CBC 2948536
<safekeeper::send_wal::EndWatch>::get CBC 2998666
<safekeeper::send_wal::EndWatch>::changed CBC 3049218
::changed CBC 1524609
::changed::{closure#0} CBC 1524609

Generated by: LCOV version 2.1-beta