|
|
|
@ -265,11 +265,17 @@ namespace
|
|
|
|
|
virtual void callback(cryptonote::levin::detail::p2p_context& context) override final
|
|
|
|
|
{}
|
|
|
|
|
|
|
|
|
|
virtual void on_connection_new(cryptonote::levin::detail::p2p_context&) override final
|
|
|
|
|
{}
|
|
|
|
|
virtual void on_connection_new(cryptonote::levin::detail::p2p_context& context) override final
|
|
|
|
|
{
|
|
|
|
|
if (notifier)
|
|
|
|
|
notifier->on_handshake_complete(context.m_connection_id, context.m_is_income);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
virtual void on_connection_close(cryptonote::levin::detail::p2p_context&) override final
|
|
|
|
|
{}
|
|
|
|
|
virtual void on_connection_close(cryptonote::levin::detail::p2p_context& context) override final
|
|
|
|
|
{
|
|
|
|
|
if (notifier)
|
|
|
|
|
notifier->on_connection_close(context.m_connection_id);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public:
|
|
|
|
|
test_receiver()
|
|
|
|
@ -306,6 +312,8 @@ namespace
|
|
|
|
|
{
|
|
|
|
|
return get_raw_message(notified_);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier{};
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
class levin_notify : public ::testing::Test
|
|
|
|
@ -343,13 +351,16 @@ namespace
|
|
|
|
|
EXPECT_EQ(connection_ids_.size(), connections_->get_connections_count());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
cryptonote::levin::notify make_notifier(const std::size_t noise_size, bool is_public, bool pad_txs)
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> make_notifier(const std::size_t noise_size, bool is_public, bool pad_txs)
|
|
|
|
|
{
|
|
|
|
|
epee::byte_slice noise = nullptr;
|
|
|
|
|
if (noise_size)
|
|
|
|
|
noise = epee::levin::make_noise_notify(noise_size);
|
|
|
|
|
epee::net_utils::zone zone = is_public ? epee::net_utils::zone::public_ : epee::net_utils::zone::i2p;
|
|
|
|
|
return cryptonote::levin::notify{io_service_, connections_, std::move(noise), zone, pad_txs, events_};
|
|
|
|
|
receiver_.notifier.reset(
|
|
|
|
|
new cryptonote::levin::notify{io_service_, connections_, std::move(noise), zone, pad_txs, events_}
|
|
|
|
|
);
|
|
|
|
|
return receiver_.notifier;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
boost::uuids::random_generator random_generator_;
|
|
|
|
@ -517,7 +528,8 @@ TEST_F(levin_notify, defaulted)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, fluff_without_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -563,7 +575,8 @@ TEST_F(levin_notify, fluff_without_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, stem_without_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -635,7 +648,8 @@ TEST_F(levin_notify, stem_without_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, stem_no_outs_without_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(true);
|
|
|
|
@ -690,7 +704,8 @@ TEST_F(levin_notify, stem_no_outs_without_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, local_without_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -762,7 +777,8 @@ TEST_F(levin_notify, local_without_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, forward_without_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -834,7 +850,8 @@ TEST_F(levin_notify, forward_without_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, block_without_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -863,7 +880,8 @@ TEST_F(levin_notify, block_without_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, none_without_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -892,7 +910,8 @@ TEST_F(levin_notify, none_without_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, fluff_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -938,7 +957,8 @@ TEST_F(levin_notify, fluff_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, stem_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1005,7 +1025,8 @@ TEST_F(levin_notify, stem_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, stem_no_outs_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(true);
|
|
|
|
@ -1059,7 +1080,8 @@ TEST_F(levin_notify, stem_no_outs_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, local_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1126,7 +1148,8 @@ TEST_F(levin_notify, local_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, forward_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1193,7 +1216,8 @@ TEST_F(levin_notify, forward_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, block_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1222,7 +1246,8 @@ TEST_F(levin_notify, block_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, none_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1251,7 +1276,8 @@ TEST_F(levin_notify, none_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, private_fluff_without_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1302,7 +1328,8 @@ TEST_F(levin_notify, private_fluff_without_padding)
|
|
|
|
|
TEST_F(levin_notify, private_stem_without_padding)
|
|
|
|
|
{
|
|
|
|
|
// private mode always uses fluff but marked as stem
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1353,7 +1380,8 @@ TEST_F(levin_notify, private_stem_without_padding)
|
|
|
|
|
TEST_F(levin_notify, private_local_without_padding)
|
|
|
|
|
{
|
|
|
|
|
// private mode always uses fluff but marked as stem
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1404,7 +1432,8 @@ TEST_F(levin_notify, private_local_without_padding)
|
|
|
|
|
TEST_F(levin_notify, private_forward_without_padding)
|
|
|
|
|
{
|
|
|
|
|
// private mode always uses fluff but marked as stem
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1455,7 +1484,8 @@ TEST_F(levin_notify, private_forward_without_padding)
|
|
|
|
|
TEST_F(levin_notify, private_block_without_padding)
|
|
|
|
|
{
|
|
|
|
|
// private mode always uses fluff but marked as stem
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1485,7 +1515,8 @@ TEST_F(levin_notify, private_block_without_padding)
|
|
|
|
|
TEST_F(levin_notify, private_none_without_padding)
|
|
|
|
|
{
|
|
|
|
|
// private mode always uses fluff but marked as stem
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1514,7 +1545,8 @@ TEST_F(levin_notify, private_none_without_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, private_fluff_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1564,7 +1596,8 @@ TEST_F(levin_notify, private_fluff_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, private_stem_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1614,7 +1647,8 @@ TEST_F(levin_notify, private_stem_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, private_local_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1664,7 +1698,8 @@ TEST_F(levin_notify, private_local_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, private_forward_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1714,7 +1749,8 @@ TEST_F(levin_notify, private_forward_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, private_block_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1743,7 +1779,8 @@ TEST_F(levin_notify, private_block_with_padding)
|
|
|
|
|
|
|
|
|
|
TEST_F(levin_notify, private_none_with_padding)
|
|
|
|
|
{
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, false, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, false, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < 10; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1774,7 +1811,8 @@ TEST_F(levin_notify, stem_mappings)
|
|
|
|
|
{
|
|
|
|
|
static constexpr const unsigned test_connections_count = (CRYPTONOTE_DANDELIONPP_STEMS + 1) * 2;
|
|
|
|
|
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < test_connections_count; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -1897,7 +1935,8 @@ TEST_F(levin_notify, fluff_multiple)
|
|
|
|
|
{
|
|
|
|
|
static constexpr const unsigned test_connections_count = (CRYPTONOTE_DANDELIONPP_STEMS + 1) * 2;
|
|
|
|
|
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(0, true, false);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(0, true, false);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
for (unsigned count = 0; count < test_connections_count; ++count)
|
|
|
|
|
add_connection(count % 2 == 0);
|
|
|
|
@ -2015,7 +2054,8 @@ TEST_F(levin_notify, noise)
|
|
|
|
|
txs[0].resize(1900, 'h');
|
|
|
|
|
|
|
|
|
|
const boost::uuids::uuid incoming_id = random_generator_();
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(2048, false, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(2048, false, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
{
|
|
|
|
|
const auto status = notifier.get_status();
|
|
|
|
@ -2106,7 +2146,8 @@ TEST_F(levin_notify, noise_stem)
|
|
|
|
|
txs[0].resize(1900, 'h');
|
|
|
|
|
|
|
|
|
|
const boost::uuids::uuid incoming_id = random_generator_();
|
|
|
|
|
cryptonote::levin::notify notifier = make_notifier(2048, false, true);
|
|
|
|
|
std::shared_ptr<cryptonote::levin::notify> notifier_ptr = make_notifier(2048, false, true);
|
|
|
|
|
auto ¬ifier = *notifier_ptr;
|
|
|
|
|
|
|
|
|
|
{
|
|
|
|
|
const auto status = notifier.get_status();
|
|
|
|
|