diff options
Diffstat (limited to 'fnet/src/tests/connection_spread/connection_spread_test.cpp')
-rw-r--r-- | fnet/src/tests/connection_spread/connection_spread_test.cpp | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/fnet/src/tests/connection_spread/connection_spread_test.cpp b/fnet/src/tests/connection_spread/connection_spread_test.cpp index d65e4fb70fe..6286ce65657 100644 --- a/fnet/src/tests/connection_spread/connection_spread_test.cpp +++ b/fnet/src/tests/connection_spread/connection_spread_test.cpp @@ -6,7 +6,6 @@ #include <vespa/fnet/ipacketstreamer.h> #include <vespa/fnet/connector.h> #include <vespa/fnet/connection.h> -#include <vespa/fastos/thread.h> #include <vespa/vespalib/util/size_literals.h> #include <vespa/vespalib/util/stringfmt.h> #include <thread> @@ -28,13 +27,12 @@ struct DummyStreamer : FNET_IPacketStreamer { struct Fixture { DummyStreamer streamer; DummyAdapter adapter; - FastOS_ThreadPool thread_pool; FNET_Transport client; FNET_Transport server; - Fixture() : streamer(), adapter(), thread_pool(), client(8), server(8) + Fixture() : streamer(), adapter(), client(8), server(8) { - ASSERT_TRUE(client.Start(&thread_pool)); - ASSERT_TRUE(server.Start(&thread_pool)); + ASSERT_TRUE(client.Start()); + ASSERT_TRUE(server.Start()); } void wait_for_components(size_t client_cnt, size_t server_cnt) { bool ok = false; @@ -49,7 +47,6 @@ struct Fixture { ~Fixture() { server.ShutDown(true); client.ShutDown(true); - thread_pool.Close(); } }; |