Permalink
Browse files

Add wait states to deal with many connections.

  • Loading branch information...
1 parent 1cd3c1e commit f474a5bd4e80157235dac13326edaa99181fb120 @dspezia dspezia committed with pietern Dec 18, 2010
Showing with 11 additions and 0 deletions.
  1. +11 −0 src/redis-benchmark.c
View
@@ -278,11 +278,22 @@ static client createClient(int replytype) {
}
static void createMissingClients(client c) {
+ int n = 0;
+
while(config.liveclients < config.numclients) {
client new = createClient(c->replytype);
new->obuf = sdsdup(c->obuf);
if (config.randomkeys) randomizeClientKey(c);
+
+ /* Listen backlog is quite limited on most systems */
+ if (++n > 64) {
+ usleep(50000);
+ n = 0;
+ }
}
+
+ /* Start the timer once the connection are established */
+ config.start = mstime();
}
static int compareLatency(const void *a, const void *b) {

0 comments on commit f474a5b

Please sign in to comment.