This is an automated email from the ASF dual-hosted git repository.

hulk pushed a commit to branch unstable
in repository https://gitbox.apache.org/repos/asf/kvrocks.git


The following commit(s) were added to refs/heads/unstable by this push:
     new 8a50e51c5 fix(core): remove extraneous 
RocksDB::CancelAllBackgroundWork calls (#3017) (#3019)
8a50e51c5 is described below

commit 8a50e51c514ef6456ea45252c05b5491378eaa65
Author: Ryan Liao <[email protected]>
AuthorDate: Tue Jun 10 01:30:13 2025 -0400

    fix(core): remove extraneous RocksDB::CancelAllBackgroundWork calls (#3017) 
(#3019)
    
    Co-authored-by: hulk <[email protected]>
---
 src/server/server.cc   | 1 -
 src/storage/storage.cc | 2 +-
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/server/server.cc b/src/server/server.cc
index 0d62f98a2..8755f4f30 100644
--- a/src/server/server.cc
+++ b/src/server/server.cc
@@ -256,7 +256,6 @@ void Server::Stop() {
     worker->Stop(0 /* immediately terminate  */);
   }
 
-  rocksdb::CancelAllBackgroundWork(storage->GetDB(), true);
   task_runner_.Cancel();
 }
 
diff --git a/src/storage/storage.cc b/src/storage/storage.cc
index 8681eed87..70e7008da 100644
--- a/src/storage/storage.cc
+++ b/src/storage/storage.cc
@@ -102,8 +102,8 @@ void Storage::CloseDB() {
 
   db_closing_ = true;
   db_->SyncWAL();
-  rocksdb::CancelAllBackgroundWork(db_.get(), true);
   for (auto handle : cf_handles_) db_->DestroyColumnFamilyHandle(handle);
+  db_->Close();
   db_ = nullptr;
 }
 

Reply via email to