Commit cd8bdea3 authored by antirez's avatar antirez
Browse files

lpush arguments vector rewrite modified for more speed and to memory leak removal.

parent b67feeca
...@@ -296,8 +296,8 @@ void pushGenericCommand(redisClient *c, int where) { ...@@ -296,8 +296,8 @@ void pushGenericCommand(redisClient *c, int where) {
* be propagated). */ * be propagated). */
if (waiting && pushed) { if (waiting && pushed) {
/* CMD KEY a b C D E */ /* CMD KEY a b C D E */
for (j = 2; j < pushed+2; j++) for (j = 0; j < waiting; j++) decrRefCount(c->argv[j+2]);
rewriteClientCommandArgument(c,j,c->argv[j+waiting]); memmove(c->argv+2,c->argv+2+waiting,sizeof(robj*)*pushed);
c->argc -= waiting; c->argc -= waiting;
} }
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment