diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-06-26 20:29:36 +0000 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-06-26 20:29:36 +0000 |
| commit | 9cd0f66be8245318198588a1b1dec9bfe917b49e (patch) | |
| tree | b31aa3641f5167908f2bd51dce6ce99eb9549158 /storage | |
| parent | b659a529c013d6ff0ac21c0a54f49d6b38dc5c67 (diff) | |
Remove 'requireSequencing' as an option.
As a consequence move protocol and params resolution to common code so that it is always handled in the decoding/encoding thread.
Diffstat (limited to 'storage')
| -rw-r--r-- | storage/src/vespa/storage/config/stor-communicationmanager.def | 2 | ||||
| -rw-r--r-- | storage/src/vespa/storageapi/mbusprot/storageprotocol.h | 1 |
2 files changed, 1 insertions, 2 deletions
diff --git a/storage/src/vespa/storage/config/stor-communicationmanager.def b/storage/src/vespa/storage/config/stor-communicationmanager.def index 65a3cd718ec..6090e6bcd08 100644 --- a/storage/src/vespa/storage/config/stor-communicationmanager.def +++ b/storage/src/vespa/storage/config/stor-communicationmanager.def @@ -51,7 +51,7 @@ mbus.dispatch_on_encode bool default=true restart ## Enable to use above thread pool for decoding replies ## False will use network(fnet) thread ## Todo: Change default once verified in large scale deployment. -mbus.dispatch_on_decode bool default=false restart +mbus.dispatch_on_decode bool default=true restart ## Skip messenger thread on reply ## Experimental diff --git a/storage/src/vespa/storageapi/mbusprot/storageprotocol.h b/storage/src/vespa/storageapi/mbusprot/storageprotocol.h index 3f36ac42117..591009c9832 100644 --- a/storage/src/vespa/storageapi/mbusprot/storageprotocol.h +++ b/storage/src/vespa/storageapi/mbusprot/storageprotocol.h @@ -22,7 +22,6 @@ public: mbus::IRoutingPolicy::UP createPolicy(const mbus::string& name, const mbus::string& param) const override; mbus::Blob encode(const vespalib::Version&, const mbus::Routable&) const override; mbus::Routable::UP decode(const vespalib::Version&, mbus::BlobRef) const override; - bool requireSequencing() const override { return true; } private: ProtocolSerialization5_0 _serializer5_0; ProtocolSerialization5_1 _serializer5_1; |