PR fixes

src/bio.c

@@ -79,9 +79,9 @@ static pthread_mutex_t bio_mutex_comp;
 static int job_comp_pipe[2];   /* Pipe used to awake the event loop */
 
 typedef struct bio_comp_item {
-    comp_fn  *func;    /* callback after completion job will be processed  */
-    uint64_t arg;      /* user data to be passed to the function */
-    void     *ptr;     /* user pointer to be passed to the function */
+    comp_fn *func;    /* callback after completion job will be processed  */
+    uint64_t arg;     /* user data to be passed to the function */
+    void *ptr;        /* user pointer to be passed to the function */
 } bio_comp_item;
 
 /* This structure represents a background Job. It is only used locally to this

src/cluster.c

@@ -1576,8 +1576,9 @@ void replySlotsFlushAndFree(client *c, SlotsFlush *sflush) {
  * flushing a single shard as a whole, but in the future the same command may be
  * used to partially flush a shard based on hash slots. Currently only if provided
  * slots cover entirely the slots of a node, the node will be flushed and the
- * return value will be pairs of slot ranges and the node. Otherwise, a single empty
- * set will be returned. If possible, SFLUSH SYNC will be run as blocking ASYNC.
+ * return value will be pairs of slot ranges. Otherwise, a single empty set will 
+ * be returned. If possible, SFLUSH SYNC will be run as blocking ASYNC as an 
+ * optimization.
  */
 void sflushCommand(client *c) {
     int flags = EMPTYDB_NO_FLAGS, argc = c->argc;

src/commands/sflush.json

@@ -16,7 +16,25 @@
         "command_tips": [
         ],
         "reply_schema": {
-            "const": "OK"
+            "description": "List of slot ranges",
+            "type": "array",
+            "minItems": 0,
+            "maxItems": 4294967295,
+            "items": {
+                "type": "array",
+                "minItems": 2,
+                "maxItems": 2,
+                "items": [
+                    {
+                        "description": "start slot number",
+                        "type": "integer"
+                    },
+                    {
+                        "description": "end slot number",
+                        "type": "integer"
+                    }
+                ]
+            }
         },
         "arguments": [
             {

src/db.c

@@ -732,7 +732,7 @@ void flushAllDataAndResetRDB(int flags) {
  * Utilized by commands SFLUSH, FLUSHALL and FLUSHDB.
  */
 void flushallSyncBgDone(uint64_t client_id, void *sflush) {
-    SlotsFlush *slotsFlush = (SlotsFlush *)sflush;
+    SlotsFlush *slotsFlush = sflush;
     client *c = lookupClientByID(client_id);
 
     /* Verify that client still exists */