diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-06-09 09:32:11 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-06-09 09:32:11 +0200 |
commit | 0ee92f9947f0a93f0ccd552dd9a994fc06e99faa (patch) | |
tree | a423663b579302c4e9ad6831dc1cad64e3c44601 /storage | |
parent | 0dfa4ad213abb67f63fd7a27263e7adeb8360792 (diff) |
Use std::make_unique.
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storage/storageserver/fnetlistener.cpp | 48 |
1 files changed, 14 insertions, 34 deletions
diff --git a/storage/src/vespa/storage/storageserver/fnetlistener.cpp b/storage/src/vespa/storage/storageserver/fnetlistener.cpp index bcd98effd60..9cc4a643d55 100644 --- a/storage/src/vespa/storage/storageserver/fnetlistener.cpp +++ b/storage/src/vespa/storage/storageserver/fnetlistener.cpp @@ -65,42 +65,28 @@ FNetListener::initRPC() { FRT_ReflectionBuilder rb(_orb.get()); - rb.DefineMethod( - "getnodestate3", "sii", "ss", true, - FRT_METHOD(FNetListener::RPC_getNodeState2), - this); + rb.DefineMethod("getnodestate3", "sii", "ss", true, FRT_METHOD(FNetListener::RPC_getNodeState2), this); rb.MethodDesc("Get state of this node"); rb.ParamDesc("nodestate", "Expected state of given node. If correct, the " "request will be queued on target until it changes. To not give " "any state use the string 'unknown', enforcing a direct reply."); - rb.ParamDesc("timeout", "Timeout of message in milliseconds, set by the " - "state requester"); + rb.ParamDesc("timeout", "Timeout of message in milliseconds, set by the state requester"); rb.ReturnDesc("nodestate", "State string for this node"); rb.ReturnDesc("hostinfo", "Information about host this node is running on"); //------------------------------------------------------------------------- - rb.DefineMethod( - "getnodestate2", "si", "s", true, - FRT_METHOD(FNetListener::RPC_getNodeState2), - this); + rb.DefineMethod("getnodestate2", "si", "s", true, FRT_METHOD(FNetListener::RPC_getNodeState2), this); rb.MethodDesc("Get state of this node"); rb.ParamDesc("nodestate", "Expected state of given node. If correct, the " "request will be queued on target until it changes. To not give " "any state use the string 'unknown', enforcing a direct reply."); - rb.ParamDesc("timeout", "Timeout of message in milliseconds, set by the " - "state requester"); + rb.ParamDesc("timeout", "Timeout of message in milliseconds, set by the state requester"); rb.ReturnDesc("nodestate", "State string for this node"); //------------------------------------------------------------------------- - rb.DefineMethod( - "setsystemstate2", "s", "", true, - FRT_METHOD(FNetListener::RPC_setSystemState2), - this); + rb.DefineMethod("setsystemstate2", "s", "", true, FRT_METHOD(FNetListener::RPC_setSystemState2), this); rb.MethodDesc("Set systemstate on this node"); rb.ParamDesc("systemstate", "New systemstate to set"); //------------------------------------------------------------------------- - rb.DefineMethod( - "getcurrenttime", "", "lis", true, - FRT_METHOD(FNetListener::RPC_getCurrentTime), - this); + rb.DefineMethod("getcurrenttime", "", "lis", true, FRT_METHOD(FNetListener::RPC_getCurrentTime), this); rb.MethodDesc("Get current time on this node"); rb.ReturnDesc("seconds", "Current time in seconds since epoch"); rb.ReturnDesc("nanoseconds", "additional nanoseconds since epoch"); @@ -140,10 +126,9 @@ FNetListener::RPC_getNodeState2(FRT_RPCRequest *req) req->GetParams()->GetValue(0)._string._len); std::shared_ptr<api::GetNodeStateCommand> cmd( - new api::GetNodeStateCommand( - expected != "unknown" ? - std::unique_ptr<lib::NodeState>(new lib::NodeState(expected)) : - std::unique_ptr<lib::NodeState>())); + new api::GetNodeStateCommand(expected != "unknown" + ? std::make_unique<lib::NodeState>(expected) + : std::unique_ptr<lib::NodeState>())); cmd->setPriority(api::StorageMessage::VERYHIGH); cmd->setTimeout(req->GetParams()->GetValue(1)._intval32); @@ -151,9 +136,7 @@ FNetListener::RPC_getNodeState2(FRT_RPCRequest *req) cmd->setSourceIndex(req->GetParams()->GetValue(2)._intval32); } // Create a request object to avoid needing a separate transport type - std::unique_ptr<RPCRequestWrapper> request(new RPCRequestWrapper(req)); - cmd->setTransportContext(std::unique_ptr<api::TransportContext>( - new StorageTransportContext(std::move(request)))); + cmd->setTransportContext(std::make_unique<StorageTransportContext>(std::make_unique<RPCRequestWrapper>(req))); req->Detach(); _comManager.enqueue(cmd); } @@ -167,17 +150,14 @@ FNetListener::RPC_setSystemState2(FRT_RPCRequest *req) return; } vespalib::string systemStateStr(req->GetParams()->GetValue(0)._string._str, - req->GetParams()->GetValue(0)._string._len); + req->GetParams()->GetValue(0)._string._len); lib::ClusterState systemState(systemStateStr); - std::shared_ptr<api::SetSystemStateCommand> cmd( - new api::SetSystemStateCommand(systemState)); + std::shared_ptr<api::SetSystemStateCommand> cmd(std::make_shared<api::SetSystemStateCommand>(systemState)); cmd->setPriority(api::StorageMessage::VERYHIGH); - // Create a request object to avoid needing a separate transport type - std::unique_ptr<RPCRequestWrapper> request(new RPCRequestWrapper(req)); - cmd->setTransportContext(std::unique_ptr<api::TransportContext>( - new StorageTransportContext(std::move(request)))); + // Create a request object to avoid needing a separate transport type + cmd->setTransportContext(std::make_unique<StorageTransportContext>(std::make_unique<RPCRequestWrapper>(req))); req->Detach(); _comManager.enqueue(cmd); } |