summaryrefslogtreecommitdiffstats
path: root/slobrok
diff options
context:
space:
mode:
authorArne Juul <arnej@yahoo-inc.com>2018-10-03 18:45:08 +0000
committerArne Juul <arnej@yahoo-inc.com>2018-10-03 18:45:08 +0000
commit936e4ebdef80ee00d541a8700ddc2d19ff2486e8 (patch)
tree4badb80baaf6808cc1855a233c03459dc068113d /slobrok
parent5646cca73e1eb7a0564a3c44f55ea0be4bef2c60 (diff)
simplify / clarify code somewhat
Diffstat (limited to 'slobrok')
-rw-r--r--slobrok/src/vespa/slobrok/server/cmd.cpp25
1 files changed, 16 insertions, 9 deletions
diff --git a/slobrok/src/vespa/slobrok/server/cmd.cpp b/slobrok/src/vespa/slobrok/server/cmd.cpp
index 00eda9799d7..99e86814852 100644
--- a/slobrok/src/vespa/slobrok/server/cmd.cpp
+++ b/slobrok/src/vespa/slobrok/server/cmd.cpp
@@ -82,11 +82,18 @@ void cleanupReservation(ScriptData & data)
void
ScriptCommand::doneHandler(OkState result)
{
- LOG_ASSERT(_data != nullptr);
+ LOG_ASSERT(_data);
std::unique_ptr<ScriptData> dataUP = std::move(_data);
+ LOG_ASSERT(! _data);
ScriptData & data = *dataUP;
+ const char *name_p = data.name.c_str();
+ const char *spec_p = data.spec.c_str();
+ ExchangeManager &xch = data.env._exchanger;
+ RpcServerManager &rsm = data.env._rpcsrvmanager;
+
if (result.failed()) {
- LOG(warning, "failed in state %d: %s", data._state, result.errorMsg.c_str());
+ LOG(warning, "failed [%s->%s] in state %d: %s",
+ name_p, spec_p, data._state, result.errorMsg.c_str());
cleanupReservation(data);
// XXX should handle different state errors differently?
if (data.registerRequest != nullptr) {
@@ -98,22 +105,22 @@ ScriptCommand::doneHandler(OkState result)
return;
}
if (data._state == ScriptData::RDC_INIT) {
- LOG(spam, "phase wantAdd(%s,%s)", data.name.c_str(), data.spec.c_str());
+ LOG(spam, "phase wantAdd(%s,%s)", name_p, spec_p);
data._state = ScriptData::XCH_WANTADD;
- data.env._exchanger.wantAdd(std::move(dataUP));
+ xch.wantAdd(std::move(dataUP));
return;
} else if (data._state == ScriptData::XCH_WANTADD) {
- LOG(spam, "phase addManaged(%s,%s)", data.name.c_str(), data.spec.c_str());
+ LOG(spam, "phase addManaged(%s,%s)", name_p, spec_p);
data._state = ScriptData::CHK_RPCSRV;
- data.env._rpcsrvmanager.addManaged(std::move(dataUP));
+ rsm.addManaged(std::move(dataUP));
return;
} else if (data._state == ScriptData::CHK_RPCSRV) {
- LOG(spam, "phase doAdd(%s,%s)", data.name.c_str(), data.spec.c_str());
+ LOG(spam, "phase doAdd(%s,%s)", name_p, spec_p);
data._state = ScriptData::XCH_DOADD;
- data.env._exchanger.doAdd(std::move(dataUP));
+ xch.doAdd(std::move(dataUP));
return;
} else if (data._state == ScriptData::XCH_DOADD) {
- LOG(debug, "done doAdd(%s,%s)", data.name.c_str(), data.spec.c_str());
+ LOG(debug, "done doAdd(%s,%s)", name_p, spec_p);
data._state = ScriptData::RDC_INVAL;
// all OK
data.registerRequest->Return();