Assert that we are not rejected. If we are there are a logic flaw somewhere....

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