diff options
| author | Stefan Boberg <[email protected]> | 2021-05-25 09:28:21 +0200 |
|---|---|---|
| committer | Stefan Boberg <[email protected]> | 2021-05-25 09:28:21 +0200 |
| commit | 317b7654133b59d20554162da4a251bdf7794cb1 (patch) | |
| tree | 2bd6b5f0dcd37721fb02351fa072ffcfdd9ae522 /zenserver/projectstore.cpp | |
| parent | Implemented simple persistence for CidStore, which stores CID->CAS mappings (diff) | |
| download | zen-317b7654133b59d20554162da4a251bdf7794cb1.tar.xz zen-317b7654133b59d20554162da4a251bdf7794cb1.zip | |
Compile out all rocksdb code for a smaller binary
Diffstat (limited to 'zenserver/projectstore.cpp')
| -rw-r--r-- | zenserver/projectstore.cpp | 22 |
1 files changed, 16 insertions, 6 deletions
diff --git a/zenserver/projectstore.cpp b/zenserver/projectstore.cpp index f99bfdcac..c94a8fe35 100644 --- a/zenserver/projectstore.cpp +++ b/zenserver/projectstore.cpp @@ -15,10 +15,13 @@ #include <zenstore/cas.h> #include <zenstore/caslog.h> -#pragma comment(lib, "Rpcrt4.lib") // RocksDB made me do this -#include <rocksdb/db.h> +#define USE_ROCKSDB 0 + +#if USE_ROCKSDB +# pragma comment(lib, "Rpcrt4.lib") // RocksDB made me do this +# include <rocksdb/db.h> +#endif -#include <lmdb.h> #include <ppl.h> #include <spdlog/spdlog.h> #include <xxh3.h> @@ -28,10 +31,11 @@ namespace zen { -namespace rocksdb = ROCKSDB_NAMESPACE; using namespace fmt::literals; -bool UseRocksDb = false; +#if USE_ROCKSDB +namespace rocksdb = ROCKSDB_NAMESPACE; +#endif ////////////////////////////////////////////////////////////////////////// @@ -46,6 +50,7 @@ struct ProjectStore::OplogStorage : public RefCounted Log().info("closing oplog storage at {}", m_OplogStoragePath); Flush(); +#if USE_ROCKSDB if (m_RocksDb) { // Column families must be torn down before database is closed @@ -61,6 +66,7 @@ struct ProjectStore::OplogStorage : public RefCounted Log().warn("db close error reported for '{}' : '{}'", m_OplogStoragePath, Status.getState()); } } +#endif } [[nodiscard]] bool Exists() { return Exists(m_OplogStoragePath); } @@ -90,7 +96,7 @@ struct ProjectStore::OplogStorage : public RefCounted ZEN_ASSERT(IsPow2(m_OpsAlign)); ZEN_ASSERT(!(m_NextOpsOffset & (m_OpsAlign - 1))); - if (UseRocksDb) +#if USE_ROCKSDB { std::string RocksdbPath = WideToUtf8((m_OplogStoragePath / "ops.rdb").native().c_str()); @@ -132,6 +138,7 @@ struct ProjectStore::OplogStorage : public RefCounted m_RocksDb.reset(Db); } +#endif } void ReplayLog(std::function<void(CbObject, const OplogEntry&)>&& Handler) @@ -221,8 +228,11 @@ private: std::atomic<uint64_t> m_NextOpsOffset{0}; uint64_t m_OpsAlign = 32; std::atomic<uint32_t> m_MaxLsn{0}; + +#if USE_ROCKSDB std::unique_ptr<rocksdb::DB> m_RocksDb; std::vector<rocksdb::ColumnFamilyHandle*> m_RocksDbColumnHandles; +#endif }; ////////////////////////////////////////////////////////////////////////// |