diff --git a/include/store.h b/include/store.h index e01e4090..63f8a392 100644 --- a/include/store.h +++ b/include/store.h @@ -334,6 +334,7 @@ public: } rocksdb::Status delete_range(const std::string& begin_key, const std::string& end_key) { + std::shared_lock lock(mutex); return db->DeleteRange(rocksdb::WriteOptions(), db->DefaultColumnFamily(), begin_key, end_key); }