Take into account lazyfree_lazy_user_flush

moticless · Sep 26, 2024 · 8a00798 · 8a00798
1 parent e0b1b07
commit 8a00798
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/cluster.c b/src/cluster.c
@@ -1581,7 +1581,7 @@ void replySlotsFlushAndFree(client *c, SlotsFlush *sflush) {
  * optimization.
  */
 void sflushCommand(client *c) {
-    int flags = EMPTYDB_NO_FLAGS, argc = c->argc;
+    int flags, argc = c->argc;
 
     if (server.cluster_enabled == 0) {
         addReplyError(c,"This instance has cluster support disabled");
@@ -1590,10 +1590,13 @@ void sflushCommand(client *c) {
 
     /* check if last argument is SYNC or ASYNC */
     if (!strcasecmp(c->argv[c->argc-1]->ptr,"sync")) {
+        flags = EMPTYDB_NO_FLAGS;
         argc--;
     } else if (!strcasecmp(c->argv[c->argc-1]->ptr,"async")) {
-        flags |= EMPTYDB_ASYNC;
+        flags = EMPTYDB_ASYNC;
         argc--;
+    } else if (server.lazyfree_lazy_user_flush) {
+        flags = EMPTYDB_ASYNC;
     }
 
     /* parse the slot range */