Merge branch 'issue-1498' of github.com:Brokenice0415/pika into issue…

…-1498
OpenAtomFoundation · May 19, 2023 · b66739e · b66739e
2 parents 46529e7 + 7867031
commit b66739e
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 0 deletions.
diff --git a/src/storage/src/redis_hashes.cc b/src/storage/src/redis_hashes.cc
@@ -24,6 +24,7 @@ Status RedisHashes::Open(const StorageOptions& storage_options, const std::strin
  small_compaction_threshold_ = storage_options.small_compaction_threshold;
 
  rocksdb::Options ops(storage_options.options);
+ ops.wal_dir = db_path + "/hashes";
  Status s = rocksdb::DB::Open(ops, db_path, &db_);
  if (s.ok()) {
  // create column family

diff --git a/src/storage/src/redis_lists.cc b/src/storage/src/redis_lists.cc
@@ -28,6 +28,7 @@ Status RedisLists::Open(const StorageOptions& storage_options, const std::string
  small_compaction_threshold_ = storage_options.small_compaction_threshold;
 
  rocksdb::Options ops(storage_options.options);
+ ops.wal_dir = db_path + "/lists";
  Status s = rocksdb::DB::Open(ops, db_path, &db_);
  if (s.ok()) {
  // Create column family

diff --git a/src/storage/src/redis_sets.cc b/src/storage/src/redis_sets.cc
@@ -37,6 +37,7 @@ rocksdb::Status RedisSets::Open(const StorageOptions& storage_options, const std
  small_compaction_threshold_ = storage_options.small_compaction_threshold;
 
  rocksdb::Options ops(storage_options.options);
+ ops.wal_dir = db_path + "/sets";
  rocksdb::Status s = rocksdb::DB::Open(ops, db_path, &db_);
  if (s.ok()) {
  // create column family

diff --git a/src/storage/src/redis_strings.cc b/src/storage/src/redis_strings.cc
@@ -25,6 +25,7 @@ RedisStrings::RedisStrings(Storage* const s, const DataType& type) : Redis(s, ty
 Status RedisStrings::Open(const StorageOptions& storage_options, const std::string& db_path) {
  rocksdb::Options ops(storage_options.options);
  ops.compaction_filter_factory = std::make_shared<StringsFilterFactory>();
+ ops.wal_dir = db_path + "/strings";
 
  // use the bloom filter policy to reduce disk reads
  rocksdb::BlockBasedTableOptions table_ops(storage_options.table_options);

diff --git a/src/storage/src/redis_zsets.cc b/src/storage/src/redis_zsets.cc
@@ -33,6 +33,7 @@ Status RedisZSets::Open(const StorageOptions& storage_options, const std::string
  small_compaction_threshold_ = storage_options.small_compaction_threshold;
 
  rocksdb::Options ops(storage_options.options);
+ ops.wal_dir = db_path + "/zsets";
  Status s = rocksdb::DB::Open(ops, db_path, &db_);
  if (s.ok()) {
  rocksdb::ColumnFamilyHandle *dcf = nullptr, *scf = nullptr;