summaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@oath.com>2018-01-18 14:08:07 +0000
committerGeir Storli <geirst@oath.com>2018-01-29 15:32:14 +0000
commit539d67d9a3bca7723af9f4b484f9a041c7053be5 (patch)
tree7c976b1b85e69debc3dfe1f6480de9e5da20e91d /storage
parent9c8e5bff07378ba8d127b73b2eb6fd52ba7c7b1f (diff)
Remove conditional enabling of protocol feature in favor of version
Cannot selectively enable for DocumentProtocol since bucket space config only applies per-cluster, while the protocol is application-global.
Diffstat (limited to 'storage')
-rw-r--r--storage/src/vespa/storage/storageserver/communicationmanager.cpp6
1 files changed, 2 insertions, 4 deletions
diff --git a/storage/src/vespa/storage/storageserver/communicationmanager.cpp b/storage/src/vespa/storage/storageserver/communicationmanager.cpp
index 9a3d3b71f38..b57be697a5e 100644
--- a/storage/src/vespa/storage/storageserver/communicationmanager.cpp
+++ b/storage/src/vespa/storage/storageserver/communicationmanager.cpp
@@ -444,8 +444,7 @@ void CommunicationManager::configure(std::unique_ptr<CommunicationManagerConfig>
// config here.
_mbus = std::make_unique<mbus::RPCMessageBus>(
mbus::ProtocolSet()
- .add(std::make_shared<documentapi::DocumentProtocol>(*_component.getLoadTypes(), _component.getTypeRepo(), "",
- _component.enableMultipleBucketSpaces()))
+ .add(std::make_shared<documentapi::DocumentProtocol>(*_component.getLoadTypes(), _component.getTypeRepo()))
.add(std::make_shared<mbusprot::StorageProtocol>(_component.getTypeRepo(), *_component.getLoadTypes(),
_component.enableMultipleBucketSpaces())),
params,
@@ -788,8 +787,7 @@ void CommunicationManager::updateMessagebusProtocol(
const document::DocumentTypeRepo::SP &repo) {
if (_mbus.get()) {
framework::SecondTime now(_component.getClock().getTimeInSeconds());
- mbus::IProtocol::SP newDocumentProtocol(new documentapi::DocumentProtocol(
- *_component.getLoadTypes(), repo, "", _component.enableMultipleBucketSpaces()));
+ auto newDocumentProtocol = std::make_shared<documentapi::DocumentProtocol>(*_component.getLoadTypes(), repo);
std::lock_guard<std::mutex> guard(_earlierGenerationsLock);
_earlierGenerations.push_back(std::make_pair(now, _mbus->getMessageBus().putProtocol(newDocumentProtocol)));
mbus::IProtocol::SP newStorageProtocol(new mbusprot::StorageProtocol(repo, *_component.getLoadTypes(), _component.enableMultipleBucketSpaces()));