Memory leak fixes

2 files changed, 5 insertions, 3 deletions

diff --git a/redis_array.c b/redis_array.c
index 5dddfd14..e6ac1fab 100644
--- a/redis_array.c
+++ b/redis_array.c
@@ -1026,12 +1026,14 @@ PHP_METHOD(RedisArray, mset)
     }
 
 
+    /* Set up our function call */
+    ZVAL_STRING(&z_fun, "MSET");
+
     /* calls */
     for(n = 0; n < ra->count; ++n) { /* for each node */
         int found = 0;
 
         /* prepare call */
-        ZVAL_STRING(&z_fun, "MSET");
         redis_inst = &ra->redis[n];
 
         /* copy args */
@@ -1067,7 +1069,6 @@ PHP_METHOD(RedisArray, mset)
         }
 
         zval_dtor(&z_ret);
-
         zval_ptr_dtor(&z_argarray);
     }
 
@@ -1077,6 +1078,7 @@ PHP_METHOD(RedisArray, mset)
     }
 
     /* cleanup */
+    zval_dtor(&z_fun);
     efree(keys);
     efree(key_free);
     efree(key_lens);
diff --git a/redis_commands.c b/redis_commands.c
index cdc8b705..eb006b43 100644
--- a/redis_commands.c
+++ b/redis_commands.c
@@ -998,7 +998,7 @@ int redis_key_varval_cmd(INTERNAL_FUNCTION_PARAMETERS, RedisSock *redis_sock,
     for(i=1;i<argc;i++) {
         arg_free = redis_serialize(redis_sock, &z_args[i], &arg, &arg_len TSRMLS_CC);
         redis_cmd_append_sstr(&cmdstr, arg, arg_len);
-        //if(arg_free) efree(arg);
+        if (arg_free) efree(arg);
     }
 
     // Push out values