dn724/dncurrency
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Block broadcast stats

Browse source
This commit is contained in:
Piotr Wójcik 2025-04-18 14:17:57 +02:00
commit 57769d4937
2 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
nano/core_test/node.cpp
View file

@ -3615,7 +3615,7 @@ TEST (node, local_block_broadcast)
// Wait until a broadcast is attempted
ASSERT_TIMELY_EQ (5s, node1.local_block_broadcaster.size (), 1);
ASSERT_TIMELY (5s, node1.stats.count (nano::stat::type::local_block_broadcaster, nano::stat::detail::broadcast, nano::stat::dir::out) >= 1);
ASSERT_TIMELY (5s, node1.stats.count (nano::stat::type::local_block_broadcaster, nano::stat::detail::broadcast) >= 1);
// The other node should not have received the block
ASSERT_NEVER (500ms, node2.block (send1->hash ()));

7
nano/node/local_block_broadcaster.cpp
View file

@ -195,8 +195,11 @@ void nano::local_block_broadcaster::run_broadcasts (nano::unique_lock<nano::mute
entry.block->hash (),
entry.rebroadcasts);
stats.inc (nano::stat::type::local_block_broadcaster, nano::stat::detail::broadcast, nano::stat::dir::out);
network.flood_block_initial (entry.block);
stats.inc (nano::stat::type::local_block_broadcaster, nano::stat::detail::broadcast);
auto sent = network.flood_block_initial (entry.block);
stats.add (nano::stat::type::local_block_broadcaster, nano::stat::detail::sent, sent);
}
}