LCOV - code coverage report

Current view: top level - safekeeper/src - send_interpreted_wal.rs (source / functions) Coverage Total Hit Test: 5445d246133daeceb0507e6cc0797ab7c1c70cb8.info Lines: 86.9 % 892 775 Test Date: 2025-03-12 18:05:02 Functions: 75.0 % 52 39

Function Name	Hit count
<safekeeper::send_interpreted_wal::CurrentPositionUpdate>::current_position	0
<safekeeper::send_interpreted_wal::CurrentPositionUpdate>::previous_position	0
<safekeeper::send_interpreted_wal::InterpretedWalReader>::run_impl::{closure#0}::{closure#3}	0
<safekeeper::send_interpreted_wal::InterpretedWalReader>::run_impl::{closure#0}::{closure#5}	0
<safekeeper::send_interpreted_wal::InterpretedWalReader>::spawn::{closure#0}::{closure#0}	0
<safekeeper::send_interpreted_wal::InterpretedWalSender<_>>::run	0
>::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	0
>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0}	0
<safekeeper::send_interpreted_wal::InterpretedWalSender<_>>::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_interpreted_wal::ShardSenderId as core::fmt::Display>::fmt	0
<safekeeper::send_interpreted_wal::ShardSenderId>::shard	0
<safekeeper::send_interpreted_wal::InterpretedWalReader>::new	1
<safekeeper::send_interpreted_wal::InterpretedWalReader>::run	1
<safekeeper::send_interpreted_wal::InterpretedWalReader>::run::{closure#0}	1
<safekeeper::send_interpreted_wal::InterpretedWalReader>::state	1
safekeeper::send_interpreted_wal::tests::test_shard_zero_does_not_skip_empty_records::{closure#0}::{closure#0}	1
<safekeeper::send_interpreted_wal::SenderId>::next	2
safekeeper::send_interpreted_wal::tests::test_batch_start_tracking_on_reset	2
safekeeper::send_interpreted_wal::tests::test_batch_start_tracking_on_reset	1
safekeeper::send_interpreted_wal::tests::test_batch_start_tracking_on_reset::{closure#0}	1
safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_fanout	2
safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_fanout	1
safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_fanout::{closure#0}	1
safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_same_shard_fanout	2
safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_same_shard_fanout	1
safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_same_shard_fanout::{closure#0}	1
safekeeper::send_interpreted_wal::tests::test_shard_zero_does_not_skip_empty_records	2
safekeeper::send_interpreted_wal::tests::test_shard_zero_does_not_skip_empty_records	1
safekeeper::send_interpreted_wal::tests::test_shard_zero_does_not_skip_empty_records::{closure#0}	1
<safekeeper::send_interpreted_wal::InterpretedWalReader>::spawn	3
<safekeeper::send_interpreted_wal::InterpretedWalReader>::spawn::{closure#0}	3
<safekeeper::send_interpreted_wal::InterpretedWalReaderHandle as core::ops::drop::Drop>::drop	3
<safekeeper::send_interpreted_wal::InterpretedWalReaderHandle>::fanout	3
<safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_same_shard_fanout::{closure#0}::Sender>::new	3
safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_same_shard_fanout::{closure#0}::{closure#0}	3
<safekeeper::send_interpreted_wal::InterpretedWalReaderState>::maybe_reset	4
<safekeeper::send_interpreted_wal::InterpretedWalReaderHandle>::abort	6
<safekeeper::send_interpreted_wal::InterpretedWalReaderHandle>::current_position	6
<safekeeper::send_interpreted_wal::InterpretedWalReaderState>::current_position	6
<safekeeper::send_interpreted_wal::SenderId>::first	6
<safekeeper::send_interpreted_wal::InterpretedWalReader>::run_impl	8
::run_impl	4
::run_impl::{closure#0}	4
safekeeper::send_interpreted_wal::tests::test_shard_zero_does_not_skip_empty_records::{closure#0}::{closure#1}	9
safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_fanout::{closure#0}::{closure#0}	13
safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_fanout::{closure#0}::{closure#1}	13
safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_fanout::{closure#0}::{closure#6}	13
<safekeeper::send_interpreted_wal::InterpretedWalReaderState>::replace_current_batch_wal_start	41
<safekeeper::send_interpreted_wal::InterpretedWalReaderState>::update_current_position	41
<safekeeper::send_interpreted_wal::InterpretedWalReader>::run_impl::{closure#0}::{closure#2}	50
<safekeeper::send_interpreted_wal::InterpretedWalReaderState>::update_current_batch_wal_start	50
<safekeeper::send_interpreted_wal::InterpretedWalReaderState>::current_batch_wal_start	57
safekeeper::send_interpreted_wal::tests::test_interpreted_wal_reader_same_shard_fanout::{closure#0}::{closure#1}	600
<safekeeper::send_interpreted_wal::ShardSenderId>::new	877
<safekeeper::send_interpreted_wal::InterpretedWalReader>::run_impl::{closure#0}::{closure#4}	1002

Generated by: LCOV version 2.1-beta