aboutsummaryrefslogtreecommitdiff
path: root/tests/unit_tests/node_server.cpp
diff options
context:
space:
mode:
authorluigi1111 <luigi1111w@gmail.com>2021-08-11 22:40:13 -0400
committerluigi1111 <luigi1111w@gmail.com>2021-08-11 22:40:13 -0400
commit82149bfe441e56d5f9d72a13ffa25ce1df6d8391 (patch)
treedca9428448629cea75f298051bbd5e93581ace98 /tests/unit_tests/node_server.cpp
parent460fd4c80ac77539596985510678291236ca1b02 (diff)
parent9c8e3e832e0da86403cbf2716b08a24898d5fce0 (diff)
downloadmonzero-core-82149bfe441e56d5f9d72a13ffa25ce1df6d8391.tar.gz
monzero-core-82149bfe441e56d5f9d72a13ffa25ce1df6d8391.tar.xz
monzero-core-82149bfe441e56d5f9d72a13ffa25ce1df6d8391.zip
Merge pull request #7818
9c8e3e8 unit_tests: fix broken tests (anon)
Diffstat (limited to 'tests/unit_tests/node_server.cpp')
-rw-r--r--tests/unit_tests/node_server.cpp10
1 files changed, 6 insertions, 4 deletions
diff --git a/tests/unit_tests/node_server.cpp b/tests/unit_tests/node_server.cpp
index 2c80acda5..cab600b3d 100644
--- a/tests/unit_tests/node_server.cpp
+++ b/tests/unit_tests/node_server.cpp
@@ -795,9 +795,11 @@ TEST(cryptonote_protocol_handler, race_condition)
workers_t workers;
} check;
check.work = std::make_shared<work_t>(check.io_context);
- check.workers.emplace_back([&check]{
- check.io_context.run();
- });
+ while (check.workers.size() < 2) {
+ check.workers.emplace_back([&check]{
+ check.io_context.run();
+ });
+ }
while (daemon.main.conn.size() < 1) {
daemon.main.conn.emplace_back(new connection_t(check.io_context, daemon.main.shared_state, {}, {}));
daemon.alt.conn.emplace_back(new connection_t(io_context, daemon.alt.shared_state, {}, {}));
@@ -856,7 +858,7 @@ TEST(cryptonote_protocol_handler, race_condition)
}
}
while (daemon.main.conn.size() < 2) {
- daemon.main.conn.emplace_back(new connection_t(io_context, daemon.main.shared_state, {}, {}));
+ daemon.main.conn.emplace_back(new connection_t(check.io_context, daemon.main.shared_state, {}, {}));
daemon.alt.conn.emplace_back(new connection_t(io_context, daemon.alt.shared_state, {}, {}));
create_conn_pair(daemon.main.conn.back(), daemon.alt.conn.back());
conduct_handshake(daemon.alt.net_node, daemon.alt.conn.back());