Commit 17802424 authored by Pieter Noordhuis's avatar Pieter Noordhuis
Browse files

Use variable for throughput test iteration count

parent cd7063e8
...@@ -336,7 +336,7 @@ static void test_reply_reader(void) { ...@@ -336,7 +336,7 @@ static void test_reply_reader(void) {
} }
static void test_throughput(void) { static void test_throughput(void) {
int i; int i, num;
long long t1, t2; long long t1, t2;
redisContext *c = blocking_context; redisContext *c = blocking_context;
redisReply **replies; redisReply **replies;
...@@ -345,55 +345,57 @@ static void test_throughput(void) { ...@@ -345,55 +345,57 @@ static void test_throughput(void) {
for (i = 0; i < 500; i++) for (i = 0; i < 500; i++)
freeReplyObject(redisCommand(c,"LPUSH mylist foo")); freeReplyObject(redisCommand(c,"LPUSH mylist foo"));
replies = malloc(sizeof(redisReply*)*1000); num = 1000;
replies = malloc(sizeof(redisReply*)*num);
t1 = usec(); t1 = usec();
for (i = 0; i < 1000; i++) { for (i = 0; i < num; i++) {
replies[i] = redisCommand(c,"PING"); replies[i] = redisCommand(c,"PING");
assert(replies[i] != NULL && replies[i]->type == REDIS_REPLY_STATUS); assert(replies[i] != NULL && replies[i]->type == REDIS_REPLY_STATUS);
} }
t2 = usec(); t2 = usec();
for (i = 0; i < 1000; i++) freeReplyObject(replies[i]); for (i = 0; i < num; i++) freeReplyObject(replies[i]);
free(replies); free(replies);
printf("\t(1000x PING: %.3fs)\n", (t2-t1)/1000000.0); printf("\t(%dx PING: %.3fs)\n", num, (t2-t1)/1000000.0);
replies = malloc(sizeof(redisReply*)*1000); replies = malloc(sizeof(redisReply*)*num);
t1 = usec(); t1 = usec();
for (i = 0; i < 1000; i++) { for (i = 0; i < num; i++) {
replies[i] = redisCommand(c,"LRANGE mylist 0 499"); replies[i] = redisCommand(c,"LRANGE mylist 0 499");
assert(replies[i] != NULL && replies[i]->type == REDIS_REPLY_ARRAY); assert(replies[i] != NULL && replies[i]->type == REDIS_REPLY_ARRAY);
assert(replies[i] != NULL && replies[i]->elements == 500); assert(replies[i] != NULL && replies[i]->elements == 500);
} }
t2 = usec(); t2 = usec();
for (i = 0; i < 1000; i++) freeReplyObject(replies[i]); for (i = 0; i < num; i++) freeReplyObject(replies[i]);
free(replies); free(replies);
printf("\t(1000x LRANGE with 500 elements: %.3fs)\n", (t2-t1)/1000000.0); printf("\t(%dx LRANGE with 500 elements: %.3fs)\n", num, (t2-t1)/1000000.0);
replies = malloc(sizeof(redisReply*)*10000); num = 10000;
for (i = 0; i < 10000; i++) replies = malloc(sizeof(redisReply*)*num);
for (i = 0; i < num; i++)
redisAppendCommand(c,"PING"); redisAppendCommand(c,"PING");
t1 = usec(); t1 = usec();
for (i = 0; i < 10000; i++) { for (i = 0; i < num; i++) {
assert(redisGetReply(c, (void*)&replies[i]) == REDIS_OK); assert(redisGetReply(c, (void*)&replies[i]) == REDIS_OK);
assert(replies[i] != NULL && replies[i]->type == REDIS_REPLY_STATUS); assert(replies[i] != NULL && replies[i]->type == REDIS_REPLY_STATUS);
} }
t2 = usec(); t2 = usec();
for (i = 0; i < 10000; i++) freeReplyObject(replies[i]); for (i = 0; i < num; i++) freeReplyObject(replies[i]);
free(replies); free(replies);
printf("\t(10000x PING (pipelined): %.3fs)\n", (t2-t1)/1000000.0); printf("\t(%dx PING (pipelined): %.3fs)\n", num, (t2-t1)/1000000.0);
replies = malloc(sizeof(redisReply*)*10000); replies = malloc(sizeof(redisReply*)*num);
for (i = 0; i < 10000; i++) for (i = 0; i < num; i++)
redisAppendCommand(c,"LRANGE mylist 0 499"); redisAppendCommand(c,"LRANGE mylist 0 499");
t1 = usec(); t1 = usec();
for (i = 0; i < 10000; i++) { for (i = 0; i < num; i++) {
assert(redisGetReply(c, (void*)&replies[i]) == REDIS_OK); assert(redisGetReply(c, (void*)&replies[i]) == REDIS_OK);
assert(replies[i] != NULL && replies[i]->type == REDIS_REPLY_ARRAY); assert(replies[i] != NULL && replies[i]->type == REDIS_REPLY_ARRAY);
assert(replies[i] != NULL && replies[i]->elements == 500); assert(replies[i] != NULL && replies[i]->elements == 500);
} }
t2 = usec(); t2 = usec();
for (i = 0; i < 10000; i++) freeReplyObject(replies[i]); for (i = 0; i < num; i++) freeReplyObject(replies[i]);
free(replies); free(replies);
printf("\t(10000x LRANGE with 500 elements: %.3fs)\n", (t2-t1)/1000000.0); printf("\t(%dx LRANGE with 500 elements (pipelined): %.3fs)\n", num, (t2-t1)/1000000.0);
} }
static void cleanup(void) { static void cleanup(void) {
......
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