summaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorHarald Musum <musum@yahoo-inc.com>2018-01-30 19:30:16 +0100
committerGitHub <noreply@github.com>2018-01-30 19:30:16 +0100
commit0c585016ca2f8fbd25756f761552693e2445c23d (patch)
tree4ba84755780853b3ea7e670605456d716fed38ca /storage
parent4d175c3c37d6ffada13dd15023d575f8e663351e (diff)
Revert "Geirst/add bucket space to document api"
Diffstat (limited to 'storage')
-rw-r--r--storage/src/vespa/storage/storageserver/communicationmanager.cpp5
1 files changed, 2 insertions, 3 deletions
diff --git a/storage/src/vespa/storage/storageserver/communicationmanager.cpp b/storage/src/vespa/storage/storageserver/communicationmanager.cpp
index 190c04cf36a..b61717e5b67 100644
--- a/storage/src/vespa/storage/storageserver/communicationmanager.cpp
+++ b/storage/src/vespa/storage/storageserver/communicationmanager.cpp
@@ -425,8 +425,7 @@ void CommunicationManager::configure(std::unique_ptr<CommunicationManagerConfig>
_mbus = std::make_unique<mbus::RPCMessageBus>(
mbus::ProtocolSet()
.add(std::make_shared<documentapi::DocumentProtocol>(*_component.getLoadTypes(), _component.getTypeRepo()))
- .add(std::make_shared<mbusprot::StorageProtocol>(_component.getTypeRepo(), *_component.getLoadTypes(),
- _component.enableMultipleBucketSpaces())),
+ .add(std::make_shared<mbusprot::StorageProtocol>(_component.getTypeRepo(), *_component.getLoadTypes(), _component.enableMultipleBucketSpaces())),
params,
_configUri);
@@ -767,7 +766,7 @@ void CommunicationManager::updateMessagebusProtocol(
const document::DocumentTypeRepo::SP &repo) {
if (_mbus.get()) {
framework::SecondTime now(_component.getClock().getTimeInSeconds());
- auto newDocumentProtocol = std::make_shared<documentapi::DocumentProtocol>(*_component.getLoadTypes(), repo);
+ mbus::IProtocol::SP newDocumentProtocol(new 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()));