LCOV - code coverage report
Current view: top level - safekeeper/src - safekeeper.rs (source / functions) Coverage Total Hit
Test: c8f8d331b83562868d9054d9e0e68f866772aeaa.info Lines: 71.6 % 1058 757
Test Date: 2025-07-26 17:20:05 Functions: 70.1 % 177 124

Function Name Sort by function name Hit count Sort by function hit count
<<safekeeper::safekeeper::AcceptorState as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::visit_map::<&mut serde_json::value::de::MapDeserializer> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::<&mut serde_json::value::de::MapDeserializer> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<&mut serde_json::value::de::SeqDeserializer> 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>>> 0
<<safekeeper::safekeeper::AppendRequestHeader as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<_> 0
<<safekeeper::safekeeper::AppendRequestHeaderV2 as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_> 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::WithOtherIntEncoding, bincode::config::int::FixintEncoding>>> 0
<<safekeeper::safekeeper::ProposerGreeting as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<_> 0
<<safekeeper::safekeeper::ProposerGreetingV2 as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_> 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::WithOtherIntEncoding, bincode::config::int::FixintEncoding>>> 0
<<safekeeper::safekeeper::TermHistory as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<_> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_newtype_struct::<&mut bincode::de::Deserializer, bincode::config::int::FixintEncoding>, bincode::config::limit::Infinite>>> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_newtype_struct:: 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<_> 0
<<safekeeper::safekeeper::TermLsn as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::visit_map::<&mut serde_json::value::de::MapDeserializer> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_map::<&mut serde_json::value::de::MapDeserializer> 0
<::deserialize::__Visitor as serde::de::Visitor>::visit_seq::<&mut serde_json::value::de::SeqDeserializer> 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>>> 0
<<safekeeper::safekeeper::VoteRequestV2 as serde::de::Deserialize>::deserialize::__Visitor as serde::de::Visitor>::visit_map::<_> 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::WithOtherIntEncoding, bincode::config::int::FixintEncoding>>> 0
<bytes::bytes::Bytes as safekeeper::safekeeper::BytesF>::get_u16_f 0
<bytes::bytes::Bytes as safekeeper::safekeeper::BytesF>::get_u32_f 110419
<bytes::bytes::Bytes as safekeeper::safekeeper::BytesF>::get_u64_f 69221
<bytes::bytes::Bytes as safekeeper::safekeeper::BytesF>::get_u8_f 28750
<safekeeper::safekeeper::AcceptorProposerMessage>::put_cstr 0
<safekeeper::safekeeper::AcceptorProposerMessage>::serialize 27059
<safekeeper::safekeeper::AcceptorProposerMessage>::serialize_mconf 20162
<safekeeper::safekeeper::AcceptorState>::get_last_log_term 1292
<safekeeper::safekeeper::AppendResponse>::term_only 0
<safekeeper::safekeeper::ProposerAcceptorMessage>::get_cstr 40324
<safekeeper::safekeeper::ProposerAcceptorMessage>::get_cstr::{closure#0} 1330692
<safekeeper::safekeeper::ProposerAcceptorMessage>::get_cstr::{closure#1} 0
<safekeeper::safekeeper::ProposerAcceptorMessage>::get_mconf 20162
<safekeeper::safekeeper::ProposerAcceptorMessage>::get_mconf::{closure#2} 0
<safekeeper::safekeeper::ProposerAcceptorMessage>::get_mconf::{closure#3} 0
<safekeeper::safekeeper::ProposerAcceptorMessage>::get_mconf::{closure#4} 0
<safekeeper::safekeeper::ProposerAcceptorMessage>::get_mconf::{closure#6} 0
<safekeeper::safekeeper::ProposerAcceptorMessage>::get_mconf::{closure#7} 0
<safekeeper::safekeeper::ProposerAcceptorMessage>::get_mconf::{closure#8} 0
<safekeeper::safekeeper::ProposerAcceptorMessage>::parse 28750
<safekeeper::safekeeper::ProposerAcceptorMessage>::parse::{closure#0} 0
<safekeeper::safekeeper::ProposerAcceptorMessage>::size 620
<safekeeper::safekeeper::SafeKeeper<misc_test::walproposer_sim::safekeeper_disk::DiskStateStorage, misc_test::walproposer_sim::safekeeper_disk::DiskWALStorage>>::handle_append_request::{closure#0} 4482
>::handle_append_request::{closure#0} 657
>::handle_append_request::{closure#0} 3220
>::handle_append_request::{closure#0} 605
<safekeeper::safekeeper::SafeKeeper<misc_test::walproposer_sim::safekeeper_disk::DiskStateStorage, misc_test::walproposer_sim::safekeeper_disk::DiskWALStorage>>::handle_elected::{closure#0} 1021
>::handle_elected::{closure#0} 21
>::handle_elected::{closure#0} 997
>::handle_elected::{closure#0} 3
<safekeeper::safekeeper::SafeKeeper<misc_test::walproposer_sim::safekeeper_disk::DiskStateStorage, misc_test::walproposer_sim::safekeeper_disk::DiskWALStorage>>::handle_flush::{closure#0} 3812
>::handle_flush::{closure#0} 618
>::handle_flush::{closure#0} 2726
>::handle_flush::{closure#0} 468
<safekeeper::safekeeper::SafeKeeper<misc_test::walproposer_sim::safekeeper_disk::DiskStateStorage, misc_test::walproposer_sim::safekeeper_disk::DiskWALStorage>>::handle_greeting::{closure#0} 20162
>::handle_greeting::{closure#0} 91
>::handle_greeting::{closure#0} 20059
>::handle_greeting::{closure#0} 12
<safekeeper::safekeeper::SafeKeeper<misc_test::walproposer_sim::safekeeper_disk::DiskStateStorage, misc_test::walproposer_sim::safekeeper_disk::DiskWALStorage>>::handle_vote_request::{closure#0} 3085
>::handle_vote_request::{closure#0} 32
>::handle_vote_request::{closure#0} 3041
>::handle_vote_request::{closure#0} 12
<safekeeper::safekeeper::SafeKeeper<misc_test::walproposer_sim::safekeeper_disk::DiskStateStorage, misc_test::walproposer_sim::safekeeper_disk::DiskWALStorage>>::process_msg::{closure#0} 32562
>::process_msg::{closure#0} 1419
>::process_msg::{closure#0} 30043
>::process_msg::{closure#0} 1100
<safekeeper::safekeeper::SafeKeeper<misc_test::walproposer_sim::safekeeper_disk::DiskStateStorage, misc_test::walproposer_sim::safekeeper_disk::DiskWALStorage>>::update_commit_lsn::{closure#0} 2877
>::update_commit_lsn::{closure#0} 619
>::update_commit_lsn::{closure#0} 1658
>::update_commit_lsn::{closure#0} 600
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::append_response 4435
>::append_response 618
>::append_response 2726
>::append_response 620
>::append_response 3
>::append_response 468
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::flush_lsn 21266
>::flush_lsn 2000
>::flush_lsn 15680
>::flush_lsn 1870
>::flush_lsn 13
>::flush_lsn 1703
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::get_last_log_term 2
>::get_last_log_term 0
>::get_last_log_term 0
>::get_last_log_term 0
>::get_last_log_term 2
>::get_last_log_term 0
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::get_term_history 4115
>::get_term_history 53
>::get_term_history 4038
>::get_term_history 5
>::get_term_history 4
>::get_term_history 15
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::handle_append_request 5107
>::handle_append_request 657
>::handle_append_request 3220
>::handle_append_request 620
>::handle_append_request 5
>::handle_append_request 605
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::handle_append_request::{closure#0} 625
>::handle_append_request::{closure#0} 620
>::handle_append_request::{closure#0} 5
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::handle_elected 1029
>::handle_elected 21
>::handle_elected 997
>::handle_elected 5
>::handle_elected 3
>::handle_elected 3
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::handle_elected::{closure#0} 8
>::handle_elected::{closure#0} 5
>::handle_elected::{closure#0} 3
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::handle_flush 5052
>::handle_flush 618
>::handle_flush 2726
>::handle_flush 620
>::handle_flush::{closure#0} 620
>::handle_flush 0
>::handle_flush::{closure#0} 0
>::handle_flush 468
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::handle_greeting 20162
>::handle_greeting 91
>::handle_greeting 20059
>::handle_greeting 0
>::handle_greeting 0
>::handle_greeting 12
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::handle_greeting::{closure#0} 0
>::handle_greeting::{closure#0} 0
>::handle_greeting::{closure#0} 0
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::handle_vote_request 3088
>::handle_vote_request 32
>::handle_vote_request 3041
>::handle_vote_request 0
>::handle_vote_request 3
>::handle_vote_request 12
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::handle_vote_request::{closure#0} 3
>::handle_vote_request::{closure#0} 0
>::handle_vote_request::{closure#0} 3
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::new 9149
>::new 40
>::new 9094
>::new 5
>::new 4
>::new 6
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::process_msg 33818
>::process_msg 1419
>::process_msg 30043
>::process_msg 1245
>::process_msg 11
>::process_msg 1100
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::process_msg::{closure#0} 1256
>::process_msg::{closure#0} 1245
>::process_msg::{closure#0} 11
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::record_safekeeper_info 0
>::record_safekeeper_info 0
>::record_safekeeper_info::{closure#0} 0
<safekeeper::safekeeper::SafeKeeper<safekeeper::control_file::FileStorage, safekeeper::wal_storage::PhysicalStorage>>::update_commit_lsn 4117
>::update_commit_lsn 619
>::update_commit_lsn 1658
>::update_commit_lsn 620
>::update_commit_lsn::{closure#0} 620
>::update_commit_lsn 0
>::update_commit_lsn::{closure#0} 0
>::update_commit_lsn 600
<safekeeper::safekeeper::TermHistory as core::fmt::Debug>::fmt 163
<safekeeper::safekeeper::TermHistory as core::fmt::Debug>::fmt::{closure#0} 159
<safekeeper::safekeeper::TermHistory>::empty 1464
<safekeeper::safekeeper::TermHistory>::find_highest_common_point 1032
<safekeeper::safekeeper::TermHistory>::from_bytes 1021
<safekeeper::safekeeper::TermHistory>::from_bytes::{closure#1} 0
<safekeeper::safekeeper::TermHistory>::from_bytes::{closure#2} 0
<safekeeper::safekeeper::TermHistory>::from_bytes_le 0
<safekeeper::safekeeper::TermHistory>::up_to 5407
<safekeeper::safekeeper::TermLsn as core::convert::From<(u64, utils::lsn::Lsn)>>::from 1277
<safekeeper::safekeeper::tests::DummyWalStore as safekeeper::wal_storage::Storage>::flush_lsn 19
<safekeeper::safekeeper::tests::DummyWalStore as safekeeper::wal_storage::Storage>::flush_wal 10
::flush_wal 5
::flush_wal::{closure#0} 5
<safekeeper::safekeeper::tests::DummyWalStore as safekeeper::wal_storage::Storage>::get_metrics 0
<safekeeper::safekeeper::tests::DummyWalStore as safekeeper::wal_storage::Storage>::initialize_first_segment 4
::initialize_first_segment 2
::initialize_first_segment::{closure#0} 2
<safekeeper::safekeeper::tests::DummyWalStore as safekeeper::wal_storage::Storage>::remove_up_to 0
<safekeeper::safekeeper::tests::DummyWalStore as safekeeper::wal_storage::Storage>::remove_up_to::{closure#0} 0
<safekeeper::safekeeper::tests::DummyWalStore as safekeeper::wal_storage::Storage>::truncate_wal 4
::truncate_wal 2
::truncate_wal::{closure#0} 2
<safekeeper::safekeeper::tests::DummyWalStore as safekeeper::wal_storage::Storage>::write_lsn 4
<safekeeper::safekeeper::tests::DummyWalStore as safekeeper::wal_storage::Storage>::write_wal 6
::write_wal 3
::write_wal::{closure#0} 3
<safekeeper::safekeeper::tests::InMemoryState as core::ops::deref::Deref>::deref 100
<safekeeper::safekeeper::tests::InMemoryState as safekeeper::control_file::Storage>::last_persist_at 0
<safekeeper::safekeeper::tests::InMemoryState as safekeeper::control_file::Storage>::persist 10
::persist 5
::persist::{closure#0} 5
safekeeper::safekeeper::tests::test_find_highest_common_point_middle 1
safekeeper::safekeeper::tests::test_find_highest_common_point_none 1
safekeeper::safekeeper::tests::test_find_highest_common_point_sk_end 1
safekeeper::safekeeper::tests::test_find_highest_common_point_walprop 1
safekeeper::safekeeper::tests::test_last_log_term_switch 2
safekeeper::safekeeper::tests::test_last_log_term_switch 1
safekeeper::safekeeper::tests::test_last_log_term_switch::{closure#0} 1
safekeeper::safekeeper::tests::test_non_consecutive_write 2
safekeeper::safekeeper::tests::test_non_consecutive_write 1
safekeeper::safekeeper::tests::test_non_consecutive_write::{closure#0} 1
safekeeper::safekeeper::tests::test_sk_state 3
safekeeper::safekeeper::tests::test_sk_state_bincode_serde_roundtrip 1
safekeeper::safekeeper::tests::test_voting 2
safekeeper::safekeeper::tests::test_voting 1
safekeeper::safekeeper::tests::test_voting::{closure#0} 1

Generated by: LCOV version 2.1-beta