diff options
author | Tor Egge <Tor.Egge@oath.com> | 2018-04-04 14:05:50 +0000 |
---|---|---|
committer | Tor Egge <Tor.Egge@oath.com> | 2018-04-04 14:11:05 +0000 |
commit | 91a0164390282d89b5b295142e4f06ce27afdbc2 (patch) | |
tree | 5645cc655627e2c1d44170cbc8c20e5c30af320a /storageserver | |
parent | 02227976fd12c40beb2fcfd2361c52e02b9f06ab (diff) |
Start using DocumentTypeRepoFactory.
Diffstat (limited to 'storageserver')
-rw-r--r-- | storageserver/src/vespa/storageserver/app/process.cpp | 7 |
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()); } } |