aboutsummaryrefslogtreecommitdiffstats
path: root/fnet/src/tests/frt/parallel_rpc/parallel_rpc_test.cpp
diff options
context:
space:
mode:
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.cpp6
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) {}