diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-26 23:23:48 +0200 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-26 23:23:48 +0200 |
| commit | 911cc20b5253e8c14d4ab534cb46fd40470db9f0 (patch) | |
| tree | 1d06f11d17cf911d2c0eb3b491e978b9e5875780 /messagebus | |
| parent | dd8ec1f9da0b8323d5d726cad8b8df532883fcdd (diff) | |
Assert that task is accepted.
Diffstat (limited to 'messagebus')
| -rw-r--r-- | messagebus/src/vespa/messagebus/network/rpcsend.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/messagebus/src/vespa/messagebus/network/rpcsend.cpp b/messagebus/src/vespa/messagebus/network/rpcsend.cpp index 244c14e8d75..5d5611a45fa 100644 --- a/messagebus/src/vespa/messagebus/network/rpcsend.cpp +++ b/messagebus/src/vespa/messagebus/network/rpcsend.cpp @@ -242,7 +242,8 @@ void RPCSend::invoke(FRT_RPCRequest *req) { req->Detach(); - _net->getExecutor().execute(vespalib::makeLambdaTask([this, req]() { doRequest(req);})); + auto rejected = _net->getExecutor().execute(vespalib::makeLambdaTask([this, req]() { doRequest(req);})); + assert(!rejected); } void |