add flushall cache clear

OpenAtomFoundation · Mar 29, 2024 · be9da25 · be9da25
1 parent ac8e1dc
commit be9da25
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/include/pika_admin.h b/include/pika_admin.h
@@ -185,7 +185,7 @@ class FlushallCmd : public Cmd {
       : Cmd(name, arity, flag, static_cast<uint32_t>(AclCategory::KEYSPACE)) {}
   void Do() override;
   void DoThroughDB() override;
-  void DoUpdateCache() override;
+  void DoUpdateCache(std::shared_ptr<DB> db);
   void Split(const HintKeys& hint_keys) override{};
   void Merge() override{};
   Cmd* Clone() override { return new FlushallCmd(*this); }

diff --git a/src/pika_admin.cc b/src/pika_admin.cc
@@ -553,10 +553,10 @@ void FlushallCmd::DoThroughDB() {
   Do();
 }
 
-void FlushallCmd::DoUpdateCache() {
+void FlushallCmd::DoUpdateCache(std::shared_ptr<DB> db) {
   // clear cache
   if (PIKA_CACHE_NONE != g_pika_conf->cache_model()) {
-    g_pika_server->ClearCacheDbAsync(db_);
+    g_pika_server->ClearCacheDbAsync(db);
   }
 }
 
@@ -580,6 +580,7 @@ void FlushallCmd::DoWithoutLock(std::shared_ptr<DB> db) {
     LOG(INFO) << "Flushall, but DB not found";
   } else {
     db->FlushDBWithoutLock();
+    DoUpdateCache(db);
   }
 }