MOD: add detect delete error

apache · Aug 22, 2019 · 074e968 · 074e968
1 parent 4a563d5
commit 074e968
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/redis_db.cc b/src/redis_db.cc
@@ -248,7 +248,11 @@ rocksdb::Status Database::FlushDB() {
   for (iter->Seek(prefix);
        iter->Valid() && iter->key().starts_with(prefix);
        iter->Next()) {
-    db_->Delete(rocksdb::WriteOptions(), metadata_cf_handle_, iter->key());
+    auto s = db_->Delete(rocksdb::WriteOptions(), metadata_cf_handle_, iter->key());
+    if (!s.ok()) {
+      delete iter;
+      return s;
+    }
   }
   delete iter;
   return rocksdb::Status::OK();