gitea-mirror/monero
1
0
Fork 0
mirror of https://github.com/monero-project/monero.git synced 2026-07-28 14:47:15 -07:00
Code Issues Packages Projects Releases Wiki Activity

tests: check node_server race init and connect

Browse Source
This commit is contained in:
selsta
2026-06-28 19:24:36 +02:00
parent 85d5a6f95b
commit 4a627d44fa
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/unit_tests/node_server.cpp
+6 -3
View File
@@ -1208,6 +1208,7 @@ TEST(node_server, race_condition)
using work_ptr = std::shared_ptr<work_t>; using work_ptr = std::shared_ptr<work_t>;
using workers_t = std::vector<std::thread>; using workers_t = std::vector<std::thread>;
using endpoint_t = boost::asio::ip::tcp::endpoint; using endpoint_t = boost::asio::ip::tcp::endpoint;
using ec_t = boost::system::error_code;
using event_t = epee::simple_event; using event_t = epee::simple_event;
struct command_handler_t: epee::levin::levin_commands_handler<context_t> { struct command_handler_t: epee::levin::levin_commands_handler<context_t> {
using span_t = epee::span<const uint8_t>; using span_t = epee::span<const uint8_t>;
@@ -1238,7 +1239,9 @@ TEST(node_server, race_condition)
shared_state->set_handler(new command_handler_t, &command_handler_t::destroy); shared_state->set_handler(new command_handler_t, &command_handler_t::destroy);
connection_ptr conn{new connection_t(io_context, shared_state, {}, {})}; connection_ptr conn{new connection_t(io_context, shared_state, {}, {})};
endpoint_t endpoint(boost::asio::ip::make_address("127.0.0.1"), 48080); endpoint_t endpoint(boost::asio::ip::make_address("127.0.0.1"), 48080);
conn->socket().connect(endpoint); ec_t ec;
conn->socket().connect(endpoint, ec);
ASSERT_EQ(ec.value(), 0) << "connect to 127.0.0.1:48080 failed: " << ec.message();
conn->socket().set_option(boost::asio::ip::tcp::socket::reuse_address(true)); conn->socket().set_option(boost::asio::ip::tcp::socket::reuse_address(true));
conn->start({}, {}); conn->start({}, {});
context_t context; context_t context;
@@ -1280,7 +1283,7 @@ TEST(node_server, race_condition)
protocol_t protocol{}; protocol_t protocol{};
node_server_t node_server(protocol); node_server_t node_server(protocol);
protocol.set_p2p_endpoint(&node_server); protocol.set_p2p_endpoint(&node_server);
node_server.init( ASSERT_TRUE(node_server.init(
[&dir]{ [&dir]{
options_t options; options_t options;
boost::program_options::store( boost::program_options::store(
@@ -1303,7 +1306,7 @@ TEST(node_server, race_condition)
); );
return options; return options;
}() }()
); ));
worker_t worker([&]{ worker_t worker([&]{
node_server.run(); node_server.run();
}); });