blob: e56877bdded58b5d348371e4a8e8df4d79a5e5a8 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#pragma once
#include "attribute_spec.h"
#include "attribute_initializer_result.h"
#include <vespa/vespalib/stllike/string.h>
#include <vespa/searchlib/common/serialnum.h>
#include <optional>
namespace search::attribute { class AttributeHeader; }
namespace vespalib { class Executor; }
namespace proton {
class AttributeDirectory;
struct IAttributeFactory;
/**
* Class used by an attribute manager to initialize and load attribute vectors from disk.
*/
class AttributeInitializer
{
public:
using UP = std::unique_ptr<AttributeInitializer>;
private:
using AttributeVectorSP = std::shared_ptr<search::AttributeVector>;
std::shared_ptr<AttributeDirectory> _attrDir;
const vespalib::string _documentSubDbName;
const AttributeSpec _spec;
const std::optional<uint64_t> _currentSerialNum;
const IAttributeFactory &_factory;
vespalib::Executor &_shared_executor;
std::unique_ptr<const search::attribute::AttributeHeader> _header;
bool _header_ok;
void readHeader();
AttributeVectorSP tryLoadAttribute() const;
bool loadAttribute(const AttributeVectorSP &attr, search::SerialNum serialNum) const;
void setupEmptyAttribute(AttributeVectorSP &attr, search::SerialNum serialNum,
const search::attribute::AttributeHeader &header) const;
AttributeVectorSP createAndSetupEmptyAttribute() const;
public:
AttributeInitializer(const std::shared_ptr<AttributeDirectory> &attrDir, const vespalib::string &documentSubDbName,
AttributeSpec && spec, std::optional<uint64_t> currentSerialNum, const IAttributeFactory &factory,
vespalib::Executor& shared_executor);
~AttributeInitializer();
AttributeInitializerResult init() const;
const std::optional<uint64_t>& getCurrentSerialNum() const noexcept { return _currentSerialNum; }
size_t get_transient_memory_usage() const;
};
} // namespace proton
|
