summaryrefslogtreecommitdiffstats
path: root/storageserver
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@oath.com>2018-04-04 14:05:50 +0000
committerTor Egge <Tor.Egge@oath.com>2018-04-04 14:11:05 +0000
commit91a0164390282d89b5b295142e4f06ce27afdbc2 (patch)
tree5645cc655627e2c1d44170cbc8c20e5c30af320a /storageserver
parent02227976fd12c40beb2fcfd2361c52e02b9f06ab (diff)
Start using DocumentTypeRepoFactory.
Diffstat (limited to 'storageserver')
-rw-r--r--storageserver/src/vespa/storageserver/app/process.cpp7
1 files changed, 5 insertions, 2 deletions
diff --git a/storageserver/src/vespa/storageserver/app/process.cpp b/storageserver/src/vespa/storageserver/app/process.cpp
index a604490ba85..0ebce27eebb 100644
--- a/storageserver/src/vespa/storageserver/app/process.cpp
+++ b/storageserver/src/vespa/storageserver/app/process.cpp
@@ -1,6 +1,7 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "process.h"
+#include <vespa/document/repo/document_type_repo_factory.h>
#include <vespa/storage/storageserver/storagenode.h>
#include <vespa/storage/storageserver/storagenodecontext.h>
#include <vespa/vespalib/util/exceptions.h>
@@ -8,6 +9,8 @@
#include <vespa/log/log.h>
LOG_SETUP(".process");
+using document::DocumentTypeRepoFactory;
+
namespace storage {
Process::Process(const config::ConfigUri & configUri)
@@ -22,7 +25,7 @@ Process::setupConfig(uint64_t subscribeTimeout)
if (!_configSubscriber.nextConfig()) {
throw vespalib::TimeoutException("Could not subscribe to document config within timeout");
}
- _repos.push_back(std::make_shared<document::DocumentTypeRepo>(*_documentHandler->getConfig()));
+ _repos.push_back(DocumentTypeRepoFactory::make(*_documentHandler->getConfig()));
getContext().getComponentRegister().setDocumentTypeRepo(_repos.back());
}
@@ -41,7 +44,7 @@ void
Process::updateConfig()
{
if (_documentHandler->isChanged()) {
- _repos.push_back(std::make_shared<document::DocumentTypeRepo>(*_documentHandler->getConfig()));
+ _repos.push_back(DocumentTypeRepoFactory::make(*_documentHandler->getConfig()));
getNode().setNewDocumentRepo(_repos.back());
}
}