diff options
author | Geir Storli <geirst@verizonmedia.com> | 2019-03-29 08:45:50 +0000 |
---|---|---|
committer | Geir Storli <geirst@verizonmedia.com> | 2019-03-29 08:45:50 +0000 |
commit | 24e3f9a0da95f11d0603a727e1ea0c860422de2e (patch) | |
tree | 6086fe8449745f148e5b86615fba029608064d24 /logd/src/tests/rpc_forwarder | |
parent | d0dd5320ca4d41847b5b789d2a8c6f7c21061b5b (diff) |
Move ownership of supervisor out of rpc forwarder.
Diffstat (limited to 'logd/src/tests/rpc_forwarder')
-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; |