diff options
Diffstat (limited to 'logd/src/tests/rpc_forwarder/rpc_forwarder_test.cpp')
-rw-r--r-- | logd/src/tests/rpc_forwarder/rpc_forwarder_test.cpp | 19 |
1 files changed, 18 insertions, 1 deletions
diff --git a/logd/src/tests/rpc_forwarder/rpc_forwarder_test.cpp b/logd/src/tests/rpc_forwarder/rpc_forwarder_test.cpp index 4c87f5a025e..30ca5e19d44 100644 --- a/logd/src/tests/rpc_forwarder/rpc_forwarder_test.cpp +++ b/logd/src/tests/rpc_forwarder/rpc_forwarder_test.cpp @@ -94,16 +94,33 @@ struct MockMetricsManager : public DummyMetricsManager { } }; +class ClientSupervisor { +private: + FRT_Supervisor _supervisor; +public: + ClientSupervisor() + : _supervisor() + { + _supervisor.Start(); + } + ~ClientSupervisor() { + _supervisor.ShutDown(true); + } + FRT_Supervisor& get() { return _supervisor; } + +}; + struct RpcForwarderTest : public ::testing::Test { RpcServer server; std::shared_ptr<MockMetricsManager> metrics_mgr; Metrics metrics; + ClientSupervisor supervisor; RpcForwarder forwarder; RpcForwarderTest() : server(), metrics_mgr(std::make_shared<MockMetricsManager>()), metrics(metrics_mgr), - forwarder(metrics, "localhost", server.get_listen_port(), 60.0, 3) + forwarder(metrics, supervisor.get(), "localhost", server.get_listen_port(), 60.0, 3) { ForwardMap forward_filter; forward_filter[ns_log::Logger::error] = true; |