Fix memory leak in streamGetEdgeID (#10753)

si is initialized by streamIteratorStart(), we should call streamIteratorStop() on it when done. regression introduced in #9127 (redis 7.0)
redis · May 22, 2022 · 4a7a4e4 · 4a7a4e4
1 parent 00a9d6b
commit 4a7a4e4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/t_stream.c b/src/t_stream.c
@@ -401,7 +401,7 @@ void streamGetEdgeID(stream *s, int first, int skip_tombstones, streamID *edge_i
         streamID min_id = {0, 0}, max_id = {UINT64_MAX, UINT64_MAX};
         *edge_id = first ? max_id : min_id;
     }
-
+    streamIteratorStop(&si);
 }
 
 /* Adds a new item into the stream 's' having the specified number of