diff options
author | Tor Egge <Tor.Egge@online.no> | 2023-02-02 12:50:21 +0100 |
---|---|---|
committer | Tor Egge <Tor.Egge@online.no> | 2023-02-02 12:50:21 +0100 |
commit | 8d47e8da15675c97def3f0ffbfd9d35cb942be4a (patch) | |
tree | 915b1b8ca0050b582b1d19e059b0684794357346 /searchcore/src/tests/proton/documentdb | |
parent | 2754ecf502e84e1b4d9fe479d1f68ab1d6194882 (diff) |
Add proton::DocumentDB::prepare_reconfig
Diffstat (limited to 'searchcore/src/tests/proton/documentdb')
-rw-r--r-- | searchcore/src/tests/proton/documentdb/document_subdbs/document_subdbs_test.cpp | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/searchcore/src/tests/proton/documentdb/document_subdbs/document_subdbs_test.cpp b/searchcore/src/tests/proton/documentdb/document_subdbs/document_subdbs_test.cpp index b1fda6e0efb..307695c4f4b 100644 --- a/searchcore/src/tests/proton/documentdb/document_subdbs/document_subdbs_test.cpp +++ b/searchcore/src/tests/proton/documentdb/document_subdbs/document_subdbs_test.cpp @@ -19,6 +19,7 @@ #include <vespa/searchcore/proton/server/bootstrapconfig.h> #include <vespa/searchcore/proton/server/document_subdb_explorer.h> #include <vespa/searchcore/proton/server/document_subdb_initializer.h> +#include <vespa/searchcore/proton/server/document_subdb_reconfig.h> #include <vespa/searchcore/proton/server/emptysearchview.h> #include <vespa/searchcore/proton/server/fast_access_document_retriever.h> #include <vespa/searchcore/proton/server/i_document_subdb_owner.h> @@ -377,8 +378,11 @@ struct FixtureBase cmpResult.documenttypesChanged = true; cmpResult.documentTypeRepoChanged = true; MyDocumentDBReferenceResolver resolver; + ReconfigParams reconfig_params(cmpResult); + auto prepared_reconfig = _subDb.prepare_reconfig(*newCfg->_cfg, *_snapshot->_cfg, reconfig_params); auto tasks = _subDb.applyConfig(*newCfg->_cfg, *_snapshot->_cfg, - serialNum, ReconfigParams(cmpResult), resolver); + serialNum, reconfig_params, resolver, *prepared_reconfig); + prepared_reconfig.reset(); _snapshot = std::move(newCfg); if (!tasks.empty()) { ReprocessingRunner runner; |