aboutsummaryrefslogtreecommitdiff
path: root/zenserver/projectstore.cpp
diff options
context:
space:
mode:
authorStefan Boberg <[email protected]>2021-05-25 09:28:21 +0200
committerStefan Boberg <[email protected]>2021-05-25 09:28:21 +0200
commit317b7654133b59d20554162da4a251bdf7794cb1 (patch)
tree2bd6b5f0dcd37721fb02351fa072ffcfdd9ae522 /zenserver/projectstore.cpp
parentImplemented simple persistence for CidStore, which stores CID->CAS mappings (diff)
downloadzen-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.cpp22
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
};
//////////////////////////////////////////////////////////////////////////