Configure rocksdb: Optimizing rocksdb is now controlled through configure.hpp (8b84ffda) · Commits · hpc / gekkofs

ifs/configure.hpp

+3 −1

Original line number	Diff line number	Diff line
		@@ -38,7 +38,9 @@
		#define DO_LOOKUP

		// Write-ahead logging of rocksdb
		//#define RDB_WOL
		//#define KV_WOL
		// Optimize key value store. Eventually, different modes will be available for different workloads. TODO
		//#define KV_OPTIMIZE

		// RPC configuration
		#define RPCPORT 4433

ifs/src/db/db_util.cpp

+10 −66

Original line number	Diff line number	Diff line
		@@ -13,8 +13,16 @@ bool init_rocksdb() {
		// create the DB if it's not already present
		options.create_if_missing = true;


		#if defined(KV_OPTIMIZE)
		optimize_rocksdb(options);
		#endif

		// Disable Write-Ahead Logging if configured
		rocksdb::WriteOptions write_options{};
		#if !defined(KV_WOL)
		write_options.disableWAL = true;
		#endif
		ADAFS_DATA->rdb_write_options(write_options);

		ADAFS_DATA->rdb_options(options);
		// rocksdb::OptimisticTransactionDB* txn_db;
		@@ -62,69 +70,5 @@ void optimize_rocksdb(rocksdb::Options& options) {
		// options.arena_block_size = 1024 * 8;
		// options.compression = rocksdb::kNoCompression; // doesnt do anything

		// Disable Write-Ahead Logging if configured
		rocksdb::WriteOptions write_options{};
		#ifndef RDB_WOL
		write_options.disableWAL = true;
		#endif
		ADAFS_DATA->rdb_write_options(write_options);
		}




		///**
		// * Build dentry key of form <d_ParentInode_filename>
		// * @param inode
		// * @param name
		// * @return
		// */
		//string db_build_dentry_key(const fuse_ino_t inode, const string& name) {
		// return ("d_"s + fmt::FormatInt(inode).str() + "_" + name);
		//}
		//
		///**
		// * Build dentry prefix of form <d_ParentInode>
		// * @param inode
		// * @param name
		// * @return
		// */
		//string db_build_dentry_prefix(const fuse_ino_t inode) {
		// return ("d_"s + fmt::FormatInt(inode).str() + "_"s);
		//}
		//
		//string db_build_dentry_value(const fuse_ino_t inode, const mode_t mode) {
		// return (fmt::FormatInt(inode).str() + "_"s + fmt::FormatInt(mode).str());
		//}
		//
		///**
		// * Build mdata key of form <inode_fieldname>
		// * @param inode
		// * @param name
		// * @return
		// */
		//string db_build_mdata_key(const fuse_ino_t inode, const string& field) {
		// return (fmt::FormatInt(inode).str() + field);
		//}
		//
		//string db_build_mdata_key(const string& inode, const string& field) {
		// return (inode + field);
		//}
		//
		//vector<string> db_build_all_mdata_keys(const fuse_ino_t inode) {
		// auto inode_key = fmt::FormatInt(inode).str();
		// vector<string> mdata_keys{};
		// mdata_keys.push_back(inode_key + std::get<to_underlying(Md_fields::atime)>(md_field_map));
		// mdata_keys.push_back(inode_key + std::get<to_underlying(Md_fields::mtime)>(md_field_map));
		// mdata_keys.push_back(inode_key + std::get<to_underlying(Md_fields::ctime)>(md_field_map));
		// mdata_keys.push_back(inode_key + std::get<to_underlying(Md_fields::uid)>(md_field_map));
		// mdata_keys.push_back(inode_key + std::get<to_underlying(Md_fields::gid)>(md_field_map));
		// mdata_keys.push_back(inode_key + std::get<to_underlying(Md_fields::mode)>(md_field_map));
		// mdata_keys.push_back(inode_key + std::get<to_underlying(Md_fields::inode_no)>(md_field_map));
		// mdata_keys.push_back(inode_key + std::get<to_underlying(Md_fields::link_count)>(md_field_map));
		// mdata_keys.push_back(inode_key + std::get<to_underlying(Md_fields::size)>(md_field_map));
		// mdata_keys.push_back(inode_key + std::get<to_underlying(Md_fields::blocks)>(md_field_map));
		// return mdata_keys;
		//}


		}
		No newline at end of file