diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-05-11 22:52:27 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-05-11 22:52:27 +0200 |
commit | 8e26b410a2732761785fe63bc860b28bd9c4e982 (patch) | |
tree | a9a11f6ee5e520d7f9f65b43c8d46dd3c440b80e /fnet/src/examples/frt/rpc/rpc_proxy.cpp | |
parent | 90e442757dbb76d412639b0952847d386dc09c0c (diff) | |
parent | 5d1e06bc17211381ad4029eedc8060537761ac52 (diff) |
Merge pull request #9360 from vespa-engine/balder/supervisor-has-only-1-role
Simplify the supervisor responsibility
Diffstat (limited to 'fnet/src/examples/frt/rpc/rpc_proxy.cpp')
-rw-r--r-- | fnet/src/examples/frt/rpc/rpc_proxy.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/fnet/src/examples/frt/rpc/rpc_proxy.cpp b/fnet/src/examples/frt/rpc/rpc_proxy.cpp index 496190b2b80..1f1a3a80f2f 100644 --- a/fnet/src/examples/frt/rpc/rpc_proxy.cpp +++ b/fnet/src/examples/frt/rpc/rpc_proxy.cpp @@ -224,18 +224,18 @@ App::Main() } bool verbose = (_argc > 3) && (strcmp(_argv[3], "verbose") == 0); - FRT_Supervisor supervisor; + fnet::frt::StandaloneFRT server; + FRT_Supervisor & supervisor = server.supervisor(); RPCProxy proxy(supervisor, _argv[2], verbose); supervisor.GetReflectionManager()->Reset(); supervisor.SetSessionInitHook(FRT_METHOD(RPCProxy::HOOK_Init), &proxy); supervisor.SetSessionDownHook(FRT_METHOD(RPCProxy::HOOK_Down), &proxy); supervisor.SetSessionFiniHook(FRT_METHOD(RPCProxy::HOOK_Fini), &proxy); - supervisor.SetMethodMismatchHook(FRT_METHOD(RPCProxy::HOOK_Mismatch), - &proxy); + supervisor.SetMethodMismatchHook(FRT_METHOD(RPCProxy::HOOK_Mismatch), &proxy); supervisor.Listen(_argv[1]); FNET_SignalShutDown ssd(*supervisor.GetTransport()); - supervisor.Main(); + server.supervisor().GetTransport()->WaitFinished(); return 0; } |