FIX: incorrect command name, flushall=>flushdb

apache · Aug 21, 2019 · 99fccfe · 99fccfe
1 parent 25b4546
commit 99fccfe
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/src/redis_cmd.cc b/src/redis_cmd.cc
@@ -118,12 +118,12 @@ class CommandKeys : public Commander {
   }
 };
 
-class CommandFlushAll : public Commander {
+class CommandFlushDB : public Commander {
  public:
-  CommandFlushAll() : Commander("flushall", 1, false) {}
+  CommandFlushDB() : Commander("flushdb", 1, false) {}
   Status Execute(Server *svr, Connection *conn, std::string *output) override {
     Redis::Database redis(svr->storage_, conn->GetNamespace());
-    rocksdb::Status s = redis.FlushAll();
+    rocksdb::Status s = redis.FlushDB();
     LOG(WARNING) << "DB keys in namespce: " << conn->GetNamespace()
               << " was flused, addr: " << conn->GetAddr();
     if (s.ok()) {
@@ -3229,9 +3229,9 @@ std::map<std::string, CommanderFactory> command_table = {
      []() -> std::unique_ptr<Commander> {
        return std::unique_ptr<Commander>(new CommandKeys);
      }},
-    {"flushall",
+    {"flushdb",
      []() -> std::unique_ptr<Commander> {
-       return std::unique_ptr<Commander>(new CommandFlushAll);
+       return std::unique_ptr<Commander>(new CommandFlushDB);
      }},
     {"dbsize",
      []() -> std::unique_ptr<Commander> {

diff --git a/src/redis_db.cc b/src/redis_db.cc
@@ -237,7 +237,7 @@ rocksdb::Status Database::RandomKey(const std::string &cursor, std::string *key)
   return rocksdb::Status::OK();
 }
 
-rocksdb::Status Database::FlushAll() {
+rocksdb::Status Database::FlushDB() {
   std::string prefix;
   AppendNamespacePrefix("", &prefix);
   LatestSnapShot ss(db_);

diff --git a/src/redis_db.h b/src/redis_db.h
@@ -19,7 +19,7 @@ class Database {
   rocksdb::Status TTL(const Slice &user_key, int *ttl);
   rocksdb::Status Type(const Slice &user_key, RedisType *type);
   rocksdb::Status Dump(const Slice &user_key, std::vector<std::string> *infos);
-  rocksdb::Status FlushAll();
+  rocksdb::Status FlushDB();
   void GetKeyNumStats(const std::string &prefix, KeyNumStats *stats);
   void Keys(std::string prefix, std::vector<std::string> *keys = nullptr, KeyNumStats *stats = nullptr);
   rocksdb::Status Scan(const std::string &cursor,