Redis test: More reliable BRPOPLPUSH replication test.

[redis.git] / src / redis-benchmark.c

diff --git a/src/redis-benchmark.c b/src/redis-benchmark.c
index fc633211985e2e596a26293d06370856e7b65bb1..19eb49152c749a00774dda1a3a4d9d5681024865 100644 (file)
--- a/src/redis-benchmark.c
+++ b/src/redis-benchmark.c
@@ -78,7 +78,7 @@ static struct config {
 typedef struct _client {
     redisContext *context;
     sds obuf;
 typedef struct _client {
     redisContext *context;
     sds obuf;

-    char *randptr[10]; /* needed for MSET against 10 keys */
+    char *randptr[32]; /* needed for MSET against 10 keys */

     size_t randlen;
     unsigned int written; /* bytes of 'obuf' already written */
     long long start; /* start time of a request */
     size_t randlen;
     unsigned int written; /* bytes of 'obuf' already written */
     long long start; /* start time of a request */


@@ -196,6 +196,8 @@ static void readHandler(aeEventLoop *el, int fd, void *privdata, int mask) {
                     exit(1);
                 }
 
                     exit(1);
                 }
 

+                freeReplyObject(reply);
+

                 if (config.requests_finished < config.requests)
                     config.latency[config.requests_finished++] = c->latency;
                 c->pending--;
                 if (config.requests_finished < config.requests)
                     config.latency[config.requests_finished++] = c->latency;
                 c->pending--;


@@ -271,13 +273,11 @@ static client createClient(char *cmd, size_t len) {
 
     /* Find substrings in the output buffer that need to be randomized. */
     if (config.randomkeys) {
 
     /* Find substrings in the output buffer that need to be randomized. */
     if (config.randomkeys) {

-        char *p = c->obuf, *newline;
+        char *p = c->obuf;

         while ((p = strstr(p,":rand:")) != NULL) {
         while ((p = strstr(p,":rand:")) != NULL) {

-            newline = strstr(p,"\r\n");
-            assert(newline-(p+6) == 12); /* 12 chars for randomness */

             assert(c->randlen < (signed)(sizeof(c->randptr)/sizeof(char*)));
             c->randptr[c->randlen++] = p+6;
             assert(c->randlen < (signed)(sizeof(c->randptr)/sizeof(char*)));
             c->randptr[c->randlen++] = p+6;

-            p = newline+2;
+            p += 6;

         }
     }
 
         }
     }
 


@@ -292,7 +292,7 @@ static void createMissingClients(client c) {
     int n = 0;
 
     while(config.liveclients < config.numclients) {
     int n = 0;
 
     while(config.liveclients < config.numclients) {

-        createClient(c->obuf,sdslen(c->obuf));
+        createClient(c->obuf,sdslen(c->obuf)/config.pipeline);

 
         /* Listen backlog is quite limited on most systems */
         if (++n > 64) {
 
         /* Listen backlog is quite limited on most systems */
         if (++n > 64) {