diff options
| author | Tor Egge <Tor.Egge@online.no> | 2021-11-04 11:23:03 +0100 |
|---|---|---|
| committer | Tor Egge <Tor.Egge@online.no> | 2021-11-04 11:23:03 +0100 |
| commit | 427f0b454a2c78d8d3f28793d341e64a22a5c837 (patch) | |
| tree | 7443036cec1d524b77d4463d2df5ecef8691129f /searchlib | |
| parent | cfae4db339dd571be22e89db55fe0ea4126eebee (diff) | |
Add max number of document inverters as a constructor argument to document
inverter collection.
Diffstat (limited to 'searchlib')
3 files changed, 4 insertions, 4 deletions
diff --git a/searchlib/src/vespa/searchlib/memoryindex/document_inverter_collection.cpp b/searchlib/src/vespa/searchlib/memoryindex/document_inverter_collection.cpp index b316b4cc360..d9b27735489 100644 --- a/searchlib/src/vespa/searchlib/memoryindex/document_inverter_collection.cpp +++ b/searchlib/src/vespa/searchlib/memoryindex/document_inverter_collection.cpp @@ -6,13 +6,13 @@ namespace search::memoryindex { -DocumentInverterCollection::DocumentInverterCollection(DocumentInverterContext& context) +DocumentInverterCollection::DocumentInverterCollection(DocumentInverterContext& context, uint32_t max_inverters) : _context(context), _free_inverters(), _inflight_inverters(), _active_inverter(std::make_unique<DocumentInverter>(_context)), _num_inverters(1), - _max_inverters(4) + _max_inverters(max_inverters) { } diff --git a/searchlib/src/vespa/searchlib/memoryindex/document_inverter_collection.h b/searchlib/src/vespa/searchlib/memoryindex/document_inverter_collection.h index ae766381cf2..deecebc164d 100644 --- a/searchlib/src/vespa/searchlib/memoryindex/document_inverter_collection.h +++ b/searchlib/src/vespa/searchlib/memoryindex/document_inverter_collection.h @@ -22,7 +22,7 @@ class DocumentInverterCollection { uint32_t _num_inverters; uint32_t _max_inverters; public: - DocumentInverterCollection(DocumentInverterContext& context); + DocumentInverterCollection(DocumentInverterContext& context, uint32_t max_inverters); ~DocumentInverterCollection(); DocumentInverter& get_active_inverter() noexcept { return *_active_inverter; } void switch_active_inverter(); diff --git a/searchlib/src/vespa/searchlib/memoryindex/memory_index.cpp b/searchlib/src/vespa/searchlib/memoryindex/memory_index.cpp index 25b36a3e245..15cdef2f664 100644 --- a/searchlib/src/vespa/searchlib/memoryindex/memory_index.cpp +++ b/searchlib/src/vespa/searchlib/memoryindex/memory_index.cpp @@ -60,7 +60,7 @@ MemoryIndex::MemoryIndex(const Schema& schema, _pushThreads(pushThreads), _fieldIndexes(std::make_unique<FieldIndexCollection>(_schema, inspector)), _inverter_context(std::make_unique<DocumentInverterContext>(_schema, _invertThreads, _pushThreads, *_fieldIndexes)), - _inverters(std::make_unique<DocumentInverterCollection>(*_inverter_context)), + _inverters(std::make_unique<DocumentInverterCollection>(*_inverter_context, 4)), _frozen(false), _maxDocId(0), // docId 0 is reserved _numDocs(0), |