fix: fix a memory leak with autopipelining. (#1470)

redis · Nov 24, 2021 · f5d8b73 · f5d8b73
1 parent e5615da
commit f5d8b73
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/autoPipelining.ts b/lib/autoPipelining.ts
@@ -45,6 +45,10 @@ function executeAutoPipeline(client, slotKey: string) {
   client._autoPipelines.delete(slotKey);
 
   const callbacks = pipeline[kCallbacks];
+  // Stop keeping a reference to callbacks immediately after the callbacks stop being used.
+  // This allows the GC to reclaim objects referenced by callbacks, especially with 16384 slots
+  // in Redis.Cluster
+  pipeline[kCallbacks] = null;
 
   // Perform the call
   pipeline.exec(function (err, results) {