diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-27 12:17:39 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-27 12:17:39 +0200 |
commit | e5b560719a4d6e364cbcb52e200501786e907133 (patch) | |
tree | 0e3d352260b6732b186ddab85141fce2a8c3af32 /messagebus/src | |
parent | e2856b653042a28f2978fa32dab2fa84a455a384 (diff) |
Assert that we are not rejected. If we are there are a logic flaw somewhere....
Diffstat (limited to 'messagebus/src')
-rw-r--r-- | messagebus/src/vespa/messagebus/network/rpcnetwork.cpp | 3 | ||||
-rw-r--r-- | messagebus/src/vespa/messagebus/network/rpcsend.cpp | 7 |
2 files changed, 6 insertions, 4 deletions
diff --git a/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp b/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp index a454f8382c0..b451a538161 100644 --- a/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp +++ b/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp @@ -86,10 +86,11 @@ RPCNetwork::SendContext::handleVersion(const vespalib::Version *version) } } if (shouldSend) { - _net.getExecutor().execute(vespalib::makeLambdaTask([this]() { + auto rejected = _net.getExecutor().execute(vespalib::makeLambdaTask([this]() { _net.send(*this); delete this; })); + assert (!rejected); } } diff --git a/messagebus/src/vespa/messagebus/network/rpcsend.cpp b/messagebus/src/vespa/messagebus/network/rpcsend.cpp index 53f1bb8a70a..bc1ac75e778 100644 --- a/messagebus/src/vespa/messagebus/network/rpcsend.cpp +++ b/messagebus/src/vespa/messagebus/network/rpcsend.cpp @@ -148,8 +148,8 @@ RPCSend::send(RoutingNode &recipient, const vespalib::Version &version, void RPCSend::RequestDone(FRT_RPCRequest *req) { - auto task = _net->getExecutor().execute(makeLambdaTask([this, req]() { doRequestDone(req);})); - assert(!task); + auto rejected = _net->getExecutor().execute(makeLambdaTask([this, req]() { doRequestDone(req);})); + assert(!rejected); } void @@ -221,9 +221,10 @@ RPCSend::decode(vespalib::stringref protocolName, const vespalib::Version & vers void RPCSend::handleReply(Reply::UP reply) { - _net->getExecutor().execute(makeLambdaTask([this, reply = std::move(reply)]() mutable { + auto rejected = _net->getExecutor().execute(makeLambdaTask([this, reply = std::move(reply)]() mutable { doHandleReply(std::move(reply)); })); + assert (!rejected); } void |