diff options
Diffstat (limited to 'fnet/src/tests/frt/parallel_rpc/parallel_rpc_test.cpp')
-rw-r--r-- | fnet/src/tests/frt/parallel_rpc/parallel_rpc_test.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/fnet/src/tests/frt/parallel_rpc/parallel_rpc_test.cpp b/fnet/src/tests/frt/parallel_rpc/parallel_rpc_test.cpp index b027b80f8ab..74f1dea0c9a 100644 --- a/fnet/src/tests/frt/parallel_rpc/parallel_rpc_test.cpp +++ b/fnet/src/tests/frt/parallel_rpc/parallel_rpc_test.cpp @@ -42,6 +42,7 @@ struct Server : Rpc { init_rpc(); start(); } + ~Server() override; void init_rpc() { FRT_ReflectionBuilder rb(&orb); rb.DefineMethod("inc", "l", "l", FRT_METHOD(Server::rpc_inc), this); @@ -56,14 +57,19 @@ struct Server : Rpc { } }; +Server::~Server() = default; + struct Client : Rpc { uint32_t port; Client(CryptoEngine::SP crypto, size_t num_threads, const Server &server, bool drop_empty = false) : Rpc(std::move(crypto), num_threads, drop_empty), port(server.port) { start(); } + ~Client() override; FRT_Target *connect() { return Rpc::connect(port); } }; +Client::~Client() = default; + struct Result { std::vector<double> req_per_sec; explicit Result(size_t num_threads) : req_per_sec(num_threads, 0.0) {} |