diff options
| author | j-berman <justinberman@protonmail.com> | 2026-03-17 19:39:13 -0700 |
|---|---|---|
| committer | j-berman <justinberman@protonmail.com> | 2026-04-04 15:02:49 -0700 |
| commit | 7bc2d5a42e8462f2a04f71bd59111a863fa9a6d8 (patch) | |
| tree | 90d8e4661f991777b4dedf996da8455bbbc2f6c9 /tests/net_load_tests | |
| parent | 1df631970fa610824117c85e05afddcedcdf8196 (diff) | |
| download | monzero-core-7bc2d5a42e8462f2a04f71bd59111a863fa9a6d8.tar.gz monzero-core-7bc2d5a42e8462f2a04f71bd59111a863fa9a6d8.tar.xz monzero-core-7bc2d5a42e8462f2a04f71bd59111a863fa9a6d8.zip | |
p2p: fix hanging shutdown
Diffstat (limited to 'tests/net_load_tests')
| -rw-r--r-- | tests/net_load_tests/clt.cpp | 2 | ||||
| -rw-r--r-- | tests/net_load_tests/net_load_tests.h | 2 | ||||
| -rw-r--r-- | tests/net_load_tests/srv.cpp | 2 |
3 files changed, 3 insertions, 3 deletions
diff --git a/tests/net_load_tests/clt.cpp b/tests/net_load_tests/clt.cpp index 6149de653..d0e79468a 100644 --- a/tests/net_load_tests/clt.cpp +++ b/tests/net_load_tests/clt.cpp @@ -110,7 +110,7 @@ namespace { if (!m_connections[id].is_nil()) { - m_tcp_server.get_config_object().close(m_connections[id]); + m_tcp_server.get_config_object().close(m_connections[id], true); return true; } else diff --git a/tests/net_load_tests/net_load_tests.h b/tests/net_load_tests/net_load_tests.h index 7af92f159..03ac952f1 100644 --- a/tests/net_load_tests/net_load_tests.h +++ b/tests/net_load_tests/net_load_tests.h @@ -188,7 +188,7 @@ namespace net_load_tests LOG_PRINT_L0("Connection isn't opened"); return false; } - if (!m_tcp_server.get_config_object().close(m_connections[idx])) + if (!m_tcp_server.get_config_object().close(m_connections[idx], true)) { LOG_PRINT_L0("Close connection error: " << m_connections[idx]); if (!ignore_close_fails) diff --git a/tests/net_load_tests/srv.cpp b/tests/net_load_tests/srv.cpp index de06812a1..59a92718a 100644 --- a/tests/net_load_tests/srv.cpp +++ b/tests/net_load_tests/srv.cpp @@ -176,7 +176,7 @@ namespace if (!ctx.m_closed) { ctx.m_closed = true; - m_tcp_server.get_config_object().close(ctx.m_connection_id); + m_tcp_server.get_config_object().close(ctx.m_connection_id, true); } else { |