LCOV - differential code coverage report
Current view: top level - safekeeper/src - send_wal.rs (source / functions) Coverage Total Hit LBC UBC CBC
Current: cd44433dd675caa99df17a61b18949c8387e2242.info Lines: 93.7 % 462 433 1 28 433
Current Date: 2024-01-09 02:06:09 Functions: 45.3 % 159 72 2 85 72
Baseline: 66c52a629a0f4a503e193045e0df4c77139e344b.info
Baseline Date: 2024-01-08 15:34:46

Function Name Sort by function name TLA Hit count Sort by function hit count
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<_> CBC 734
::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 734
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<_>::{closure#0} CBC 734
::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 734
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_> CBC 734
::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 734
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0} CBC 734
::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 734
<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::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#1} CBC 18
::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 18
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#2} CBC 734
::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 734
<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<_>::{closure#0}::{closure#3} CBC 2111715
::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 2111715
<safekeeper::send_wal::EndWatch>::changed CBC 2405234
::changed CBC 1202617
::changed::{closure#0} CBC 1202617
<safekeeper::send_wal::EndWatch>::get CBC 2261841
<safekeeper::send_wal::HotStandbyFeedback as core::fmt::Debug>::fmt CBC 7
<::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::<<&mut bincode::de::Deserializer<_, _> as serde::de::Deserializer>::deserialize_tuple::Access, bincode::config::int::FixintEncoding>, bincode::config::limit::Infinite>>> CBC 2
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> UBC 0
::clone UBC 0
::fmt UBC 0
::deserialize::<&mut bincode::de::Deserializer, bincode::config::int::FixintEncoding>, bincode::config::limit::Infinite>>> CBC 2
::deserialize::<&mut serde_json::de::Deserializer> UBC 0
::deserialize::> UBC 0
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 3
::serialize::<&mut serde_json::ser::Serializer<&mut utils::http::endpoint::ChannelWriter>> UBC 0
::serialize::, serde_json::ser::CompactFormatter>> UBC 0
::serialize::> UBC 0
<safekeeper::send_wal::HotStandbyFeedback>::empty CBC 1295244
<safekeeper::send_wal::ReplicationFeedback as core::fmt::Debug>::fmt CBC 196
<::deserialize::__Field as serde::de::Deserialize>::deserialize::<&mut serde_json::de::Deserializer> CBC 3
<::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:: CBC 3
<::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
<::deserialize::__Visitor as serde::de::Visitor>::visit_enum::> CBC 3
::clone CBC 92
::fmt UBC 0
::deserialize::<&mut serde_json::de::Deserializer> CBC 3
::deserialize::> UBC 0
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 88
::serialize::<&mut serde_json::ser::Serializer<&mut utils::http::endpoint::ChannelWriter>> CBC 4
::serialize::, serde_json::ser::CompactFormatter>> UBC 0
::serialize::> UBC 0
<safekeeper::send_wal::ReplyReader<_>>::handle_feedback CBC 567108
>::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 567108
<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::ReplyReader<_>>::run CBC 1468
>::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 CBC 734
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0} CBC 734
<safekeeper::send_wal::StandbyFeedback as core::fmt::Debug>::fmt LBC 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>> LBC 0
::serialize::<&mut serde_json::ser::Serializer<&mut utils::http::endpoint::ChannelWriter>> UBC 0
<safekeeper::send_wal::StandbyReply as core::fmt::Debug>::fmt CBC 2590
<::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::<<&mut bincode::de::Deserializer<_, _> as serde::de::Deserializer>::deserialize_tuple::Access, bincode::config::int::FixintEncoding>, bincode::config::limit::Infinite>>> CBC 1295
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> UBC 0
::clone UBC 0
::fmt UBC 0
::deserialize::<&mut bincode::de::Deserializer, bincode::config::int::FixintEncoding>, bincode::config::limit::Infinite>>> CBC 1295
::deserialize::<&mut serde_json::de::Deserializer> UBC 0
::deserialize::> UBC 0
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> LBC 0
::serialize::<&mut serde_json::ser::Serializer<&mut utils::http::endpoint::ChannelWriter>> UBC 0
::serialize::, serde_json::ser::CompactFormatter>> UBC 0
::serialize::> UBC 0
<safekeeper::send_wal::StandbyReply>::empty CBC 4
<safekeeper::send_wal::WalSender<_>>::run CBC 1468
>::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 CBC 734
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0} CBC 734
<safekeeper::send_wal::WalSender<_>>::run::{closure#0}::{closure#0}::{closure#0} UBC 0
>::run::{closure#0}::{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}::{closure#0} UBC 0
<safekeeper::send_wal::WalSender<_>>::run::{closure#0}::{closure#1} UBC 0
>::run::{closure#0}::{closure#1} UBC 0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0}::{closure#1} UBC 0
<safekeeper::send_wal::WalSender<_>>::wait_wal CBC 1138140
>::wait_wal UBC 0
>::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 CBC 569070
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal::{closure#0} CBC 569070
<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::WalSenderGuard as core::ops::drop::Drop>::drop CBC 418
<safekeeper::send_wal::WalSenderState as core::fmt::Debug>::fmt CBC 220
<::deserialize::__Field as serde::de::Deserialize>::deserialize::> CBC 15
<::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:: CBC 15
<::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::> CBC 3
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::> UBC 0
::clone CBC 92
::fmt UBC 0
::deserialize::<&mut serde_json::de::Deserializer> CBC 3
::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec>> CBC 88
::serialize::<&mut serde_json::ser::Serializer<&mut utils::http::endpoint::ChannelWriter>> CBC 4
<safekeeper::send_wal::WalSenders>::get_all CBC 252
<safekeeper::send_wal::WalSenders>::get_feedbacks CBC 1294232
<safekeeper::send_wal::WalSenders>::get_ps_feedback CBC 51
<safekeeper::send_wal::WalSenders>::get_remote_consistent_lsn CBC 26716
<safekeeper::send_wal::WalSenders>::get_ws_remote_consistent_lsn CBC 3461
<safekeeper::send_wal::WalSenders>::new CBC 582
<safekeeper::send_wal::WalSenders>::record_hs_feedback CBC 2
<safekeeper::send_wal::WalSenders>::record_ps_feedback CBC 565811
<safekeeper::send_wal::WalSenders>::record_standby_reply CBC 1295
<safekeeper::send_wal::WalSenders>::register CBC 734
<safekeeper::send_wal::WalSenders>::register::{closure#0} CBC 348
<safekeeper::send_wal::WalSenders>::unregister CBC 418
<safekeeper::send_wal::WalSenders>::update_remote_consistent_lsn CBC 577771
<safekeeper::send_wal::WalSendersShared>::get_slot CBC 3461
<safekeeper::send_wal::WalSendersShared>::get_slot_mut CBC 567108
<safekeeper::send_wal::WalSendersShared>::new CBC 585
<safekeeper::send_wal::WalSendersShared>::update_hs_feedback CBC 422
<safekeeper::send_wal::WalSendersShared>::update_ps_feedback CBC 565812
<safekeeper::send_wal::WalSendersShared>::update_ps_feedback::{closure#0} CBC 570374
safekeeper::send_wal::tests::hs_feedback CBC 4
safekeeper::send_wal::tests::mock_addr CBC 6
safekeeper::send_wal::tests::mock_ttid CBC 6
safekeeper::send_wal::tests::ps_feedback CBC 2
safekeeper::send_wal::tests::push_feedback CBC 6
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::wait_for_lsn CBC 490111
safekeeper::send_wal::wait_for_lsn::{closure#0} CBC 490111
safekeeper::send_wal::wait_for_lsn::{closure#0}::{closure#0} CBC 490111

Generated by: LCOV version 2.1-beta