aboutsummaryrefslogtreecommitdiffstats
path: root/logd/src/tests/rpc_forwarder/rpc_forwarder_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'logd/src/tests/rpc_forwarder/rpc_forwarder_test.cpp')
-rw-r--r--logd/src/tests/rpc_forwarder/rpc_forwarder_test.cpp19
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;