Fix rDiscardShardsAsync()

Smithsonian · Jan 5, 2025 · 8d00cd0 · 8d00cd0
1 parent 9ec682d
commit 8d00cd0
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/src/redisx-cluster.c b/src/redisx-cluster.c
@@ -115,7 +115,6 @@ static void rDiscardShardsAsync(RedisShard *shards, int n_shards) {
 
   if(!shards) return;
 
-
   for(i = 0; i < n_shards; i++) {
     RedisShard *s = &shards[i];
     int m;
@@ -125,8 +124,11 @@ static void rDiscardShardsAsync(RedisShard *shards, int n_shards) {
       redisxDisconnect(r);
       redisxDestroy(r);
     }
-    free(shards);
+
+    if(s->redis) free(s->redis);
   }
+
+  free(shards);
 }
 
 /**
@@ -195,10 +197,10 @@ static RedisShard *rClusterDiscoverAsync(Redis *redis, int *n_shards) {
         rCopyConfig(&((RedisPrivate *) redis->priv)->config, s->redis[m]);
       }
     }
-
-    redisxDestroyRESP(reply);
   }
 
+  redisxDestroyRESP(reply);
+
   if(!isConnected) redisxDisconnect(redis);
 
   if(*n_shards < 0) x_trace(fn, NULL, *n_shards);