diff options
-rw-r--r-- | slobrok/src/vespa/slobrok/server/rpchooks.cpp | 42 | ||||
-rw-r--r-- | slobrok/src/vespa/slobrok/server/rpchooks.h | 4 |
2 files changed, 0 insertions, 46 deletions
diff --git a/slobrok/src/vespa/slobrok/server/rpchooks.cpp b/slobrok/src/vespa/slobrok/server/rpchooks.cpp index 70a9a0f268a..59f0b0e448a 100644 --- a/slobrok/src/vespa/slobrok/server/rpchooks.cpp +++ b/slobrok/src/vespa/slobrok/server/rpchooks.cpp @@ -73,14 +73,6 @@ RPCHooks::initRPC(FRT_Supervisor *supervisor) FRT_ReflectionBuilder rb(supervisor); //------------------------------------------------------------------------- - rb.DefineMethod("slobrok.system.resume", "", "", - FRT_METHOD(RPCHooks::rpc_resume), this); - rb.MethodDesc("Enable something - currently NOP"); - //------------------------------------------------------------------------- - rb.DefineMethod("slobrok.system.suspend", "", "", - FRT_METHOD(RPCHooks::rpc_suspend), this); - rb.MethodDesc("Disable something - currently NOP"); - //------------------------------------------------------------------------- rb.DefineMethod("slobrok.system.version", "", "s", FRT_METHOD(RPCHooks::rpc_version), this); rb.MethodDesc("Get location broker version"); @@ -139,11 +131,6 @@ RPCHooks::initRPC(FRT_Supervisor *supervisor) rb.MethodDesc("List rpcservers served"); rb.ReturnDesc("names", "The rpcserver names this server wants to serve"); //------------------------------------------------------------------------- - rb.DefineMethod("slobrok.callback.notifyUnregistered", "s", "", - FRT_METHOD(RPCHooks::rpc_notifyUnregistered), this); - rb.MethodDesc("Notify a server about removed registration"); - rb.ParamDesc("name", "NamedService name"); - //------------------------------------------------------------------------- //------------------------------------------------------------------------- rb.DefineMethod("slobrok.admin.removePeer", "ss", "", @@ -224,17 +211,6 @@ RPCHooks::rpc_listNamesServed(FRT_RPCRequest *req) } void -RPCHooks::rpc_notifyUnregistered(FRT_RPCRequest *req) -{ - FRT_Values &args = *req->GetParams(); - const char *dName = args[0]._string._str; - LOG(warning, "got notifyUnregistered '%s'", dName); - _cnts.otherReqs++; - return; -} - - -void RPCHooks::rpc_registerRpcServer(FRT_RPCRequest *req) { FRT_Values &args = *req->GetParams(); @@ -578,22 +554,4 @@ RPCHooks::rpc_version(FRT_RPCRequest *req) } -void -RPCHooks::rpc_suspend(FRT_RPCRequest *req) -{ - _cnts.adminReqs++; - req->SetError(FRTE_RPC_METHOD_FAILED, "not implemented"); - LOG(debug, "RPC suspend command received (ignored)"); -} - - -void -RPCHooks::rpc_resume(FRT_RPCRequest *req) -{ - _cnts.adminReqs++; - // XXX always ignored - (void) req; - LOG(debug, "RPC resume command received (ignored)"); -} - } // namespace slobrok diff --git a/slobrok/src/vespa/slobrok/server/rpchooks.h b/slobrok/src/vespa/slobrok/server/rpchooks.h index 58866e68a4e..499ce431d20 100644 --- a/slobrok/src/vespa/slobrok/server/rpchooks.h +++ b/slobrok/src/vespa/slobrok/server/rpchooks.h @@ -70,15 +70,11 @@ private: void rpc_doAdd(FRT_RPCRequest *req); void rpc_doRemove(FRT_RPCRequest *req); - void rpc_forceUnregisterRpcServer(FRT_RPCRequest *req); void rpc_listNamesServed(FRT_RPCRequest *req); - void rpc_notifyUnregistered(FRT_RPCRequest *req); void rpc_getRpcServerHistory(FRT_RPCRequest *req); void rpc_stop(FRT_RPCRequest *req); - void rpc_suspend(FRT_RPCRequest *req); void rpc_version(FRT_RPCRequest *req); - void rpc_resume(FRT_RPCRequest *req); }; } // namespace slobrok |