blob: b7650f00ecd5785b08c635b02a58b830f09aa848 [file] [log] [blame]
Kun Yi68c81142018-12-18 11:17:14 -08001#pragma once
2
Patrick Venture15f0f942020-07-09 09:38:18 -07003#include "binarystore_interface.hpp"
Kun Yi2765b642019-01-16 11:11:24 -08004#include "sys_file.hpp"
5
Kun Yi64dc05c2018-12-19 13:19:03 -08006#include <unistd.h>
7
Kun Yi1a25e0d2020-05-11 12:28:53 -07008#include <blobs-ipmid/blobs.hpp>
Kun Yi68c81142018-12-18 11:17:14 -08009#include <cstdint>
William A. Kennington III7e145862024-02-01 15:56:33 -080010#include <map>
Kun Yi64dc05c2018-12-19 13:19:03 -080011#include <memory>
Willy Tu67391d52021-12-07 19:53:49 -080012#include <optional>
Kun Yi68c81142018-12-18 11:17:14 -080013#include <string>
14#include <vector>
15
16using std::size_t;
17using std::uint16_t;
18using std::uint32_t;
19using std::uint64_t;
20using std::uint8_t;
21
22namespace binstore
23{
24
25/**
Kun Yi64dc05c2018-12-19 13:19:03 -080026 * @class BinaryStore instantiates a concrete implementation of
27 * BinaryStoreInterface. The dependency on file is injected through its
28 * constructor.
29 */
30class BinaryStore : public BinaryStoreInterface
31{
32 public:
Kun Yi1a25e0d2020-05-11 12:28:53 -070033 /* |CommitState| differs slightly with |StateFlags| in blob.hpp,
34 * and thus is defined in the OEM space (bit 8 - 15). User can call stat()
35 * to query the |CommitState| of the blob path. */
36 enum CommitState
37 {
38 Dirty = (1 << 8), // In-memory data might not match persisted data
39 Clean = (1 << 9), // In-memory data matches persisted data
40 Uninitialized = (1 << 10), // Cannot find persisted data
41 CommitError = (1 << 11) // Error happened during committing
42 };
43
Kun Yi2765b642019-01-16 11:11:24 -080044 BinaryStore() = delete;
Willy Tu67391d52021-12-07 19:53:49 -080045 BinaryStore(const std::string& baseBlobId, std::unique_ptr<SysFile> file,
46 std::optional<uint32_t> maxSize = std::nullopt) :
47 baseBlobId_(baseBlobId),
48 file_(std::move(file)), maxSize(maxSize)
Kun Yi64dc05c2018-12-19 13:19:03 -080049 {
50 }
51
Willy Tu67391d52021-12-07 19:53:49 -080052 BinaryStore(std::unique_ptr<SysFile> file, bool readOnly = false,
53 std::optional<uint32_t> maxSize = std::nullopt) :
54 readOnly_{readOnly},
55 file_(std::move(file)), maxSize(maxSize)
Maksym Sloykoeb274112021-10-27 23:48:32 +000056 {
57 }
58
Kun Yi64dc05c2018-12-19 13:19:03 -080059 ~BinaryStore() = default;
Kun Yi2765b642019-01-16 11:11:24 -080060
Kun Yi64dc05c2018-12-19 13:19:03 -080061 BinaryStore(const BinaryStore&) = delete;
62 BinaryStore& operator=(const BinaryStore&) = delete;
63 BinaryStore(BinaryStore&&) = default;
64 BinaryStore& operator=(BinaryStore&&) = default;
65
66 std::string getBaseBlobId() const override;
Willy Tu7f107802023-11-06 23:05:25 -080067 bool setBaseBlobId(const std::string& baseBlobId) override;
Kun Yi64dc05c2018-12-19 13:19:03 -080068 std::vector<std::string> getBlobIds() const override;
69 bool openOrCreateBlob(const std::string& blobId, uint16_t flags) override;
70 bool deleteBlob(const std::string& blobId) override;
71 std::vector<uint8_t> read(uint32_t offset, uint32_t requestedSize) override;
Maksym Sloykoeb274112021-10-27 23:48:32 +000072 std::vector<uint8_t> readBlob(const std::string& blobId) const override;
Kun Yi64dc05c2018-12-19 13:19:03 -080073 bool write(uint32_t offset, const std::vector<uint8_t>& data) override;
74 bool commit() override;
75 bool close() override;
Kun Yi1a25e0d2020-05-11 12:28:53 -070076 bool stat(blobs::BlobMeta* meta) override;
Kun Yi64dc05c2018-12-19 13:19:03 -080077
78 /**
79 * Helper factory method to create a BinaryStore instance
80 * @param baseBlobId: base id for the created instance
Kun Yi2765b642019-01-16 11:11:24 -080081 * @param sysFile: system file object for storing binary
Kun Yi64dc05c2018-12-19 13:19:03 -080082 * @returns unique_ptr to constructed BinaryStore. Caller should take
83 * ownership of the instance.
84 */
Willy Tu7f107802023-11-06 23:05:25 -080085 static std::unique_ptr<BinaryStoreInterface> createFromConfig(
86 const std::string& baseBlobId, std::unique_ptr<SysFile> file,
87 std::optional<uint32_t> maxSize = std::nullopt,
88 std::optional<std::string> aliasBlobBaseId = std::nullopt);
Kun Yi64dc05c2018-12-19 13:19:03 -080089
Maksym Sloykoeb274112021-10-27 23:48:32 +000090 /**
91 * Helper factory method to create a BinaryStore instance
92 * This function should be used with existing stores. It reads
93 * the baseBlobId name from the storage.
94 * @param sysFile: system file object for storing binary
95 * @param readOnly: if true, open the store in read only mode
96 * @returns unique_ptr to constructed BinaryStore.
97 */
98 static std::unique_ptr<BinaryStoreInterface>
Willy Tu67391d52021-12-07 19:53:49 -080099 createFromFile(std::unique_ptr<SysFile> file, bool readOnly = true,
100 std::optional<uint32_t> maxSize = std::nullopt);
Maksym Sloykoeb274112021-10-27 23:48:32 +0000101
Kun Yi64dc05c2018-12-19 13:19:03 -0800102 private:
Kun Yi97be3af2019-03-05 22:43:41 -0800103 /* Load the serialized data from sysfile if commit state is dirty.
104 * Returns False if encountered error when loading */
Willy Tu7f107802023-11-06 23:05:25 -0800105 bool loadSerializedData(
106 std::optional<std::string> aliasBlobBaseId = std::nullopt);
Kun Yi97be3af2019-03-05 22:43:41 -0800107
William A. Kennington III7e145862024-02-01 15:56:33 -0800108 std::map<std::string, std::vector<std::uint8_t>> blobs_;
109 std::string baseBlobId_, currentBlob_;
Maksym Sloykoeb274112021-10-27 23:48:32 +0000110 /* True if current blob is writable */
Kun Yi6baa7132019-01-08 21:21:02 -0800111 bool writable_ = false;
Maksym Sloykoeb274112021-10-27 23:48:32 +0000112 /* True if the entire store (not just individual blobs) is read only */
113 bool readOnly_ = false;
Kun Yi2765b642019-01-16 11:11:24 -0800114 std::unique_ptr<SysFile> file_ = nullptr;
Kun Yid297c9f2019-01-09 13:52:30 -0800115 CommitState commitState_ = CommitState::Dirty;
Willy Tu67391d52021-12-07 19:53:49 -0800116 std::optional<uint32_t> maxSize;
Kun Yi64dc05c2018-12-19 13:19:03 -0800117};
118
Kun Yi68c81142018-12-18 11:17:14 -0800119} // namespace binstore