diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-30 18:37:05 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-30 18:37:05 +0200 |
commit | af4345125a88ac53b347b003595398d3bedb095d (patch) | |
tree | f2a425ff4948d1f659eb28b0995bfa5ca255ba9a /messagebus | |
parent | 19ac47a78d13646a4142688cb554f08b4a3400c3 (diff) |
Be conservative if you do not know the protocol.
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/vespa/messagebus/network/rpcsend.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/messagebus/src/vespa/messagebus/network/rpcsend.cpp b/messagebus/src/vespa/messagebus/network/rpcsend.cpp index 1ee791d5454..e23f4dc29d9 100644 --- a/messagebus/src/vespa/messagebus/network/rpcsend.cpp +++ b/messagebus/src/vespa/messagebus/network/rpcsend.cpp @@ -221,7 +221,7 @@ void RPCSend::handleReply(Reply::UP reply) { const IProtocol * protocol = _net->getOwner().getProtocol(reply->getProtocol()); - if (protocol->requireSequencing()) { + if (!protocol || protocol->requireSequencing()) { doHandleReply(protocol, std::move(reply)); } else { auto rejected = _net->getExecutor().execute(makeLambdaTask([this, protocol, reply = std::move(reply)]() mutable { |