diff options
author | Håvard Pettersen <havardpe@oath.com> | 2018-09-04 12:16:55 +0000 |
---|---|---|
committer | Håvard Pettersen <havardpe@oath.com> | 2018-09-05 13:25:25 +0000 |
commit | f163bfa304b627aa0fda87b13bf4d22f5bf21fbf (patch) | |
tree | 9b1d694b790ac407417ea5dfa0f0ddbb0ae500b7 /searchcore | |
parent | 3bcb5407524034b3206aef269fef52a196023504 (diff) |
remove non-instant invocation
Diffstat (limited to 'searchcore')
3 files changed, 12 insertions, 12 deletions
diff --git a/searchcore/src/vespa/searchcore/fdispatch/common/rpc.cpp b/searchcore/src/vespa/searchcore/fdispatch/common/rpc.cpp index 0d2f6dff983..eaff3b90d78 100644 --- a/searchcore/src/vespa/searchcore/fdispatch/common/rpc.cpp +++ b/searchcore/src/vespa/searchcore/fdispatch/common/rpc.cpp @@ -43,12 +43,12 @@ FastS_RPC::Init(int port, const vespalib::string &myHeartbeatId) void FastS_RPC::RegisterMethods(FRT_ReflectionBuilder *rb) { - rb->DefineMethod("fs.admin.getNodeType", "", "s", true, + rb->DefineMethod("fs.admin.getNodeType", "", "s", FRT_METHOD(FastS_RPC::RPC_GetNodeType), this); rb->MethodDesc("Get string indicating the node type"); rb->ReturnDesc("type", "node type"); //---------------------------------------------------------------// - rb->DefineMethod("fs.admin.getCompileInfo", "", "*", true, + rb->DefineMethod("fs.admin.getCompileInfo", "", "*", FRT_METHOD(FastS_RPC::RPC_GetCompileInfo), this); rb->MethodDesc("Obtain compile info for this node"); rb->ReturnDesc("info", "any number of descriptive strings"); diff --git a/searchcore/src/vespa/searchcore/fdispatch/program/rpc.cpp b/searchcore/src/vespa/searchcore/fdispatch/program/rpc.cpp index 4217ef6d8c9..56301c5e986 100644 --- a/searchcore/src/vespa/searchcore/fdispatch/program/rpc.cpp +++ b/searchcore/src/vespa/searchcore/fdispatch/program/rpc.cpp @@ -9,13 +9,13 @@ FastS_fdispatch_RPC::RegisterMethods(FRT_ReflectionBuilder *rb) { FastS_RPC::RegisterMethods(rb); //------------------------------------------------------------------ - rb->DefineMethod("fs.admin.enableEngine", "s", "i", true, + rb->DefineMethod("fs.admin.enableEngine", "s", "i", FRT_METHOD(FastS_fdispatch_RPC::RPC_EnableEngine), this); rb->MethodDesc("Enable the given engine (clear badness)."); rb->ParamDesc("name", "engine name"); rb->ReturnDesc("count", "number of engines affected"); //------------------------------------------------------------------ - rb->DefineMethod("fs.admin.disableEngine", "s", "i", true, + rb->DefineMethod("fs.admin.disableEngine", "s", "i", FRT_METHOD(FastS_fdispatch_RPC::RPC_DisableEngine), this); rb->MethodDesc("Disable the given engine (mark as admin bad)."); rb->ParamDesc("name", "engine name"); diff --git a/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp b/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp index ab012760762..6e442f472b1 100644 --- a/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp @@ -127,7 +127,7 @@ RPCHooksBase::initRPC() FRT_ReflectionBuilder rb(_orb.get()); //------------------------------------------------------------------------- - rb.DefineMethod("pandora.rtc.getState", "ii", "SSi", true, + rb.DefineMethod("pandora.rtc.getState", "ii", "SSi", FRT_METHOD(RPCHooksBase::rpc_GetState), this); rb.MethodDesc("Get the current state of node"); rb.ParamDesc("gencnt", "old state generation held by the client"); @@ -136,7 +136,7 @@ RPCHooksBase::initRPC() rb.ReturnDesc("values", "Array of state values"); rb.ReturnDesc("newgen", "New state generation count"); //------------------------------------------------------------------------- - rb.DefineMethod("proton.getStatus", "s", "SSSS", true, + rb.DefineMethod("proton.getStatus", "s", "SSSS", FRT_METHOD(RPCHooksBase::rpc_GetProtonStatus), this); rb.MethodDesc("Get the current state of proton or a proton component"); rb.ParamDesc("component", "Which component to check the status for"); @@ -145,7 +145,7 @@ RPCHooksBase::initRPC() rb.ReturnDesc("internalStates", "Array of internal states "); rb.ReturnDesc("message", "Array of status messages"); //------------------------------------------------------------------------- - rb.DefineMethod("pandora.rtc.getIncrementalState", "i", "SSi", true, + rb.DefineMethod("pandora.rtc.getIncrementalState", "i", "SSi", FRT_METHOD(RPCHooksBase::rpc_getIncrementalState), this); rb.MethodDesc("Get node state changes since last invocation"); rb.ParamDesc("timeout", "How many milliseconds to wait for state update"); @@ -153,26 +153,26 @@ RPCHooksBase::initRPC() rb.ReturnDesc("values", "Array of state values"); rb.ReturnDesc("dummy", "Dummy value to enable code reuse"); //------------------------------------------------------------------------- - rb.DefineMethod("pandora.rtc.shutdown", "", "", true, + rb.DefineMethod("pandora.rtc.shutdown", "", "", FRT_METHOD(RPCHooksBase::rpc_Shutdown), this); rb.MethodDesc("Shut down the rtc application"); //------------------------------------------------------------------------- - rb.DefineMethod("pandora.rtc.die", "", "", true, + rb.DefineMethod("pandora.rtc.die", "", "", FRT_METHOD(RPCHooksBase::rpc_die), this); rb.MethodDesc("Exit the rtc application without cleanup"); //------------------------------------------------------------------------- - rb.DefineMethod("proton.triggerFlush", "", "b", true, + rb.DefineMethod("proton.triggerFlush", "", "b", FRT_METHOD(RPCHooksBase::rpc_triggerFlush), this); rb.MethodDesc("Tell the node to trigger flush ASAP"); rb.ReturnDesc("success", "Whether or not a flush was triggered."); //------------------------------------------------------------------------- - rb.DefineMethod("proton.prepareRestart", "", "b", true, + rb.DefineMethod("proton.prepareRestart", "", "b", FRT_METHOD(RPCHooksBase::rpc_prepareRestart), this); rb.MethodDesc("Tell the node to prepare for a restart by flushing components " "such that TLS replay time + time spent flushing components is as low as possible"); rb.ReturnDesc("success", "Whether or not prepare for restart was triggered."); //------------------------------------------------------------------------- - rb.DefineMethod("proton.getDocsums", "bix", "bix", true, FRT_METHOD(RPCHooksBase::rpc_getDocSums), this); + rb.DefineMethod("proton.getDocsums", "bix", "bix", FRT_METHOD(RPCHooksBase::rpc_getDocSums), this); rb.MethodDesc("Get list of document summaries"); rb.ParamDesc("encoding", "0=raw, 6=lz4"); rb.ParamDesc("uncompressedBlobSize", "Uncompressed blob size"); |